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 booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-06-01T15:40:50.907966+00:00 EmrCreateJobFlowOperator 2021-06-01T16:11:10.538583+00:00 2021-06-01T16:11:12.390140+00:00 0:00:01.851557 35206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T16:11:08.256318+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-06-01T15:40:50.907966+00:00 EmrCreateJobFlowOperator 2021-06-01T16:11:08.688905+00:00 2021-06-01T16:11:10.515785+00:00 0:00:01.826880 35205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T16:11:06.259125+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-06-01T15:05:00+00:00 PythonOperator 2021-06-01T16:10:55.949255+00:00 2021-06-01T16:10:59.313841+00:00 0:00:03.364586 35204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T16:10:52.236840+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-06-01T15:40:50.907966+00:00 PythonOperator 2021-06-01T16:10:49.495623+00:00 2021-06-01T16:10:54.166135+00:00 0:00:04.670512 35203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T16:10:46.232786+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-06-01T15:40:50.907966+00:00 PythonOperator 2021-06-01T16:10:47.216820+00:00 2021-06-01T16:10:50.973774+00:00 0:00:03.756954 35202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T16:10:44.222653+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-06-01T15:40:50.907966+00:00 TriggerDagRunOperator 2021-06-01T16:03:57.767754+00:00 2021-06-01T16:03:58.326226+00:00 0:00:00.558472 35200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T16:03:55.405380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-06-01T15:40:50.907966+00:00 TriggerDagRunOperator 2021-06-01T16:03:57.597230+00:00 2021-06-01T16:03:58.016838+00:00 0:00:00.419608 35199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T16:03:55.405418+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-06-01T15:00:00+00:00 EmrJobFlowSensor 2021-06-01T16:01:07.313198+00:00 2021-06-01T16:11:10.129961+00:00 0:10:02.816763 35198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T16:01:05.113895+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-06-01T15:00:00+00:00 EmrJobFlowSensor 2021-06-01T16:00:59.356650+00:00 2021-06-01T16:12:02.410350+00:00 0:11:03.053700 35197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T16:00:57.101288+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-06-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T16:00:45.890253+00:00 2021-06-01T16:00:47.538603+00:00 0:00:01.648350 35196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T16:00:43.092065+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-06-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T16:00:37.541981+00:00 2021-06-01T16:00:39.257362+00:00 0:00:01.715381 35195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-06-01T16:00:35.154890+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-06-01T15:00:00+00:00 PythonOperator 2021-06-01T16:00:23.581188+00:00 2021-06-01T16:00:26.857647+00:00 0:00:03.276459 35194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T16:00:21.148310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-06-01T15:00:00+00:00 PythonOperator 2021-06-01T16:00:17.137994+00:00 2021-06-01T16:00:20.445895+00:00 0:00:03.307901 35193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-06-01T16:00:14.987949+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-06-01T15:40:50.907966+00:00 EmrJobFlowSensor 2021-06-01T15:41:47.196034+00:00 2021-06-01T16:03:51.642866+00:00 0:22:04.446832 35192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T15:41:45.081526+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-06-01T15:40:50.907966+00:00 EmrCreateJobFlowOperator 2021-06-01T15:41:25.329876+00:00 2021-06-01T15:41:27.163039+00:00 0:00:01.833163 35191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-06-01T15:41:23.017723+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-06-01T15:40:50.907966+00:00 PythonOperator 2021-06-01T15:41:03.252033+00:00 2021-06-01T15:41:06.595711+00:00 0:00:03.343678 35190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-06-01T15:41:01.057256+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-06-01T14:00:00+00:00 EmrJobFlowSensor 2021-06-01T15:15:22.471390+00:00 2021-06-01T15:24:25.079467+00:00 0:09:02.608077 35189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T15:15:20.263028+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-06-01T14:00:00+00:00 EmrJobFlowSensor 2021-06-01T15:15:16.396014+00:00 2021-06-01T15:24:19.180379+00:00 0:09:02.784365 35188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T15:15:14.256251+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-06-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T15:15:00.520406+00:00 2021-06-01T15:15:02.377348+00:00 0:00:01.856942 35187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T15:14:58.259750+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-06-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T15:14:54.496617+00:00 2021-06-01T15:14:56.158304+00:00 0:00:01.661687 35186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T15:14:52.242715+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-06-01T14:00:00+00:00 PythonOperator 2021-06-01T15:14:40.504006+00:00 2021-06-01T15:14:43.699251+00:00 0:00:03.195245 35185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T15:14:38.227193+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-06-01T14:00:00+00:00 PythonOperator 2021-06-01T15:14:34.643424+00:00 2021-06-01T15:14:38.127831+00:00 0:00:03.484407 35184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T15:14:32.212125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-06-01T14:00:00+00:00 TriggerDagRunOperator 2021-06-01T15:14:15.122053+00:00 2021-06-01T15:14:15.628272+00:00 0:00:00.506219 35183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T15:14:12.204731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-06-01T14:00:00+00:00 TriggerDagRunOperator 2021-06-01T15:14:14.697070+00:00 2021-06-01T15:14:15.278974+00:00 0:00:00.581904 35182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T15:14:12.204764+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-06-01T14:05:00+00:00 EmrJobFlowSensor 2021-06-01T15:05:47.629630+00:00 2021-06-01T15:15:50.140889+00:00 0:10:02.511259 35181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T15:05:45.495871+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-06-01T14:05:00+00:00 EmrCreateJobFlowOperator 2021-06-01T15:05:25.814418+00:00 2021-06-01T15:05:27.609307+00:00 0:00:01.794889 35180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T15:05:23.425842+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-06-01T14:05:00+00:00 PythonOperator 2021-06-01T15:05:06.323928+00:00 2021-06-01T15:05:09.468202+00:00 0:00:03.144274 35179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T15:05:03.390022+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-06-01T14:00:00+00:00 EmrJobFlowSensor 2021-06-01T15:05:05.586920+00:00 2021-06-01T15:14:08.129523+00:00 0:09:02.542603 35178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T15:05:03.390052+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-06-01T14:00:00+00:00 EmrJobFlowSensor 2021-06-01T15:05:04.059339+00:00 2021-06-01T15:14:07.148546+00:00 0:09:03.089207 35177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T15:05:01.387679+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-06-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T15:04:43.633402+00:00 2021-06-01T15:04:45.464112+00:00 0:00:01.830710 35176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-06-01T15:04:41.256265+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-06-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T15:04:41.489976+00:00 2021-06-01T15:04:43.184988+00:00 0:00:01.695012 35175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T15:04:39.260153+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-06-01T14:00:00+00:00 PythonOperator 2021-06-01T15:04:19.908414+00:00 2021-06-01T15:04:23.187957+00:00 0:00:03.279543 35174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-06-01T15:04:17.233146+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-06-01T14:00:00+00:00 PythonOperator 2021-06-01T15:04:19.797248+00:00 2021-06-01T15:04:23.197223+00:00 0:00:03.399975 35173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T15:04:17.233174+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-06-01T13:00:00+00:00 EmrJobFlowSensor 2021-06-01T14:11:27.823692+00:00 2021-06-01T14:21:30.710907+00:00 0:10:02.887215 35171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T14:11:25.456627+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-06-01T13:00:00+00:00 EmrJobFlowSensor 2021-06-01T14:11:11.824751+00:00 2021-06-01T14:20:14.434478+00:00 0:09:02.609727 35170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T14:11:09.448289+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-06-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T14:11:07.807422+00:00 2021-06-01T14:11:09.671557+00:00 0:00:01.864135 35169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T14:11:05.454431+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-06-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T14:10:49.687115+00:00 2021-06-01T14:10:51.491278+00:00 0:00:01.804163 35168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T14:10:47.320843+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-06-01T13:00:00+00:00 PythonOperator 2021-06-01T14:10:45.630077+00:00 2021-06-01T14:10:49.174538+00:00 0:00:03.544461 35167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T14:10:43.317062+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-06-01T13:00:00+00:00 PythonOperator 2021-06-01T14:10:30.018685+00:00 2021-06-01T14:10:33.351516+00:00 0:00:03.332831 35166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T14:10:27.303739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-06-01T13:00:00+00:00 TriggerDagRunOperator 2021-06-01T14:10:21.530316+00:00 2021-06-01T14:10:22.065206+00:00 0:00:00.534890 35165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T14:10:19.264641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-06-01T13:00:00+00:00 TriggerDagRunOperator 2021-06-01T14:10:21.495150+00:00 2021-06-01T14:10:21.910851+00:00 0:00:00.415701 35164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T14:10:19.264669+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-06-01T13:05:00+00:00 EmrJobFlowSensor 2021-06-01T14:05:55.276688+00:00 2021-06-01T14:14:57.712476+00:00 0:09:02.435788 35163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T14:05:52.946994+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-06-01T13:05:00+00:00 EmrCreateJobFlowOperator 2021-06-01T14:05:35.174044+00:00 2021-06-01T14:05:36.917743+00:00 0:00:01.743699 35162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T14:05:32.794660+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-06-01T13:05:00+00:00 PythonOperator 2021-06-01T14:05:13.134709+00:00 2021-06-01T14:05:16.285773+00:00 0:00:03.151064 35161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T14:05:10.760386+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-06-01T13:00:00+00:00 EmrJobFlowSensor 2021-06-01T14:01:04.697071+00:00 2021-06-01T14:10:07.327064+00:00 0:09:02.629993 35160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T14:01:02.191025+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-06-01T13:00:00+00:00 EmrJobFlowSensor 2021-06-01T14:00:48.566004+00:00 2021-06-01T14:10:51.337160+00:00 0:10:02.771156 35159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T14:00:46.163787+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-06-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T14:00:42.440057+00:00 2021-06-01T14:00:44.165049+00:00 0:00:01.724992 35158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-06-01T14:00:40.161917+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-06-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T14:00:26.467231+00:00 2021-06-01T14:00:28.325315+00:00 0:00:01.858084 35157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T14:00:24.108681+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-06-01T13:00:00+00:00 PythonOperator 2021-06-01T14:00:20.388361+00:00 2021-06-01T14:00:23.681179+00:00 0:00:03.292818 35156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-06-01T14:00:18.101130+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-06-01T13:00:00+00:00 PythonOperator 2021-06-01T14:00:06.414451+00:00 2021-06-01T14:00:09.799493+00:00 0:00:03.385042 35155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T14:00:04.085494+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-06-01T12:00:00+00:00 EmrJobFlowSensor 2021-06-01T13:11:08.635212+00:00 2021-06-01T13:20:11.271679+00:00 0:09:02.636467 35153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T13:11:05.804846+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-06-01T12:00:00+00:00 EmrJobFlowSensor 2021-06-01T13:11:06.419577+00:00 2021-06-01T13:21:09.600957+00:00 0:10:03.181380 35152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T13:11:03.868506+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-06-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T13:10:46.215165+00:00 2021-06-01T13:10:47.987809+00:00 0:00:01.772644 35151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T13:10:43.861829+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-06-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T13:10:46.213837+00:00 2021-06-01T13:10:48.082606+00:00 0:00:01.868769 35150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T13:10:43.861799+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-06-01T12:00:00+00:00 PythonOperator 2021-06-01T13:10:24.289260+00:00 2021-06-01T13:10:27.699364+00:00 0:00:03.410104 35149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T13:10:21.757745+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-06-01T12:00:00+00:00 PythonOperator 2021-06-01T13:10:24.197319+00:00 2021-06-01T13:10:27.674180+00:00 0:00:03.476861 35148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T13:10:21.757781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-06-01T12:00:00+00:00 TriggerDagRunOperator 2021-06-01T13:10:10.466196+00:00 2021-06-01T13:10:10.959336+00:00 0:00:00.493140 35147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T13:10:07.749403+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-06-01T12:00:00+00:00 TriggerDagRunOperator 2021-06-01T13:10:10.323933+00:00 2021-06-01T13:10:10.946884+00:00 0:00:00.622951 35146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T13:10:07.749446+00:00 2 default_pool
success promote_lab_audience_to_prd_v01 promote_lab_audience_to_prd 2021-06-01T13:06:16.932716+00:00 PythonOperator 2021-06-01T13:06:38.857212+00:00 2021-06-01T13:07:01.374196+00:00 0:00:22.516984 35145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T13:06:35.442937+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-06-01T12:05:00+00:00 EmrJobFlowSensor 2021-06-01T13:06:03.472621+00:00 2021-06-01T13:15:06.152529+00:00 0:09:02.679908 35144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T13:06:01.333977+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-06-01T12:05:00+00:00 EmrCreateJobFlowOperator 2021-06-01T13:05:33.733328+00:00 2021-06-01T13:05:35.518861+00:00 0:00:01.785533 35143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T13:05:31.301651+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-06-01T12:05:00+00:00 PythonOperator 2021-06-01T13:05:11.642885+00:00 2021-06-01T13:05:14.887664+00:00 0:00:03.244779 35142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T13:05:09.353834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-06-01T12:00:00+00:00 EmrJobFlowSensor 2021-06-01T13:01:03.127294+00:00 2021-06-01T13:10:05.907725+00:00 0:09:02.780431 35141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T13:01:00.885171+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-06-01T12:00:00+00:00 EmrJobFlowSensor 2021-06-01T13:00:59.052289+00:00 2021-06-01T13:10:01.760346+00:00 0:09:02.708057 35140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T13:00:56.883377+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-06-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T13:00:41.015126+00:00 2021-06-01T13:00:42.832543+00:00 0:00:01.817417 35139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-06-01T13:00:38.860128+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-06-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T13:00:37.113336+00:00 2021-06-01T13:00:38.907258+00:00 0:00:01.793922 35138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T13:00:34.855359+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-06-01T12:00:00+00:00 PythonOperator 2021-06-01T13:00:19.002108+00:00 2021-06-01T13:00:22.330548+00:00 0:00:03.328440 35137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-06-01T13:00:16.799175+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-06-01T12:00:00+00:00 PythonOperator 2021-06-01T13:00:15.336543+00:00 2021-06-01T13:00:18.537386+00:00 0:00:03.200843 35136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T13:00:12.852194+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-06-01T11:00:00+00:00 EmrJobFlowSensor 2021-06-01T12:10:28.219644+00:00 2021-06-01T12:19:30.937772+00:00 0:09:02.718128 35134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T12:10:25.969562+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-06-01T11:00:00+00:00 EmrJobFlowSensor 2021-06-01T12:10:18.116607+00:00 2021-06-01T12:20:20.950534+00:00 0:10:02.833927 35133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T12:10:15.961734+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-06-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T12:10:08.343088+00:00 2021-06-01T12:10:10.078723+00:00 0:00:01.735635 35132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T12:10:05.953039+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-06-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T12:09:58.682701+00:00 2021-06-01T12:10:00.495583+00:00 0:00:01.812882 35131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T12:09:55.946910+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-06-01T11:00:00+00:00 PythonOperator 2021-06-01T12:09:46.257402+00:00 2021-06-01T12:09:49.378708+00:00 0:00:03.121306 35130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T12:09:43.961629+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-06-01T11:00:00+00:00 PythonOperator 2021-06-01T12:09:36.392238+00:00 2021-06-01T12:09:39.884985+00:00 0:00:03.492747 35129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T12:09:33.948891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-06-01T11:00:00+00:00 TriggerDagRunOperator 2021-06-01T12:09:22.191811+00:00 2021-06-01T12:09:22.635307+00:00 0:00:00.443496 35128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T12:09:19.884617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-06-01T11:00:00+00:00 TriggerDagRunOperator 2021-06-01T12:09:22.126630+00:00 2021-06-01T12:09:22.750635+00:00 0:00:00.624005 35127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T12:09:19.884655+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-06-01T11:05:00+00:00 EmrJobFlowSensor 2021-06-01T12:05:47.617661+00:00 2021-06-01T12:14:50.297446+00:00 0:09:02.679785 35126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T12:05:45.420460+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-06-01T11:05:00+00:00 EmrCreateJobFlowOperator 2021-06-01T12:05:27.623460+00:00 2021-06-01T12:05:29.275314+00:00 0:00:01.651854 35125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T12:05:25.404204+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-06-01T11:05:00+00:00 PythonOperator 2021-06-01T12:05:05.559554+00:00 2021-06-01T12:05:08.825006+00:00 0:00:03.265452 35124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T12:05:03.399189+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-06-01T11:00:00+00:00 EmrJobFlowSensor 2021-06-01T12:01:13.231923+00:00 2021-06-01T12:09:15.708853+00:00 0:08:02.476930 35123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T12:01:11.019175+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-06-01T11:00:00+00:00 EmrJobFlowSensor 2021-06-01T12:01:09.306184+00:00 2021-06-01T12:10:12.045648+00:00 0:09:02.739464 35122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T12:01:07.014192+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-06-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T12:00:47.233723+00:00 2021-06-01T12:00:49.040958+00:00 0:00:01.807235 35121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-06-01T12:00:44.994012+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-06-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T12:00:41.167233+00:00 2021-06-01T12:00:42.866569+00:00 0:00:01.699336 35120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T12:00:38.988527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-06-01T11:00:00+00:00 PythonOperator 2021-06-01T12:00:17.806757+00:00 2021-06-01T12:00:21.603970+00:00 0:00:03.797213 35119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-06-01T12:00:14.894101+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-06-01T11:00:00+00:00 PythonOperator 2021-06-01T12:00:13.354923+00:00 2021-06-01T12:00:17.464073+00:00 0:00:04.109150 35118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T12:00:10.898943+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-06-01T10:00:00+00:00 EmrJobFlowSensor 2021-06-01T11:12:51.541366+00:00 2021-06-01T11:22:54.262407+00:00 0:10:02.721041 35116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T11:12:49.149207+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-06-01T10:00:00+00:00 EmrJobFlowSensor 2021-06-01T11:12:37.317201+00:00 2021-06-01T11:21:39.891054+00:00 0:09:02.573853 35115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T11:12:35.088378+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-06-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T11:12:29.598692+00:00 2021-06-01T11:12:31.406424+00:00 0:00:01.807732 35114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T11:12:27.078814+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-06-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T11:12:15.314101+00:00 2021-06-01T11:12:17.126795+00:00 0:00:01.812694 35113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T11:12:12.993110+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-06-01T10:00:00+00:00 PythonOperator 2021-06-01T11:12:09.409603+00:00 2021-06-01T11:12:12.975173+00:00 0:00:03.565570 35112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T11:12:07.053154+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-06-01T10:00:00+00:00 PythonOperator 2021-06-01T11:11:55.192214+00:00 2021-06-01T11:11:58.545225+00:00 0:00:03.353011 35111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T11:11:52.930954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-06-01T10:00:00+00:00 TriggerDagRunOperator 2021-06-01T11:11:49.506288+00:00 2021-06-01T11:11:50.048678+00:00 0:00:00.542390 35110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T11:11:46.936285+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-06-01T10:00:00+00:00 TriggerDagRunOperator 2021-06-01T11:11:49.232321+00:00 2021-06-01T11:11:49.674940+00:00 0:00:00.442619 35109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T11:11:46.936251+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-06-01T10:05:00+00:00 EmrJobFlowSensor 2021-06-01T11:05:58.543740+00:00 2021-06-01T11:15:01.045393+00:00 0:09:02.501653 35108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T11:05:56.370774+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-06-01T10:05:00+00:00 EmrCreateJobFlowOperator 2021-06-01T11:05:38.632590+00:00 2021-06-01T11:05:40.272728+00:00 0:00:01.640138 35107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T11:05:36.289528+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-06-01T10:05:00+00:00 PythonOperator 2021-06-01T11:05:14.566777+00:00 2021-06-01T11:05:17.717949+00:00 0:00:03.151172 35106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T11:05:12.251563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-06-01T10:00:00+00:00 EmrJobFlowSensor 2021-06-01T11:01:08.183372+00:00 2021-06-01T11:11:11.026403+00:00 0:10:02.843031 35105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T11:01:05.879360+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-06-01T10:00:00+00:00 EmrJobFlowSensor 2021-06-01T11:01:02.258323+00:00 2021-06-01T11:11:05.102333+00:00 0:10:02.844010 35104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T11:00:59.861507+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-06-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T11:00:45.940491+00:00 2021-06-01T11:00:47.648793+00:00 0:00:01.708302 35103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-06-01T11:00:43.753698+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-06-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T11:00:39.897709+00:00 2021-06-01T11:00:41.610144+00:00 0:00:01.712435 35102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T11:00:37.741255+00:00 2 default_pool