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-24T06:00:00+00:00 PythonOperator 2021-03-24T07:00:20.001439+00:00 2021-03-24T07:00:22.745514+00:00 0:00:02.744075 11157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T07:00:17.476587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T05:00:00+00:00 TriggerDagRunOperator 2021-03-24T06:11:37.366338+00:00 2021-03-24T06:11:37.811644+00:00 0:00:00.445306 11149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:11:35.051217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T05:00:00+00:00 TriggerDagRunOperator 2021-03-24T06:11:37.382164+00:00 2021-03-24T06:11:37.947620+00:00 0:00:00.565456 11148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:11:35.051254+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T05:00:00+00:00 EmrJobFlowSensor 2021-03-24T06:01:16.273405+00:00 2021-03-24T06:11:19.031568+00:00 0:10:02.758163 11144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:01:14.023723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:00:52.283741+00:00 2021-03-24T06:00:54.080246+00:00 0:00:01.796505 11143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T06:00:49.998199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T05:00:00+00:00 PythonOperator 2021-03-24T06:00:18.407846+00:00 2021-03-24T06:00:21.146727+00:00 0:00:02.738881 11142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T06:00:15.972374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T04:00:00+00:00 TriggerDagRunOperator 2021-03-24T05:10:35.839586+00:00 2021-03-24T05:10:36.332406+00:00 0:00:00.492820 11134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:10:33.521738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T04:00:00+00:00 TriggerDagRunOperator 2021-03-24T05:10:35.675779+00:00 2021-03-24T05:10:36.086939+00:00 0:00:00.411160 11133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:10:33.521769+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T04:00:00+00:00 EmrJobFlowSensor 2021-03-24T05:01:08.860539+00:00 2021-03-24T05:10:11.658983+00:00 0:09:02.798444 11129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:01:06.537297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:00:46.962428+00:00 2021-03-24T05:00:48.769401+00:00 0:00:01.806973 11128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T05:00:44.573913+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T04:00:00+00:00 PythonOperator 2021-03-24T05:00:25.164357+00:00 2021-03-24T05:00:27.916003+00:00 0:00:02.751646 11127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T05:00:22.572978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T03:00:00+00:00 TriggerDagRunOperator 2021-03-24T04:10:16.194752+00:00 2021-03-24T04:10:16.699301+00:00 0:00:00.504549 11119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T04:10:13.769279+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T03:00:00+00:00 TriggerDagRunOperator 2021-03-24T04:10:15.943209+00:00 2021-03-24T04:10:16.330033+00:00 0:00:00.386824 11118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T04:10:13.769314+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T03:00:00+00:00 EmrJobFlowSensor 2021-03-24T04:00:55.309296+00:00 2021-03-24T04:09:57.923619+00:00 0:09:02.614323 11114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T04:00:53.004781+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T04:00:33.203541+00:00 2021-03-24T04:00:34.996944+00:00 0:00:01.793403 11113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T04:00:30.995498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T03:00:00+00:00 PythonOperator 2021-03-24T04:00:11.226348+00:00 2021-03-24T04:00:14.061978+00:00 0:00:02.835630 11112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T04:00:08.919865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T02:00:00+00:00 TriggerDagRunOperator 2021-03-24T03:10:19.514602+00:00 2021-03-24T03:10:20.029340+00:00 0:00:00.514738 11104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T03:10:16.941323+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T02:00:00+00:00 TriggerDagRunOperator 2021-03-24T03:10:19.368339+00:00 2021-03-24T03:10:19.868549+00:00 0:00:00.500210 11103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T03:10:16.941276+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T02:00:00+00:00 EmrJobFlowSensor 2021-03-24T03:00:58.037626+00:00 2021-03-24T03:10:00.925710+00:00 0:09:02.888084 11099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T03:00:55.906143+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T03:00:36.237311+00:00 2021-03-24T03:00:38.021845+00:00 0:00:01.784534 11098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T03:00:33.892138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T02:00:00+00:00 PythonOperator 2021-03-24T03:00:14.332562+00:00 2021-03-24T03:00:17.076680+00:00 0:00:02.744118 11097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T03:00:11.821359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T01:00:00+00:00 TriggerDagRunOperator 2021-03-24T02:11:21.840804+00:00 2021-03-24T02:11:22.345207+00:00 0:00:00.504403 11089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:11:19.523262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T01:00:00+00:00 TriggerDagRunOperator 2021-03-24T02:11:21.701158+00:00 2021-03-24T02:11:22.111147+00:00 0:00:00.409989 11088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:11:19.523230+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T01:00:00+00:00 EmrJobFlowSensor 2021-03-24T02:01:04.808534+00:00 2021-03-24T02:11:07.980947+00:00 0:10:03.172413 11084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:01:02.494566+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:00:42.618869+00:00 2021-03-24T02:00:44.388166+00:00 0:00:01.769297 11083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T02:00:40.420450+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T01:00:00+00:00 PythonOperator 2021-03-24T02:00:21.182913+00:00 2021-03-24T02:00:23.997661+00:00 0:00:02.814748 11082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T02:00:18.464334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T00:00:00+00:00 TriggerDagRunOperator 2021-03-24T01:11:18.997495+00:00 2021-03-24T01:11:19.509036+00:00 0:00:00.511541 11074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:11:16.377286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T00:00:00+00:00 TriggerDagRunOperator 2021-03-24T01:11:18.920258+00:00 2021-03-24T01:11:19.317770+00:00 0:00:00.397512 11073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:11:16.377340+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T00:00:00+00:00 EmrJobFlowSensor 2021-03-24T01:00:51.595112+00:00 2021-03-24T01:10:54.444882+00:00 0:10:02.849770 11069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:00:49.283644+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:00:29.446809+00:00 2021-03-24T01:00:31.158011+00:00 0:00:01.711202 11068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T01:00:27.264642+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T00:00:00+00:00 PythonOperator 2021-03-24T01:00:09.497433+00:00 2021-03-24T01:00:12.217241+00:00 0:00:02.719808 11067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T01:00:07.211379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T23:00:00+00:00 TriggerDagRunOperator 2021-03-24T00:09:18.550184+00:00 2021-03-24T00:09:19.155873+00:00 0:00:00.605689 11059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T00:09:16.152002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T23:00:00+00:00 TriggerDagRunOperator 2021-03-24T00:09:18.343637+00:00 2021-03-24T00:09:18.745498+00:00 0:00:00.401861 11058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T00:09:16.151961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T23:00:00+00:00 EmrJobFlowSensor 2021-03-24T00:01:06.077679+00:00 2021-03-24T00:09:08.721420+00:00 0:08:02.643741 11054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T00:01:03.544520+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T00:00:45.792163+00:00 2021-03-24T00:00:47.511661+00:00 0:00:01.719498 11053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T00:00:43.457371+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T23:00:00+00:00 PythonOperator 2021-03-24T00:00:23.759361+00:00 2021-03-24T00:00:26.576457+00:00 0:00:02.817096 11052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T00:00:21.380617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T22:00:00+00:00 TriggerDagRunOperator 2021-03-23T23:10:34.623861+00:00 2021-03-23T23:10:35.119239+00:00 0:00:00.495378 11044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T23:10:32.094599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T22:00:00+00:00 TriggerDagRunOperator 2021-03-23T23:10:34.420436+00:00 2021-03-23T23:10:34.865993+00:00 0:00:00.445557 11043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T23:10:32.094635+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T22:00:00+00:00 EmrJobFlowSensor 2021-03-23T23:01:09.312741+00:00 2021-03-23T23:10:12.043228+00:00 0:09:02.730487 11039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T23:01:07.060796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T23:00:47.344363+00:00 2021-03-23T23:00:49.190549+00:00 0:00:01.846186 11038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T23:00:45.089947+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T22:00:00+00:00 PythonOperator 2021-03-23T23:00:27.326243+00:00 2021-03-23T23:00:30.084617+00:00 0:00:02.758374 11037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T23:00:25.029311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T21:00:00+00:00 TriggerDagRunOperator 2021-03-23T22:10:17.931610+00:00 2021-03-23T22:10:18.478163+00:00 0:00:00.546553 11029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T22:10:15.467724+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T21:00:00+00:00 TriggerDagRunOperator 2021-03-23T22:10:17.876535+00:00 2021-03-23T22:10:18.399846+00:00 0:00:00.523311 11028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T22:10:15.467774+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T21:00:00+00:00 EmrJobFlowSensor 2021-03-23T22:00:58.931814+00:00 2021-03-23T22:10:01.515356+00:00 0:09:02.583542 11024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T22:00:56.560427+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T22:00:38.606066+00:00 2021-03-23T22:00:40.367945+00:00 0:00:01.761879 11023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T22:00:36.445132+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T21:00:00+00:00 PythonOperator 2021-03-23T22:00:16.866497+00:00 2021-03-23T22:00:19.700651+00:00 0:00:02.834154 11022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T22:00:14.425574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T20:00:00+00:00 TriggerDagRunOperator 2021-03-23T21:10:03.344890+00:00 2021-03-23T21:10:03.742949+00:00 0:00:00.398059 11014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T21:10:00.751486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T20:00:00+00:00 TriggerDagRunOperator 2021-03-23T21:10:03.370977+00:00 2021-03-23T21:10:03.875539+00:00 0:00:00.504562 11013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T21:10:00.751455+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T20:00:00+00:00 EmrJobFlowSensor 2021-03-23T21:00:56.010685+00:00 2021-03-23T21:09:58.581315+00:00 0:09:02.570630 11009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T21:00:53.802858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T21:00:36.097656+00:00 2021-03-23T21:00:37.891223+00:00 0:00:01.793567 11008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T21:00:33.788420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T20:00:00+00:00 PythonOperator 2021-03-23T21:00:12.216546+00:00 2021-03-23T21:00:14.954615+00:00 0:00:02.738069 11007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T21:00:09.844424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T19:00:00+00:00 TriggerDagRunOperator 2021-03-23T20:11:16.577085+00:00 2021-03-23T20:11:16.996140+00:00 0:00:00.419055 10999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T20:11:14.093030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T19:00:00+00:00 TriggerDagRunOperator 2021-03-23T20:11:16.465220+00:00 2021-03-23T20:11:16.996102+00:00 0:00:00.530882 10998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T20:11:14.093002+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T19:00:00+00:00 EmrJobFlowSensor 2021-03-23T20:00:55.204046+00:00 2021-03-23T20:10:57.987398+00:00 0:10:02.783352 10994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T20:00:53.025365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T20:00:33.522651+00:00 2021-03-23T20:00:35.191400+00:00 0:00:01.668749 10993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T20:00:31.077774+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T19:00:00+00:00 PythonOperator 2021-03-23T20:00:11.307811+00:00 2021-03-23T20:00:14.177462+00:00 0:00:02.869651 10992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T20:00:09.052601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T18:00:00+00:00 TriggerDagRunOperator 2021-03-23T19:12:23.264400+00:00 2021-03-23T19:12:24.057844+00:00 0:00:00.793444 10985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T19:12:20.513878+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T18:00:00+00:00 TriggerDagRunOperator 2021-03-23T19:12:23.188794+00:00 2021-03-23T19:12:23.879092+00:00 0:00:00.690298 10984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T19:12:20.513841+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T18:00:00+00:00 EmrJobFlowSensor 2021-03-23T19:01:07.812058+00:00 2021-03-23T19:11:10.570196+00:00 0:10:02.758138 10979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T19:01:05.554788+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T19:00:45.721886+00:00 2021-03-23T19:00:47.420479+00:00 0:00:01.698593 10978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T19:00:43.429861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T18:00:00+00:00 PythonOperator 2021-03-23T19:00:25.597416+00:00 2021-03-23T19:00:28.306693+00:00 0:00:02.709277 10977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T19:00:23.409017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T17:00:00+00:00 TriggerDagRunOperator 2021-03-23T18:11:30.929209+00:00 2021-03-23T18:11:31.473201+00:00 0:00:00.543992 10970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T18:11:28.294488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T17:00:00+00:00 TriggerDagRunOperator 2021-03-23T18:11:30.789158+00:00 2021-03-23T18:11:31.225830+00:00 0:00:00.436672 10969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T18:11:28.294459+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T17:00:00+00:00 EmrJobFlowSensor 2021-03-23T18:00:57.083862+00:00 2021-03-23T18:10:59.974377+00:00 0:10:02.890515 10964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T18:00:54.903564+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T18:00:35.304487+00:00 2021-03-23T18:00:36.982584+00:00 0:00:01.678097 10963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T18:00:32.888462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T17:00:00+00:00 PythonOperator 2021-03-23T18:00:13.010285+00:00 2021-03-23T18:00:15.825659+00:00 0:00:02.815374 10962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T18:00:10.819163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T16:00:00+00:00 TriggerDagRunOperator 2021-03-23T17:10:43.082443+00:00 2021-03-23T17:10:43.584597+00:00 0:00:00.502154 10955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:10:40.189334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T16:00:00+00:00 TriggerDagRunOperator 2021-03-23T17:10:42.859095+00:00 2021-03-23T17:10:43.255738+00:00 0:00:00.396643 10954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:10:40.189363+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T16:00:00+00:00 EmrJobFlowSensor 2021-03-23T17:00:50.718831+00:00 2021-03-23T17:09:53.349606+00:00 0:09:02.630775 10949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:00:48.231799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:00:28.602446+00:00 2021-03-23T17:00:30.408922+00:00 0:00:01.806476 10948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T17:00:26.270857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T16:00:00+00:00 PythonOperator 2021-03-23T17:00:08.662273+00:00 2021-03-23T17:00:11.559144+00:00 0:00:02.896871 10947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T17:00:06.253434+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T15:00:00+00:00 TriggerDagRunOperator 2021-03-23T16:18:26.409715+00:00 2021-03-23T16:18:26.925487+00:00 0:00:00.515772 10940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:18:23.950034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T15:00:00+00:00 TriggerDagRunOperator 2021-03-23T16:18:26.251321+00:00 2021-03-23T16:18:26.667702+00:00 0:00:00.416381 10939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:18:23.950086+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T15:00:00+00:00 EmrJobFlowSensor 2021-03-23T16:09:19.657710+00:00 2021-03-23T16:18:22.471059+00:00 0:09:02.813349 10937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:09:17.061445+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:08:57.208563+00:00 2021-03-23T16:08:58.889245+00:00 0:00:01.680682 10935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T16:08:55.049296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T15:00:00+00:00 PythonOperator 2021-03-23T16:08:31.695037+00:00 2021-03-23T16:08:34.440762+00:00 0:00:02.745725 10933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T16:08:29.075872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T14:00:00+00:00 TriggerDagRunOperator 2021-03-23T15:10:59.320002+00:00 2021-03-23T15:10:59.800804+00:00 0:00:00.480802 10925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:10:56.811676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T14:00:00+00:00 TriggerDagRunOperator 2021-03-23T15:10:59.144819+00:00 2021-03-23T15:10:59.564479+00:00 0:00:00.419660 10924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:10:56.811643+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T14:00:00+00:00 EmrJobFlowSensor 2021-03-23T15:00:50.041177+00:00 2021-03-23T15:10:52.876818+00:00 0:10:02.835641 10920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:00:47.790124+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:00:27.936948+00:00 2021-03-23T15:00:29.626019+00:00 0:00:01.689071 10919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T15:00:25.770137+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T14:00:00+00:00 PythonOperator 2021-03-23T15:00:08.178897+00:00 2021-03-23T15:00:10.931487+00:00 0:00:02.752590 10918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T15:00:05.720809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T13:00:00+00:00 TriggerDagRunOperator 2021-03-23T14:11:15.675065+00:00 2021-03-23T14:11:16.066300+00:00 0:00:00.391235 10910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:11:13.456209+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T13:00:00+00:00 TriggerDagRunOperator 2021-03-23T14:11:15.715022+00:00 2021-03-23T14:11:16.209846+00:00 0:00:00.494824 10909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:11:13.456241+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T13:00:00+00:00 EmrJobFlowSensor 2021-03-23T14:00:54.994479+00:00 2021-03-23T14:10:57.767703+00:00 0:10:02.773224 10905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:00:52.321717+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:00:32.672992+00:00 2021-03-23T14:00:34.519209+00:00 0:00:01.846217 10904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T14:00:30.360691+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T13:00:00+00:00 PythonOperator 2021-03-23T14:00:10.674896+00:00 2021-03-23T14:00:13.527014+00:00 0:00:02.852118 10903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T14:00:08.263729+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T12:00:00+00:00 TriggerDagRunOperator 2021-03-23T13:10:08.649271+00:00 2021-03-23T13:10:09.117401+00:00 0:00:00.468130 10895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:10:06.159548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T12:00:00+00:00 TriggerDagRunOperator 2021-03-23T13:10:08.621192+00:00 2021-03-23T13:10:09.143087+00:00 0:00:00.521895 10894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:10:06.159597+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T12:00:00+00:00 EmrJobFlowSensor 2021-03-23T13:00:51.210617+00:00 2021-03-23T13:09:53.881524+00:00 0:09:02.670907 10890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:00:49.023585+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T13:00:29.323662+00:00 2021-03-23T13:00:31.075873+00:00 0:00:01.752211 10889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T13:00:27.060747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T12:00:00+00:00 PythonOperator 2021-03-23T13:00:09.514932+00:00 2021-03-23T13:00:12.360807+00:00 0:00:02.845875 10888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T13:00:07.051041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T11:00:00+00:00 TriggerDagRunOperator 2021-03-23T12:11:07.332275+00:00 2021-03-23T12:11:07.903163+00:00 0:00:00.570888 10880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T12:11:04.758167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T11:00:00+00:00 TriggerDagRunOperator 2021-03-23T12:11:07.229446+00:00 2021-03-23T12:11:07.630878+00:00 0:00:00.401432 10879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T12:11:04.758136+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T11:00:00+00:00 EmrJobFlowSensor 2021-03-23T12:00:57.895743+00:00 2021-03-23T12:11:00.747523+00:00 0:10:02.851780 10875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T12:00:55.701738+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T12:00:36.084806+00:00 2021-03-23T12:00:37.751016+00:00 0:00:01.666210 10874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T12:00:33.762543+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T11:00:00+00:00 PythonOperator 2021-03-23T12:00:16.549803+00:00 2021-03-23T12:00:19.357354+00:00 0:00:02.807551 10873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T12:00:13.662483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T10:00:00+00:00 TriggerDagRunOperator 2021-03-23T11:10:22.032951+00:00 2021-03-23T11:10:22.524188+00:00 0:00:00.491237 10865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T11:10:19.730949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T10:00:00+00:00 TriggerDagRunOperator 2021-03-23T11:10:21.940511+00:00 2021-03-23T11:10:22.323894+00:00 0:00:00.383383 10864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T11:10:19.730982+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T10:00:00+00:00 EmrJobFlowSensor 2021-03-23T11:01:05.256170+00:00 2021-03-23T11:10:07.812966+00:00 0:09:02.556796 10860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T11:01:02.806208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T11:00:43.070945+00:00 2021-03-23T11:00:44.866383+00:00 0:00:01.795438 10859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T11:00:40.790096+00:00 2 default_pool