Task Instances

Reset Filters
  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-25T22:00:00+00:00 PythonOperator 2021-03-25T23:00:11.305918+00:00 2021-03-25T23:00:14.112830+00:00 0:00:02.806912 11699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T23:00:09.053668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T21:00:00+00:00 TriggerDagRunOperator 2021-03-25T22:19:09.796569+00:00 2021-03-25T22:19:10.265814+00:00 0:00:00.469245 11695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:19:07.244622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T21:00:00+00:00 TriggerDagRunOperator 2021-03-25T22:19:09.783995+00:00 2021-03-25T22:19:10.343123+00:00 0:00:00.559128 11694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:19:07.244593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T21:00:00+00:00 EmrJobFlowSensor 2021-03-25T22:00:49.119905+00:00 2021-03-25T22:18:53.033800+00:00 0:18:03.913895 11689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T22:00:46.900364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T22:00:29.017348+00:00 2021-03-25T22:00:30.716783+00:00 0:00:01.699435 11688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T22:00:26.823724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T21:00:00+00:00 PythonOperator 2021-03-25T22:00:07.545141+00:00 2021-03-25T22:00:10.401270+00:00 0:00:02.856129 11687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T22:00:04.805247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T20:00:00+00:00 TriggerDagRunOperator 2021-03-25T21:09:23.000653+00:00 2021-03-25T21:09:23.400653+00:00 0:00:00.400000 11682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:09:20.543943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T20:00:00+00:00 TriggerDagRunOperator 2021-03-25T21:09:22.893807+00:00 2021-03-25T21:09:23.422147+00:00 0:00:00.528340 11681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:09:20.543912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T20:00:00+00:00 EmrJobFlowSensor 2021-03-25T21:01:06.207454+00:00 2021-03-25T21:09:08.899768+00:00 0:08:02.692314 11677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T21:01:03.871482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T21:00:46.106952+00:00 2021-03-25T21:00:47.769313+00:00 0:00:01.662361 11676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T21:00:43.853126+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T20:00:00+00:00 PythonOperator 2021-03-25T21:00:24.664132+00:00 2021-03-25T21:00:27.560047+00:00 0:00:02.895915 11675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T21:00:21.863892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T19:00:00+00:00 TriggerDagRunOperator 2021-03-25T20:09:25.464853+00:00 2021-03-25T20:09:25.885018+00:00 0:00:00.420165 11670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:09:23.156336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T19:00:00+00:00 TriggerDagRunOperator 2021-03-25T20:09:25.380464+00:00 2021-03-25T20:09:25.939048+00:00 0:00:00.558584 11669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:09:23.156370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T19:00:00+00:00 EmrJobFlowSensor 2021-03-25T20:00:58.721030+00:00 2021-03-25T20:09:01.368499+00:00 0:08:02.647469 11665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T20:00:56.366355+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T20:00:36.804349+00:00 2021-03-25T20:00:38.591950+00:00 0:00:01.787601 11664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T20:00:34.359411+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T19:00:00+00:00 PythonOperator 2021-03-25T20:00:12.661190+00:00 2021-03-25T20:00:15.552390+00:00 0:00:02.891200 11663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T20:00:10.243771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T18:00:00+00:00 TriggerDagRunOperator 2021-03-25T19:09:18.449915+00:00 2021-03-25T19:09:18.977263+00:00 0:00:00.527348 11658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:09:16.195283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T18:00:00+00:00 TriggerDagRunOperator 2021-03-25T19:09:18.412976+00:00 2021-03-25T19:09:18.888433+00:00 0:00:00.475457 11657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:09:16.195311+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T18:00:00+00:00 EmrJobFlowSensor 2021-03-25T19:00:55.515475+00:00 2021-03-25T19:08:57.921628+00:00 0:08:02.406153 11653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:00:53.333643+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:00:33.885152+00:00 2021-03-25T19:00:35.654976+00:00 0:00:01.769824 11652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T19:00:31.375853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T18:00:00+00:00 PythonOperator 2021-03-25T19:00:11.979176+00:00 2021-03-25T19:00:14.740453+00:00 0:00:02.761277 11651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T19:00:09.366675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T17:00:00+00:00 TriggerDagRunOperator 2021-03-25T18:10:32.401679+00:00 2021-03-25T18:10:32.916342+00:00 0:00:00.514663 11646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:10:30.041026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T17:00:00+00:00 TriggerDagRunOperator 2021-03-25T18:10:32.334309+00:00 2021-03-25T18:10:32.813024+00:00 0:00:00.478715 11645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:10:30.041077+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T17:00:00+00:00 EmrJobFlowSensor 2021-03-25T18:00:53.667795+00:00 2021-03-25T18:09:56.377907+00:00 0:09:02.710112 11641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:00:51.311837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:00:31.461454+00:00 2021-03-25T18:00:33.191291+00:00 0:00:01.729837 11640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T18:00:29.291717+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T17:00:00+00:00 PythonOperator 2021-03-25T18:00:11.521223+00:00 2021-03-25T18:00:14.350348+00:00 0:00:02.829125 11639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T18:00:09.229702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T16:00:00+00:00 TriggerDagRunOperator 2021-03-25T17:11:14.711556+00:00 2021-03-25T17:11:15.198945+00:00 0:00:00.487389 11634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:11:12.302753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T16:00:00+00:00 TriggerDagRunOperator 2021-03-25T17:11:14.521346+00:00 2021-03-25T17:11:14.898784+00:00 0:00:00.377438 11633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:11:12.302706+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T16:00:00+00:00 EmrJobFlowSensor 2021-03-25T17:01:08.002464+00:00 2021-03-25T17:11:11.032304+00:00 0:10:03.029840 11629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T17:01:05.560555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T17:00:45.730175+00:00 2021-03-25T17:00:47.528042+00:00 0:00:01.797867 11628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T17:00:43.491836+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T16:00:00+00:00 PythonOperator 2021-03-25T17:00:23.831398+00:00 2021-03-25T17:00:26.745517+00:00 0:00:02.914119 11627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T17:00:21.477753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T15:00:00+00:00 TriggerDagRunOperator 2021-03-25T16:25:26.330551+00:00 2021-03-25T16:25:26.848788+00:00 0:00:00.518237 11623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:25:23.791438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T15:00:00+00:00 TriggerDagRunOperator 2021-03-25T16:25:26.049227+00:00 2021-03-25T16:25:26.456673+00:00 0:00:00.407446 11622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:25:23.791409+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T15:00:00+00:00 EmrJobFlowSensor 2021-03-25T16:15:11.069385+00:00 2021-03-25T16:25:14.009858+00:00 0:10:02.940473 11621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T16:15:08.819988+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T16:14:50.987974+00:00 2021-03-25T16:14:52.778820+00:00 0:00:01.790846 11619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T16:14:48.805124+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T15:00:00+00:00 PythonOperator 2021-03-25T16:14:29.122772+00:00 2021-03-25T16:14:31.850489+00:00 0:00:02.727717 11617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T16:14:26.782260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T14:00:00+00:00 TriggerDagRunOperator 2021-03-25T15:10:17.363600+00:00 2021-03-25T15:10:17.876406+00:00 0:00:00.512806 11611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:10:15.056017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T14:00:00+00:00 TriggerDagRunOperator 2021-03-25T15:10:17.314128+00:00 2021-03-25T15:10:17.721303+00:00 0:00:00.407175 11610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:10:15.056053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T14:00:00+00:00 EmrJobFlowSensor 2021-03-25T15:00:58.389045+00:00 2021-03-25T15:10:01.158658+00:00 0:09:02.769613 11606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T15:00:56.111002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T15:00:36.222683+00:00 2021-03-25T15:00:37.906481+00:00 0:00:01.683798 11605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T15:00:34.087010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T14:00:00+00:00 PythonOperator 2021-03-25T15:00:16.848702+00:00 2021-03-25T15:00:19.717445+00:00 0:00:02.868743 11604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T15:00:14.071030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T13:00:00+00:00 TriggerDagRunOperator 2021-03-25T14:11:06.664270+00:00 2021-03-25T14:11:07.172895+00:00 0:00:00.508625 11599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:11:04.350192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T13:00:00+00:00 TriggerDagRunOperator 2021-03-25T14:11:06.586925+00:00 2021-03-25T14:11:06.995038+00:00 0:00:00.408113 11598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:11:04.350232+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T13:00:00+00:00 EmrJobFlowSensor 2021-03-25T14:00:49.879203+00:00 2021-03-25T14:10:52.595566+00:00 0:10:02.716363 11594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T14:00:47.531106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T14:00:28.033116+00:00 2021-03-25T14:00:29.723664+00:00 0:00:01.690548 11593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T14:00:25.565214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T13:00:00+00:00 PythonOperator 2021-03-25T14:00:06.092244+00:00 2021-03-25T14:00:08.850990+00:00 0:00:02.758746 11592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T14:00:03.558396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T12:00:00+00:00 TriggerDagRunOperator 2021-03-25T13:09:59.280814+00:00 2021-03-25T13:09:59.761641+00:00 0:00:00.480827 11587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:09:56.834747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T12:00:00+00:00 TriggerDagRunOperator 2021-03-25T13:09:59.014946+00:00 2021-03-25T13:09:59.409575+00:00 0:00:00.394629 11586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:09:56.834712+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T12:00:00+00:00 EmrJobFlowSensor 2021-03-25T13:00:48.150688+00:00 2021-03-25T13:09:50.616439+00:00 0:09:02.465751 11582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:00:45.915974+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:00:26.093977+00:00 2021-03-25T13:00:27.772358+00:00 0:00:01.678381 11581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T13:00:23.910778+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T12:00:00+00:00 PythonOperator 2021-03-25T13:00:04.173339+00:00 2021-03-25T13:00:07.011119+00:00 0:00:02.837780 11580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T13:00:01.853649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T11:00:00+00:00 TriggerDagRunOperator 2021-03-25T12:10:07.618661+00:00 2021-03-25T12:10:08.112012+00:00 0:00:00.493351 11575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:05.271365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T11:00:00+00:00 TriggerDagRunOperator 2021-03-25T12:10:07.447815+00:00 2021-03-25T12:10:07.862438+00:00 0:00:00.414623 11574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:05.271336+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T11:00:00+00:00 EmrJobFlowSensor 2021-03-25T12:00:48.756839+00:00 2021-03-25T12:09:51.534244+00:00 0:09:02.777405 11570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:00:46.489889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:00:28.708215+00:00 2021-03-25T12:00:30.386645+00:00 0:00:01.678430 11569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T12:00:26.476695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T11:00:00+00:00 PythonOperator 2021-03-25T12:00:06.968765+00:00 2021-03-25T12:00:09.803555+00:00 0:00:02.834790 11568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T12:00:04.456599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T10:00:00+00:00 TriggerDagRunOperator 2021-03-25T11:10:16.287265+00:00 2021-03-25T11:10:16.682551+00:00 0:00:00.395286 11563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:10:13.755599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T10:00:00+00:00 TriggerDagRunOperator 2021-03-25T11:10:16.106581+00:00 2021-03-25T11:10:16.645382+00:00 0:00:00.538801 11562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:10:13.755563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T10:00:00+00:00 EmrJobFlowSensor 2021-03-25T11:01:06.911797+00:00 2021-03-25T11:10:09.630949+00:00 0:09:02.719152 11558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:01:04.787406+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:00:45.084282+00:00 2021-03-25T11:00:46.958361+00:00 0:00:01.874079 11557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T11:00:42.759571+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T10:00:00+00:00 PythonOperator 2021-03-25T11:00:23.381369+00:00 2021-03-25T11:00:26.507716+00:00 0:00:03.126347 11556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T11:00:20.766644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T09:00:00+00:00 TriggerDagRunOperator 2021-03-25T10:11:16.247751+00:00 2021-03-25T10:11:16.667547+00:00 0:00:00.419796 11551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:11:13.945140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T09:00:00+00:00 TriggerDagRunOperator 2021-03-25T10:11:16.210494+00:00 2021-03-25T10:11:16.740736+00:00 0:00:00.530242 11550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:11:13.945105+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T09:00:00+00:00 EmrJobFlowSensor 2021-03-25T10:01:05.072783+00:00 2021-03-25T10:11:07.937862+00:00 0:10:02.865079 11546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:01:02.912807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:00:43.130032+00:00 2021-03-25T10:00:44.955749+00:00 0:00:01.825717 11545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T10:00:40.891037+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T09:00:00+00:00 PythonOperator 2021-03-25T10:00:21.502964+00:00 2021-03-25T10:00:24.233654+00:00 0:00:02.730690 11544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T10:00:18.872932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T08:00:00+00:00 TriggerDagRunOperator 2021-03-25T09:10:08.177839+00:00 2021-03-25T09:10:08.673844+00:00 0:00:00.496005 11539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:10:05.653010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T08:00:00+00:00 TriggerDagRunOperator 2021-03-25T09:10:08.135616+00:00 2021-03-25T09:10:08.686148+00:00 0:00:00.550532 11538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:10:05.653052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T08:00:00+00:00 EmrJobFlowSensor 2021-03-25T09:00:58.843655+00:00 2021-03-25T09:10:01.519494+00:00 0:09:02.675839 11534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:00:56.631968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:00:38.916993+00:00 2021-03-25T09:00:40.590359+00:00 0:00:01.673366 11533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T09:00:36.611991+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T08:00:00+00:00 PythonOperator 2021-03-25T09:00:17.273525+00:00 2021-03-25T09:00:20.031495+00:00 0:00:02.757970 11532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T09:00:14.662881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T07:00:00+00:00 TriggerDagRunOperator 2021-03-25T08:10:57.673105+00:00 2021-03-25T08:10:58.067104+00:00 0:00:00.393999 11527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:10:55.324353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T07:00:00+00:00 TriggerDagRunOperator 2021-03-25T08:10:57.626414+00:00 2021-03-25T08:10:58.127822+00:00 0:00:00.501408 11526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:10:55.324324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T07:00:00+00:00 EmrJobFlowSensor 2021-03-25T08:00:48.391874+00:00 2021-03-25T08:10:51.173511+00:00 0:10:02.781637 11522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T08:00:46.303901+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:00:26.590399+00:00 2021-03-25T08:00:28.290160+00:00 0:00:01.699761 11521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T08:00:24.369692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T07:00:00+00:00 PythonOperator 2021-03-25T08:00:04.697355+00:00 2021-03-25T08:00:07.565744+00:00 0:00:02.868389 11520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T08:00:02.211415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T06:00:00+00:00 TriggerDagRunOperator 2021-03-25T07:10:28.315264+00:00 2021-03-25T07:10:28.721426+00:00 0:00:00.406162 11515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:10:25.971520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T06:00:00+00:00 TriggerDagRunOperator 2021-03-25T07:10:28.299031+00:00 2021-03-25T07:10:28.865202+00:00 0:00:00.566171 11514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:10:25.971476+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T06:00:00+00:00 EmrJobFlowSensor 2021-03-25T07:01:07.266548+00:00 2021-03-25T07:10:09.910960+00:00 0:09:02.644412 11510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T07:01:05.057749+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T07:00:43.203514+00:00 2021-03-25T07:00:44.902252+00:00 0:00:01.698738 11509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T07:00:41.011230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T06:00:00+00:00 PythonOperator 2021-03-25T07:00:23.789360+00:00 2021-03-25T07:00:26.619095+00:00 0:00:02.829735 11508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T07:00:21.051669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T05:00:00+00:00 TriggerDagRunOperator 2021-03-25T06:10:58.980321+00:00 2021-03-25T06:10:59.379400+00:00 0:00:00.399079 11503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:10:56.535924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T05:00:00+00:00 TriggerDagRunOperator 2021-03-25T06:10:58.878341+00:00 2021-03-25T06:10:59.407856+00:00 0:00:00.529515 11502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:10:56.535898+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T05:00:00+00:00 EmrJobFlowSensor 2021-03-25T06:00:49.690906+00:00 2021-03-25T06:10:52.515239+00:00 0:10:02.824333 11498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T06:00:47.543477+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T06:00:27.781007+00:00 2021-03-25T06:00:29.543501+00:00 0:00:01.762494 11497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T06:00:25.521366+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T05:00:00+00:00 PythonOperator 2021-03-25T06:00:06.316329+00:00 2021-03-25T06:00:09.151424+00:00 0:00:02.835095 11496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T06:00:03.552239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T04:00:00+00:00 TriggerDagRunOperator 2021-03-25T05:09:19.030114+00:00 2021-03-25T05:09:19.731775+00:00 0:00:00.701661 11491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:09:16.697921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T04:00:00+00:00 TriggerDagRunOperator 2021-03-25T05:09:18.956392+00:00 2021-03-25T05:09:19.348917+00:00 0:00:00.392525 11490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:09:16.697952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T04:00:00+00:00 EmrJobFlowSensor 2021-03-25T05:01:06.355083+00:00 2021-03-25T05:09:08.980833+00:00 0:08:02.625750 11486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T05:01:03.882275+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T05:00:38.071051+00:00 2021-03-25T05:00:39.842927+00:00 0:00:01.771876 11485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T05:00:35.810540+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T04:00:00+00:00 PythonOperator 2021-03-25T05:00:12.424847+00:00 2021-03-25T05:00:15.326644+00:00 0:00:02.901797 11484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T05:00:09.792237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T03:00:00+00:00 TriggerDagRunOperator 2021-03-25T04:10:25.145689+00:00 2021-03-25T04:10:25.692154+00:00 0:00:00.546465 11478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T04:10:22.643631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T03:00:00+00:00 TriggerDagRunOperator 2021-03-25T04:10:25.105723+00:00 2021-03-25T04:10:25.515221+00:00 0:00:00.409498 11477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T04:10:22.643581+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T03:00:00+00:00 EmrJobFlowSensor 2021-03-25T04:01:07.678813+00:00 2021-03-25T04:10:10.299552+00:00 0:09:02.620739 11473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T04:01:05.560782+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T04:00:45.743174+00:00 2021-03-25T04:00:47.429953+00:00 0:00:01.686779 11472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T04:00:43.516846+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T03:00:00+00:00 PythonOperator 2021-03-25T04:00:24.350961+00:00 2021-03-25T04:00:27.239606+00:00 0:00:02.888645 11471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T04:00:21.558176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T02:00:00+00:00 TriggerDagRunOperator 2021-03-25T03:10:31.215400+00:00 2021-03-25T03:10:31.678271+00:00 0:00:00.462871 11463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T03:10:28.465601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T02:00:00+00:00 TriggerDagRunOperator 2021-03-25T03:10:31.014112+00:00 2021-03-25T03:10:31.595816+00:00 0:00:00.581704 11462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T03:10:28.465560+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T02:00:00+00:00 EmrJobFlowSensor 2021-03-25T03:01:05.817797+00:00 2021-03-25T03:10:08.599206+00:00 0:09:02.781409 11458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T03:01:03.581062+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T03:00:43.810616+00:00 2021-03-25T03:00:45.613044+00:00 0:00:01.802428 11457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T03:00:41.540298+00:00 2 default_pool