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_cluster_and_add_emr_steps 2021-03-24T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T22:00:41.636671+00:00 2021-03-24T22:00:43.418542+00:00 0:00:01.781871 11382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T22:00:39.416729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T21:00:00+00:00 PythonOperator 2021-03-24T22:00:13.708923+00:00 2021-03-24T22:00:16.562397+00:00 0:00:02.853474 11381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T22:00:11.395655+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T20:00:00+00:00 EmrJobFlowSensor 2021-03-24T21:11:21.029553+00:00 2021-03-24T21:20:23.665819+00:00 0:09:02.636266 11379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:11:18.759524+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T20:00:00+00:00 EmrJobFlowSensor 2021-03-24T21:11:04.894776+00:00 2021-03-24T21:20:07.483143+00:00 0:09:02.588367 11378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:11:02.687561+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T21:10:58.804262+00:00 2021-03-24T21:11:00.551221+00:00 0:00:01.746959 11377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T21:10:56.635790+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T21:10:42.884571+00:00 2021-03-24T21:10:44.564535+00:00 0:00:01.679964 11376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T21:10:40.615125+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T20:00:00+00:00 PythonOperator 2021-03-24T21:10:38.793504+00:00 2021-03-24T21:10:41.605799+00:00 0:00:02.812295 11375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T21:10:36.622123+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T20:00:00+00:00 PythonOperator 2021-03-24T21:10:20.968537+00:00 2021-03-24T21:10:24.033024+00:00 0:00:03.064487 11374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T21:10:18.666100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T20:00:00+00:00 TriggerDagRunOperator 2021-03-24T21:10:12.850967+00:00 2021-03-24T21:10:13.363481+00:00 0:00:00.512514 11373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:10:10.592498+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T20:00:00+00:00 TriggerDagRunOperator 2021-03-24T21:10:12.820437+00:00 2021-03-24T21:10:13.221884+00:00 0:00:00.401447 11372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:10:10.592531+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T20:05:00+00:00 EmrJobFlowSensor 2021-03-24T21:05:48.320057+00:00 2021-03-24T21:14:50.861873+00:00 0:09:02.541816 11371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:05:46.192761+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T20:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T21:05:28.443710+00:00 2021-03-24T21:05:30.168419+00:00 0:00:01.724709 11370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T21:05:26.111070+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T20:05:00+00:00 PythonOperator 2021-03-24T21:05:06.282920+00:00 2021-03-24T21:05:09.038265+00:00 0:00:02.755345 11369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T21:05:04.089206+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T20:00:00+00:00 EmrJobFlowSensor 2021-03-24T21:00:56.090302+00:00 2021-03-24T21:09:58.728606+00:00 0:09:02.638304 11368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T21:00:53.706300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T21:00:34.369206+00:00 2021-03-24T21:00:36.052449+00:00 0:00:01.683243 11367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T21:00:31.764783+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T20:00:00+00:00 PythonOperator 2021-03-24T21:00:11.900216+00:00 2021-03-24T21:00:14.619891+00:00 0:00:02.719675 11366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T21:00:09.645173+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T19:00:00+00:00 EmrJobFlowSensor 2021-03-24T20:10:27.728699+00:00 2021-03-24T20:19:30.391717+00:00 0:09:02.663018 11364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:10:25.070122+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T19:00:00+00:00 EmrJobFlowSensor 2021-03-24T20:10:27.641782+00:00 2021-03-24T20:19:30.276421+00:00 0:09:02.634639 11363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:10:25.070157+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T20:10:05.297095+00:00 2021-03-24T20:10:07.023108+00:00 0:00:01.726013 11362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T20:10:02.986307+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T20:10:05.217823+00:00 2021-03-24T20:10:07.066974+00:00 0:00:01.849151 11361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T20:10:02.986272+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T19:00:00+00:00 PythonOperator 2021-03-24T20:09:43.213564+00:00 2021-03-24T20:09:46.256262+00:00 0:00:03.042698 11360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T20:09:40.929845+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T19:00:00+00:00 PythonOperator 2021-03-24T20:09:43.163774+00:00 2021-03-24T20:09:45.905681+00:00 0:00:02.741907 11359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T20:09:40.929807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T19:00:00+00:00 TriggerDagRunOperator 2021-03-24T20:09:19.203662+00:00 2021-03-24T20:09:19.726226+00:00 0:00:00.522564 11358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:09:16.909803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T19:00:00+00:00 TriggerDagRunOperator 2021-03-24T20:09:19.139162+00:00 2021-03-24T20:09:19.557599+00:00 0:00:00.418437 11357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:09:16.909840+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T19:05:00+00:00 EmrJobFlowSensor 2021-03-24T20:05:55.113838+00:00 2021-03-24T20:13:57.708139+00:00 0:08:02.594301 11356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:05:52.671506+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T20:05:28.778408+00:00 2021-03-24T20:05:30.429760+00:00 0:00:01.651352 11355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T20:05:26.587453+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T19:05:00+00:00 PythonOperator 2021-03-24T20:05:06.692618+00:00 2021-03-24T20:05:09.381727+00:00 0:00:02.689109 11354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T20:05:04.558317+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T19:00:00+00:00 EmrJobFlowSensor 2021-03-24T20:00:58.392753+00:00 2021-03-24T20:09:01.001740+00:00 0:08:02.608987 11353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T20:00:56.158338+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T20:00:38.445623+00:00 2021-03-24T20:00:40.279510+00:00 0:00:01.833887 11352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T20:00:36.140174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T19:00:00+00:00 PythonOperator 2021-03-24T20:00:16.545493+00:00 2021-03-24T20:00:19.341155+00:00 0:00:02.795662 11351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T20:00:14.124817+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T18:00:00+00:00 EmrJobFlowSensor 2021-03-24T19:11:21.399278+00:00 2021-03-24T19:21:24.164645+00:00 0:10:02.765367 11349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:11:19.245434+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T18:00:00+00:00 EmrJobFlowSensor 2021-03-24T19:11:17.531186+00:00 2021-03-24T19:20:20.269879+00:00 0:09:02.738693 11348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:11:15.241986+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T19:10:57.470358+00:00 2021-03-24T19:10:59.181872+00:00 0:00:01.711514 11347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T19:10:55.221722+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T19:10:49.404570+00:00 2021-03-24T19:10:51.174000+00:00 0:00:01.769430 11346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T19:10:47.216818+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T18:00:00+00:00 PythonOperator 2021-03-24T19:10:29.657462+00:00 2021-03-24T19:10:32.580814+00:00 0:00:02.923352 11345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T19:10:27.258556+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T18:00:00+00:00 PythonOperator 2021-03-24T19:10:27.393129+00:00 2021-03-24T19:10:30.265278+00:00 0:00:02.872149 11344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T19:10:25.199184+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T18:00:00+00:00 TriggerDagRunOperator 2021-03-24T19:10:09.606514+00:00 2021-03-24T19:10:10.073493+00:00 0:00:00.466979 11343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:10:07.184639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T18:00:00+00:00 TriggerDagRunOperator 2021-03-24T19:10:09.390987+00:00 2021-03-24T19:10:09.891460+00:00 0:00:00.500473 11342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:10:07.184602+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T18:05:00+00:00 EmrJobFlowSensor 2021-03-24T19:05:46.798461+00:00 2021-03-24T19:14:49.413358+00:00 0:09:02.614897 11341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:05:44.651743+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T19:05:24.815323+00:00 2021-03-24T19:05:26.546524+00:00 0:00:01.731201 11340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T19:05:22.630012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T18:05:00+00:00 PythonOperator 2021-03-24T19:05:04.871504+00:00 2021-03-24T19:05:07.550217+00:00 0:00:02.678713 11339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T19:05:02.614946+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T18:00:00+00:00 EmrJobFlowSensor 2021-03-24T19:00:54.623133+00:00 2021-03-24T19:09:57.273827+00:00 0:09:02.650694 11338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T19:00:52.213049+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T19:00:34.427264+00:00 2021-03-24T19:00:36.124353+00:00 0:00:01.697089 11337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T19:00:32.190416+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T18:00:00+00:00 PythonOperator 2021-03-24T19:00:12.384933+00:00 2021-03-24T19:00:15.114989+00:00 0:00:02.730056 11336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T19:00:10.169804+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T17:00:00+00:00 EmrJobFlowSensor 2021-03-24T18:12:13.863694+00:00 2021-03-24T18:21:16.334588+00:00 0:09:02.470894 11334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T18:12:11.695665+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T17:00:00+00:00 EmrJobFlowSensor 2021-03-24T18:11:57.923395+00:00 2021-03-24T18:22:00.733723+00:00 0:10:02.810328 11333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T18:11:55.654634+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T18:11:51.802662+00:00 2021-03-24T18:11:53.520959+00:00 0:00:01.718297 11332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T18:11:49.655291+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T18:11:37.840268+00:00 2021-03-24T18:11:39.624469+00:00 0:00:01.784201 11331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T18:11:35.634450+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T17:00:00+00:00 PythonOperator 2021-03-24T18:11:31.781977+00:00 2021-03-24T18:11:34.519889+00:00 0:00:02.737912 11330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T18:11:29.627614+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T17:00:00+00:00 PythonOperator 2021-03-24T18:11:16.097475+00:00 2021-03-24T18:11:19.293534+00:00 0:00:03.196059 11329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T18:11:13.580591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T17:00:00+00:00 TriggerDagRunOperator 2021-03-24T18:11:06.000156+00:00 2021-03-24T18:11:06.518875+00:00 0:00:00.518719 11328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T18:11:03.528237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T17:00:00+00:00 TriggerDagRunOperator 2021-03-24T18:11:05.821976+00:00 2021-03-24T18:11:06.210691+00:00 0:00:00.388715 11327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T18:11:03.528209+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T17:05:00+00:00 EmrJobFlowSensor 2021-03-24T18:05:59.109685+00:00 2021-03-24T18:15:01.607067+00:00 0:09:02.497382 11326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T18:05:56.974616+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T18:05:39.102189+00:00 2021-03-24T18:05:40.724933+00:00 0:00:01.622744 11325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T18:05:36.957358+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T17:05:00+00:00 PythonOperator 2021-03-24T18:05:17.066858+00:00 2021-03-24T18:05:19.768981+00:00 0:00:02.702123 11324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T18:05:14.936770+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T17:00:00+00:00 EmrJobFlowSensor 2021-03-24T18:00:50.863173+00:00 2021-03-24T18:10:53.788682+00:00 0:10:02.925509 11323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T18:00:48.600170+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T18:00:28.810761+00:00 2021-03-24T18:00:30.496453+00:00 0:00:01.685692 11322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T18:00:26.527013+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T17:00:00+00:00 PythonOperator 2021-03-24T18:00:08.805669+00:00 2021-03-24T18:00:11.547376+00:00 0:00:02.741707 11321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T18:00:06.510463+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T16:00:00+00:00 EmrJobFlowSensor 2021-03-24T17:12:18.934114+00:00 2021-03-24T17:21:21.588710+00:00 0:09:02.654596 11319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:12:16.624481+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T16:00:00+00:00 EmrJobFlowSensor 2021-03-24T17:12:10.790646+00:00 2021-03-24T17:20:13.333589+00:00 0:08:02.542943 11318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:12:08.618841+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T17:11:56.953739+00:00 2021-03-24T17:11:58.758024+00:00 0:00:01.804285 11317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T17:11:54.606703+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T17:11:49.124144+00:00 2021-03-24T17:11:50.911229+00:00 0:00:01.787085 11316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T17:11:46.643867+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T16:00:00+00:00 PythonOperator 2021-03-24T17:11:34.908301+00:00 2021-03-24T17:11:37.939842+00:00 0:00:03.031541 11315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T17:11:32.591565+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T16:00:00+00:00 PythonOperator 2021-03-24T17:11:27.001187+00:00 2021-03-24T17:11:29.798031+00:00 0:00:02.796844 11314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T17:11:24.581593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T16:00:00+00:00 TriggerDagRunOperator 2021-03-24T17:11:10.940174+00:00 2021-03-24T17:11:11.378462+00:00 0:00:00.438288 11313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:11:08.580504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T16:00:00+00:00 TriggerDagRunOperator 2021-03-24T17:11:10.911656+00:00 2021-03-24T17:11:11.443231+00:00 0:00:00.531575 11312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:11:08.580473+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T16:05:00+00:00 EmrJobFlowSensor 2021-03-24T17:06:04.573159+00:00 2021-03-24T17:14:07.085627+00:00 0:08:02.512468 11311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:06:02.060295+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T16:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T17:05:42.170078+00:00 2021-03-24T17:05:43.947636+00:00 0:00:01.777558 11310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T17:05:39.957166+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T16:05:00+00:00 PythonOperator 2021-03-24T17:05:21.974722+00:00 2021-03-24T17:05:24.655360+00:00 0:00:02.680638 11309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T17:05:19.815990+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T16:00:00+00:00 EmrJobFlowSensor 2021-03-24T17:00:47.573022+00:00 2021-03-24T17:10:50.374864+00:00 0:10:02.801842 11308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T17:00:45.259094+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T17:00:25.475040+00:00 2021-03-24T17:00:27.220188+00:00 0:00:01.745148 11307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T17:00:23.219490+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T16:00:00+00:00 PythonOperator 2021-03-24T17:00:05.616683+00:00 2021-03-24T17:00:08.429712+00:00 0:00:02.813029 11306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T17:00:03.210720+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T15:00:00+00:00 EmrJobFlowSensor 2021-03-24T16:14:24.765151+00:00 2021-03-24T16:23:27.490272+00:00 0:09:02.725121 11305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:14:22.495852+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T15:00:00+00:00 EmrJobFlowSensor 2021-03-24T16:14:16.882041+00:00 2021-03-24T16:22:19.431965+00:00 0:08:02.549924 11304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:14:14.556700+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T16:14:02.646171+00:00 2021-03-24T16:14:04.438098+00:00 0:00:01.791927 11303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T16:14:00.438688+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T16:13:48.884365+00:00 2021-03-24T16:13:50.574044+00:00 0:00:01.689679 11302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T16:13:46.421997+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T15:00:00+00:00 PythonOperator 2021-03-24T16:13:38.626034+00:00 2021-03-24T16:13:41.531400+00:00 0:00:02.905366 11301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T16:13:36.413861+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T15:00:00+00:00 PythonOperator 2021-03-24T16:13:22.572363+00:00 2021-03-24T16:13:25.272596+00:00 0:00:02.700233 11300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T16:13:20.399021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T15:00:00+00:00 TriggerDagRunOperator 2021-03-24T16:13:17.390701+00:00 2021-03-24T16:13:18.032940+00:00 0:00:00.642239 11299 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:13:14.335755+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T15:00:00+00:00 TriggerDagRunOperator 2021-03-24T16:13:17.172870+00:00 2021-03-24T16:13:17.695867+00:00 0:00:00.522997 11298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:13:14.335783+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T15:05:00+00:00 EmrJobFlowSensor 2021-03-24T16:06:01.757610+00:00 2021-03-24T16:14:04.355858+00:00 0:08:02.598248 11296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:05:59.359528+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T16:05:39.283581+00:00 2021-03-24T16:05:40.915675+00:00 0:00:01.632094 11295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T16:05:37.188573+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T15:05:00+00:00 PythonOperator 2021-03-24T16:05:17.276273+00:00 2021-03-24T16:05:20.086839+00:00 0:00:02.810566 11294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T16:05:15.107486+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T15:00:00+00:00 EmrJobFlowSensor 2021-03-24T16:01:04.820949+00:00 2021-03-24T16:11:07.639424+00:00 0:10:02.818475 11293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T16:01:02.686326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T16:00:40.915054+00:00 2021-03-24T16:00:42.724208+00:00 0:00:01.809154 11292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T16:00:38.640782+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T15:00:00+00:00 PythonOperator 2021-03-24T16:00:18.914652+00:00 2021-03-24T16:00:21.784033+00:00 0:00:02.869381 11291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T16:00:16.597424+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T14:00:00+00:00 EmrJobFlowSensor 2021-03-24T15:12:24.389688+00:00 2021-03-24T15:21:26.975899+00:00 0:09:02.586211 11290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:12:22.051259+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T14:00:00+00:00 EmrJobFlowSensor 2021-03-24T15:12:12.195544+00:00 2021-03-24T15:22:15.076807+00:00 0:10:02.881263 11289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:12:09.986465+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:12:04.388294+00:00 2021-03-24T15:12:06.092610+00:00 0:00:01.704316 11288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T15:12:01.954539+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:11:52.376683+00:00 2021-03-24T15:11:54.076488+00:00 0:00:01.699805 11287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T15:11:49.944473+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T14:00:00+00:00 PythonOperator 2021-03-24T15:11:42.583080+00:00 2021-03-24T15:11:45.291271+00:00 0:00:02.708191 11286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:11:39.897991+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T14:00:00+00:00 PythonOperator 2021-03-24T15:11:30.685696+00:00 2021-03-24T15:11:33.610945+00:00 0:00:02.925249 11285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:11:27.940943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T14:00:00+00:00 TriggerDagRunOperator 2021-03-24T15:11:18.149832+00:00 2021-03-24T15:11:18.694944+00:00 0:00:00.545112 11284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:11:15.721460+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T14:00:00+00:00 TriggerDagRunOperator 2021-03-24T15:11:17.893149+00:00 2021-03-24T15:11:18.293593+00:00 0:00:00.400444 11283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:11:15.721425+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T14:05:00+00:00 EmrJobFlowSensor 2021-03-24T15:07:33.667053+00:00 2021-03-24T15:17:36.517259+00:00 0:10:02.850206 11282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:07:31.473221+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:07:11.581866+00:00 2021-03-24T15:07:13.239813+00:00 0:00:01.657947 11281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T15:07:09.390993+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T14:05:00+00:00 PythonOperator 2021-03-24T15:06:49.656817+00:00 2021-03-24T15:06:52.353779+00:00 0:00:02.696962 11280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:06:47.372773+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T14:00:00+00:00 EmrJobFlowSensor 2021-03-24T15:01:05.653113+00:00 2021-03-24T15:11:08.620373+00:00 0:10:02.967260 11278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:01:03.111201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:00:41.446303+00:00 2021-03-24T15:00:43.138804+00:00 0:00:01.692501 11277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T15:00:39.161948+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T14:00:00+00:00 PythonOperator 2021-03-24T15:00:21.186396+00:00 2021-03-24T15:00:24.078532+00:00 0:00:02.892136 11276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T15:00:18.995450+00:00 2 default_pool