Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-03-26T08:00:00+00:00 PythonOperator 2021-03-26T09:00:08.779789+00:00 2021-03-26T09:00:11.654853+00:00 0:00:02.875064 11819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T09:00:05.951099+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T07:00:00+00:00 EmrJobFlowSensor 2021-03-26T08:11:14.389894+00:00 2021-03-26T08:21:17.386091+00:00 0:10:02.996197 11817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:11:11.995158+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T08:10:51.990306+00:00 2021-03-26T08:10:53.748518+00:00 0:00:01.758212 11816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T08:10:49.852151+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T07:00:00+00:00 PythonOperator 2021-03-26T08:10:30.595279+00:00 2021-03-26T08:10:33.598671+00:00 0:00:03.003392 11815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T08:10:27.846255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T07:00:00+00:00 TriggerDagRunOperator 2021-03-26T08:10:18.089511+00:00 2021-03-26T08:10:18.506185+00:00 0:00:00.416674 11814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:10:15.826730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T07:00:00+00:00 TriggerDagRunOperator 2021-03-26T08:10:18.124625+00:00 2021-03-26T08:10:18.682615+00:00 0:00:00.557990 11813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:10:15.826702+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T07:05:00+00:00 EmrJobFlowSensor 2021-03-26T08:06:07.473389+00:00 2021-03-26T08:15:10.073178+00:00 0:09:02.599789 11812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:06:05.353199+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T08:05:45.677139+00:00 2021-03-26T08:05:47.306891+00:00 0:00:01.629752 11811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T08:05:43.344468+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T07:05:00+00:00 PythonOperator 2021-03-26T08:05:23.746601+00:00 2021-03-26T08:05:26.513492+00:00 0:00:02.766891 11810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T08:05:21.277135+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T07:00:00+00:00 EmrJobFlowSensor 2021-03-26T08:01:06.903364+00:00 2021-03-26T08:10:09.654338+00:00 0:09:02.750974 11809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T08:01:04.651645+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T08:00:40.817466+00:00 2021-03-26T08:00:42.505073+00:00 0:00:01.687607 11808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T08:00:38.594283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T07:00:00+00:00 PythonOperator 2021-03-26T08:00:18.941310+00:00 2021-03-26T08:00:21.757189+00:00 0:00:02.815879 11807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T08:00:16.550415+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T06:00:00+00:00 EmrJobFlowSensor 2021-03-26T07:11:00.172641+00:00 2021-03-26T07:22:03.238498+00:00 0:11:03.065857 11805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:10:57.784221+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T07:10:37.980943+00:00 2021-03-26T07:10:39.750182+00:00 0:00:01.769239 11804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T07:10:35.720282+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T06:00:00+00:00 PythonOperator 2021-03-26T07:10:13.929279+00:00 2021-03-26T07:10:17.055464+00:00 0:00:03.126185 11803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T07:10:11.687142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T06:00:00+00:00 TriggerDagRunOperator 2021-03-26T07:10:06.089180+00:00 2021-03-26T07:10:06.529873+00:00 0:00:00.440693 11802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:10:03.651167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T06:00:00+00:00 TriggerDagRunOperator 2021-03-26T07:10:05.979108+00:00 2021-03-26T07:10:06.539408+00:00 0:00:00.560300 11801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:10:03.651127+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T06:05:00+00:00 EmrJobFlowSensor 2021-03-26T07:06:09.538806+00:00 2021-03-26T07:14:12.038431+00:00 0:08:02.499625 11800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:06:07.341943+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T06:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T07:05:49.471581+00:00 2021-03-26T07:05:51.136074+00:00 0:00:01.664493 11799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T07:05:47.320828+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T06:05:00+00:00 PythonOperator 2021-03-26T07:05:23.746095+00:00 2021-03-26T07:05:26.563098+00:00 0:00:02.817003 11798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T07:05:21.299269+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T06:00:00+00:00 EmrJobFlowSensor 2021-03-26T07:00:51.030247+00:00 2021-03-26T07:09:53.687979+00:00 0:09:02.657732 11797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T07:00:48.706545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T07:00:28.835277+00:00 2021-03-26T07:00:30.562539+00:00 0:00:01.727262 11796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T07:00:26.689317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T06:00:00+00:00 PythonOperator 2021-03-26T07:00:07.000610+00:00 2021-03-26T07:00:09.704696+00:00 0:00:02.704086 11795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T07:00:04.593264+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T05:00:00+00:00 EmrJobFlowSensor 2021-03-26T06:12:04.204559+00:00 2021-03-26T06:22:06.888345+00:00 0:10:02.683786 11793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T06:12:01.655385+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T06:11:41.731910+00:00 2021-03-26T06:11:43.514876+00:00 0:00:01.782966 11792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T06:11:39.525534+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T05:00:00+00:00 PythonOperator 2021-03-26T06:11:19.869862+00:00 2021-03-26T06:11:22.927911+00:00 0:00:03.058049 11791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T06:11:17.517808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T05:00:00+00:00 TriggerDagRunOperator 2021-03-26T06:11:11.870793+00:00 2021-03-26T06:11:12.269793+00:00 0:00:00.399000 11790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T06:11:09.504720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T05:00:00+00:00 TriggerDagRunOperator 2021-03-26T06:11:11.671475+00:00 2021-03-26T06:11:12.204361+00:00 0:00:00.532886 11789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T06:11:09.504752+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T05:05:00+00:00 EmrJobFlowSensor 2021-03-26T06:05:55.237402+00:00 2021-03-26T06:14:57.880510+00:00 0:09:02.643108 11788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T06:05:53.067835+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T05:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T06:05:33.367171+00:00 2021-03-26T06:05:35.111612+00:00 0:00:01.744441 11787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T06:05:31.062022+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T05:05:00+00:00 PythonOperator 2021-03-26T06:05:11.245958+00:00 2021-03-26T06:05:13.961103+00:00 0:00:02.715145 11786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T06:05:09.044306+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T05:00:00+00:00 EmrJobFlowSensor 2021-03-26T06:01:02.516407+00:00 2021-03-26T06:11:05.396845+00:00 0:10:02.880438 11785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T06:01:00.313320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T06:00:38.653748+00:00 2021-03-26T06:00:40.429484+00:00 0:00:01.775736 11784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T06:00:36.299311+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T05:00:00+00:00 PythonOperator 2021-03-26T06:00:15.065965+00:00 2021-03-26T06:00:17.810803+00:00 0:00:02.744838 11783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T06:00:12.280670+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T04:00:00+00:00 EmrJobFlowSensor 2021-03-26T05:11:22.913177+00:00 2021-03-26T05:21:25.756675+00:00 0:10:02.843498 11781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T05:11:20.723168+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T05:11:01.190351+00:00 2021-03-26T05:11:03.026052+00:00 0:00:01.835701 11780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T05:10:58.850136+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T04:00:00+00:00 PythonOperator 2021-03-26T05:10:39.082178+00:00 2021-03-26T05:10:42.103533+00:00 0:00:03.021355 11779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T05:10:36.688551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T04:00:00+00:00 TriggerDagRunOperator 2021-03-26T05:10:28.939864+00:00 2021-03-26T05:10:29.333628+00:00 0:00:00.393764 11778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T05:10:26.645657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T04:00:00+00:00 TriggerDagRunOperator 2021-03-26T05:10:28.929408+00:00 2021-03-26T05:10:29.434918+00:00 0:00:00.505510 11777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T05:10:26.645726+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T04:05:00+00:00 EmrJobFlowSensor 2021-03-26T05:06:04.462103+00:00 2021-03-26T05:15:07.254052+00:00 0:09:02.791949 11776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T05:06:02.291958+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T04:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T05:05:44.434273+00:00 2021-03-26T05:05:46.183609+00:00 0:00:01.749336 11775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T05:05:42.242344+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T04:05:00+00:00 PythonOperator 2021-03-26T05:05:22.522237+00:00 2021-03-26T05:05:25.302854+00:00 0:00:02.780617 11774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T05:05:20.240458+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T04:00:00+00:00 EmrJobFlowSensor 2021-03-26T05:01:08.067570+00:00 2021-03-26T05:10:10.661390+00:00 0:09:02.593820 11773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T05:01:05.908392+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T05:00:46.185081+00:00 2021-03-26T05:00:47.903778+00:00 0:00:01.718697 11772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T05:00:43.891373+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T04:00:00+00:00 PythonOperator 2021-03-26T05:00:24.269235+00:00 2021-03-26T05:00:26.962069+00:00 0:00:02.692834 11771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T05:00:21.856645+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T03:00:00+00:00 EmrJobFlowSensor 2021-03-26T04:12:33.805501+00:00 2021-03-26T04:22:36.645223+00:00 0:10:02.839722 11769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T04:12:31.573676+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T04:12:09.699631+00:00 2021-03-26T04:12:11.393028+00:00 0:00:01.693397 11768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T04:12:07.544013+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T03:00:00+00:00 PythonOperator 2021-03-26T04:11:45.790389+00:00 2021-03-26T04:11:48.972569+00:00 0:00:03.182180 11767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T04:11:43.573959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T03:00:00+00:00 TriggerDagRunOperator 2021-03-26T04:11:23.876908+00:00 2021-03-26T04:11:24.557782+00:00 0:00:00.680874 11766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T04:11:21.441820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T03:00:00+00:00 TriggerDagRunOperator 2021-03-26T04:11:23.808921+00:00 2021-03-26T04:11:24.418748+00:00 0:00:00.609827 11765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T04:11:21.441783+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T03:05:00+00:00 EmrJobFlowSensor 2021-03-26T04:06:07.288746+00:00 2021-03-26T04:15:09.995224+00:00 0:09:02.706478 11764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T04:06:05.087084+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T03:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T04:05:45.268916+00:00 2021-03-26T04:05:46.911350+00:00 0:00:01.642434 11763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T04:05:42.994151+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T03:05:00+00:00 PythonOperator 2021-03-26T04:05:23.195773+00:00 2021-03-26T04:05:26.164212+00:00 0:00:02.968439 11762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T04:05:20.924813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T03:00:00+00:00 EmrJobFlowSensor 2021-03-26T04:01:12.655714+00:00 2021-03-26T04:11:15.468364+00:00 0:10:02.812650 11761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T04:01:10.466874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T04:00:52.603270+00:00 2021-03-26T04:00:54.362288+00:00 0:00:01.759018 11760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T04:00:50.432596+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T03:00:00+00:00 PythonOperator 2021-03-26T04:00:24.985587+00:00 2021-03-26T04:00:27.732953+00:00 0:00:02.747366 11759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T04:00:22.411033+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T02:00:00+00:00 EmrJobFlowSensor 2021-03-26T03:11:00.658385+00:00 2021-03-26T03:21:03.468663+00:00 0:10:02.810278 11757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T03:10:58.252121+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T03:10:38.506331+00:00 2021-03-26T03:10:40.241040+00:00 0:00:01.734709 11756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T03:10:36.051797+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T02:00:00+00:00 PythonOperator 2021-03-26T03:10:16.432426+00:00 2021-03-26T03:10:19.524902+00:00 0:00:03.092476 11755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T03:10:14.052150+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T02:00:00+00:00 TriggerDagRunOperator 2021-03-26T03:10:08.718880+00:00 2021-03-26T03:10:09.184204+00:00 0:00:00.465324 11754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T03:10:05.941577+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T02:00:00+00:00 TriggerDagRunOperator 2021-03-26T03:10:08.363425+00:00 2021-03-26T03:10:08.879825+00:00 0:00:00.516400 11753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T03:10:05.941608+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T02:05:00+00:00 EmrJobFlowSensor 2021-03-26T03:06:05.763661+00:00 2021-03-26T03:15:08.346798+00:00 0:09:02.583137 11752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T03:06:03.542376+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T02:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T03:05:45.704335+00:00 2021-03-26T03:05:47.419290+00:00 0:00:01.714955 11751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T03:05:43.522338+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T02:05:00+00:00 PythonOperator 2021-03-26T03:05:23.988781+00:00 2021-03-26T03:05:26.822433+00:00 0:00:02.833652 11750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T03:05:21.558905+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T02:00:00+00:00 EmrJobFlowSensor 2021-03-26T03:00:57.388883+00:00 2021-03-26T03:10:00.179782+00:00 0:09:02.790899 11749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T03:00:55.185865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T03:00:35.494865+00:00 2021-03-26T03:00:37.178972+00:00 0:00:01.684107 11748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T03:00:33.185348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T02:00:00+00:00 PythonOperator 2021-03-26T03:00:13.623999+00:00 2021-03-26T03:00:16.522726+00:00 0:00:02.898727 11747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T03:00:11.086950+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T01:00:00+00:00 EmrJobFlowSensor 2021-03-26T02:10:44.603229+00:00 2021-03-26T02:20:47.564527+00:00 0:10:02.961298 11745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T02:10:42.262850+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T02:10:24.445063+00:00 2021-03-26T02:10:26.247222+00:00 0:00:01.802159 11744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T02:10:22.212112+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T01:00:00+00:00 PythonOperator 2021-03-26T02:10:02.706364+00:00 2021-03-26T02:10:05.627416+00:00 0:00:02.921052 11743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T02:10:00.268446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T01:00:00+00:00 TriggerDagRunOperator 2021-03-26T02:09:58.560308+00:00 2021-03-26T02:09:59.058658+00:00 0:00:00.498350 11742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T02:09:56.119381+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T01:00:00+00:00 TriggerDagRunOperator 2021-03-26T02:09:58.371687+00:00 2021-03-26T02:09:58.792985+00:00 0:00:00.421298 11741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T02:09:56.119344+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T01:05:00+00:00 EmrJobFlowSensor 2021-03-26T02:06:09.912780+00:00 2021-03-26T02:14:12.455418+00:00 0:08:02.542638 11740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T02:06:07.743914+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T01:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T02:05:37.915347+00:00 2021-03-26T02:05:39.672407+00:00 0:00:01.757060 11739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T02:05:35.716661+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T01:05:00+00:00 PythonOperator 2021-03-26T02:05:11.826777+00:00 2021-03-26T02:05:14.560215+00:00 0:00:02.733438 11738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T02:05:09.690059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T01:00:00+00:00 EmrJobFlowSensor 2021-03-26T02:00:49.510650+00:00 2021-03-26T02:09:52.359143+00:00 0:09:02.848493 11737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T02:00:47.229423+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T02:00:27.466116+00:00 2021-03-26T02:00:29.202756+00:00 0:00:01.736640 11736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T02:00:25.211645+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T01:00:00+00:00 PythonOperator 2021-03-26T02:00:05.852734+00:00 2021-03-26T02:00:08.735784+00:00 0:00:02.883050 11735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T02:00:03.340862+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T00:00:00+00:00 EmrJobFlowSensor 2021-03-26T01:11:23.951669+00:00 2021-03-26T01:21:26.949380+00:00 0:10:02.997711 11733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:11:21.544368+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T01:11:01.623838+00:00 2021-03-26T01:11:03.343155+00:00 0:00:01.719317 11732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T01:10:59.371603+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T00:00:00+00:00 PythonOperator 2021-03-26T01:10:39.598563+00:00 2021-03-26T01:10:42.587038+00:00 0:00:02.988475 11731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T01:10:37.349265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T00:00:00+00:00 TriggerDagRunOperator 2021-03-26T01:10:15.572392+00:00 2021-03-26T01:10:16.085027+00:00 0:00:00.512635 11730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:10:13.299205+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T00:00:00+00:00 TriggerDagRunOperator 2021-03-26T01:10:15.526748+00:00 2021-03-26T01:10:15.939477+00:00 0:00:00.412729 11729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:10:13.299174+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T00:05:00+00:00 EmrJobFlowSensor 2021-03-26T01:06:10.966555+00:00 2021-03-26T01:15:13.656421+00:00 0:09:02.689866 11728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:06:08.804801+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T00:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T01:05:49.281609+00:00 2021-03-26T01:05:50.906493+00:00 0:00:01.624884 11727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T01:05:46.864093+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T00:05:00+00:00 PythonOperator 2021-03-26T01:05:26.872484+00:00 2021-03-26T01:05:29.596363+00:00 0:00:02.723879 11726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T01:05:24.731550+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T00:00:00+00:00 EmrJobFlowSensor 2021-03-26T01:00:58.815664+00:00 2021-03-26T01:10:01.536248+00:00 0:09:02.720584 11725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T01:00:56.444303+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T01:00:38.595713+00:00 2021-03-26T01:00:40.297282+00:00 0:00:01.701569 11724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T01:00:36.336179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T00:00:00+00:00 PythonOperator 2021-03-26T01:00:16.589277+00:00 2021-03-26T01:00:19.368373+00:00 0:00:02.779096 11723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T01:00:14.230709+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T23:00:00+00:00 EmrJobFlowSensor 2021-03-26T00:10:27.831070+00:00 2021-03-26T00:20:30.654707+00:00 0:10:02.823637 11721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:10:25.544801+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T00:10:07.712104+00:00 2021-03-26T00:10:09.457212+00:00 0:00:01.745108 11720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T00:10:05.528707+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T23:00:00+00:00 PythonOperator 2021-03-26T00:09:43.721045+00:00 2021-03-26T00:09:46.746240+00:00 0:00:03.025195 11719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T00:09:41.509142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T23:00:00+00:00 TriggerDagRunOperator 2021-03-26T00:09:38.067997+00:00 2021-03-26T00:09:38.922637+00:00 0:00:00.854640 11718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:09:35.570990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T23:00:00+00:00 TriggerDagRunOperator 2021-03-26T00:09:37.867604+00:00 2021-03-26T00:09:38.260681+00:00 0:00:00.393077 11717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:09:35.570941+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T23:05:00+00:00 EmrJobFlowSensor 2021-03-26T00:06:07.363182+00:00 2021-03-26T00:15:09.943456+00:00 0:09:02.580274 11716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:06:05.217039+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T23:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T00:05:45.687057+00:00 2021-03-26T00:05:47.326572+00:00 0:00:01.639515 11715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T00:05:43.263762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T23:05:00+00:00 PythonOperator 2021-03-26T00:05:23.778636+00:00 2021-03-26T00:05:26.608828+00:00 0:00:02.830192 11714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T00:05:21.184296+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T23:00:00+00:00 EmrJobFlowSensor 2021-03-26T00:01:15.011372+00:00 2021-03-26T00:09:17.632450+00:00 0:08:02.621078 11713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T00:01:12.783093+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T00:00:53.062891+00:00 2021-03-26T00:00:54.751089+00:00 0:00:01.688198 11712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T00:00:50.784284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T23:00:00+00:00 PythonOperator 2021-03-26T00:00:24.972656+00:00 2021-03-26T00:00:27.697785+00:00 0:00:02.725129 11711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T00:00:22.730375+00:00 2 default_pool