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-25T02:00:00+00:00 PythonOperator 2021-03-25T03:00:22.112860+00:00 2021-03-25T03:00:24.989017+00:00 0:00:02.876157 11456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T03:00:19.500908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T01:00:00+00:00 TriggerDagRunOperator 2021-03-25T02:10:02.121297+00:00 2021-03-25T02:10:02.513363+00:00 0:00:00.392066 11448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T02:09:59.265985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T01:00:00+00:00 TriggerDagRunOperator 2021-03-25T02:10:01.807018+00:00 2021-03-25T02:10:02.313490+00:00 0:00:00.506472 11447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T02:09:59.265942+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T01:00:00+00:00 EmrJobFlowSensor 2021-03-25T02:00:48.344804+00:00 2021-03-25T02:09:50.950398+00:00 0:09:02.605594 11443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T02:00:46.195329+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T02:00:24.349423+00:00 2021-03-25T02:00:26.073633+00:00 0:00:01.724210 11442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T02:00:22.134720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T01:00:00+00:00 PythonOperator 2021-03-25T02:00:04.604306+00:00 2021-03-25T02:00:07.316375+00:00 0:00:02.712069 11441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T02:00:02.117430+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T00:00:00+00:00 TriggerDagRunOperator 2021-03-25T01:10:15.386982+00:00 2021-03-25T01:10:15.816539+00:00 0:00:00.429557 11433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:10:12.858935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T00:00:00+00:00 TriggerDagRunOperator 2021-03-25T01:10:15.196956+00:00 2021-03-25T01:10:15.737481+00:00 0:00:00.540525 11432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:10:12.858889+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T00:00:00+00:00 EmrJobFlowSensor 2021-03-25T01:00:56.070907+00:00 2021-03-25T01:09:58.659716+00:00 0:09:02.588809 11428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:00:53.864703+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:00:34.303996+00:00 2021-03-25T01:00:36.162970+00:00 0:00:01.858974 11427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T01:00:31.843131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T00:00:00+00:00 PythonOperator 2021-03-25T01:00:12.163893+00:00 2021-03-25T01:00:14.988834+00:00 0:00:02.824941 11426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T01:00:09.795295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T23:00:00+00:00 TriggerDagRunOperator 2021-03-25T00:11:26.111795+00:00 2021-03-25T00:11:26.699599+00:00 0:00:00.587804 11418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:11:23.824104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T23:00:00+00:00 TriggerDagRunOperator 2021-03-25T00:11:26.085015+00:00 2021-03-25T00:11:26.486247+00:00 0:00:00.401232 11417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:11:23.824071+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T23:00:00+00:00 EmrJobFlowSensor 2021-03-25T00:01:03.408089+00:00 2021-03-25T00:11:06.208254+00:00 0:10:02.800165 11413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T00:01:01.052387+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T00:00:43.118697+00:00 2021-03-25T00:00:44.774613+00:00 0:00:01.655916 11412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T00:00:40.923651+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T23:00:00+00:00 PythonOperator 2021-03-25T00:00:09.279598+00:00 2021-03-25T00:00:11.998759+00:00 0:00:02.719161 11411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T00:00:06.889307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T22:00:00+00:00 TriggerDagRunOperator 2021-03-24T23:10:14.285220+00:00 2021-03-24T23:10:14.689804+00:00 0:00:00.404584 11403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T23:10:11.932336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T22:00:00+00:00 TriggerDagRunOperator 2021-03-24T23:10:14.229113+00:00 2021-03-24T23:10:14.750653+00:00 0:00:00.521540 11402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T23:10:11.932367+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T22:00:00+00:00 EmrJobFlowSensor 2021-03-24T23:00:49.314693+00:00 2021-03-24T23:09:51.978819+00:00 0:09:02.664126 11398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T23:00:47.096737+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T23:00:27.206150+00:00 2021-03-24T23:00:28.886354+00:00 0:00:01.680204 11397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T23:00:25.006650+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T22:00:00+00:00 PythonOperator 2021-03-24T23:00:05.505921+00:00 2021-03-24T23:00:08.254712+00:00 0:00:02.748791 11396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T23:00:03.060261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T21:00:00+00:00 TriggerDagRunOperator 2021-03-24T22:10:20.886636+00:00 2021-03-24T22:10:21.296548+00:00 0:00:00.409912 11388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T22:10:18.368051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T21:00:00+00:00 TriggerDagRunOperator 2021-03-24T22:10:20.816356+00:00 2021-03-24T22:10:21.324718+00:00 0:00:00.508362 11387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T22:10:18.368099+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T21:00:00+00:00 EmrJobFlowSensor 2021-03-24T22:01:09.950075+00:00 2021-03-24T22:10:12.577972+00:00 0:09:02.627897 11383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T22:01:07.551704+00:00 2 default_pool
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-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 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-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 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 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 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-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 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 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 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 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 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-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 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
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T13:00:00+00:00 TriggerDagRunOperator 2021-03-24T14:13:14.186840+00:00 2021-03-24T14:13:14.620112+00:00 0:00:00.433272 11269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:13:11.674663+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T13:00:00+00:00 TriggerDagRunOperator 2021-03-24T14:13:14.073065+00:00 2021-03-24T14:13:14.623526+00:00 0:00:00.550461 11268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:13:11.674616+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T13:00:00+00:00 EmrJobFlowSensor 2021-03-24T14:02:55.139191+00:00 2021-03-24T14:12:57.852186+00:00 0:10:02.712995 11264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:02:52.773358+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:02:35.148490+00:00 2021-03-24T14:02:36.942857+00:00 0:00:01.794367 11263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T14:02:32.753492+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T13:00:00+00:00 PythonOperator 2021-03-24T14:02:11.084808+00:00 2021-03-24T14:02:13.859422+00:00 0:00:02.774614 11262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T14:02:08.659497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T12:00:00+00:00 TriggerDagRunOperator 2021-03-24T13:11:06.603807+00:00 2021-03-24T13:11:06.974099+00:00 0:00:00.370292 11254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:11:03.811126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T12:00:00+00:00 TriggerDagRunOperator 2021-03-24T13:11:06.073075+00:00 2021-03-24T13:11:06.600240+00:00 0:00:00.527165 11253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:11:03.811168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T12:00:00+00:00 EmrJobFlowSensor 2021-03-24T13:00:51.133828+00:00 2021-03-24T13:10:53.986946+00:00 0:10:02.853118 11249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:00:48.901964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:00:29.254487+00:00 2021-03-24T13:00:30.954782+00:00 0:00:01.700295 11248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T13:00:26.947298+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T12:00:00+00:00 PythonOperator 2021-03-24T13:00:09.623925+00:00 2021-03-24T13:00:12.534306+00:00 0:00:02.910381 11247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T13:00:06.863989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T11:00:00+00:00 TriggerDagRunOperator 2021-03-24T12:11:07.375328+00:00 2021-03-24T12:11:07.928870+00:00 0:00:00.553542 11239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:11:04.780312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T11:00:00+00:00 TriggerDagRunOperator 2021-03-24T12:11:07.095540+00:00 2021-03-24T12:11:07.510273+00:00 0:00:00.414733 11238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:11:04.780358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T11:00:00+00:00 EmrJobFlowSensor 2021-03-24T12:00:50.070356+00:00 2021-03-24T12:10:52.822037+00:00 0:10:02.751681 11234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:00:47.808438+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:00:28.088527+00:00 2021-03-24T12:00:29.772355+00:00 0:00:01.683828 11233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T12:00:25.790234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T11:00:00+00:00 PythonOperator 2021-03-24T12:00:08.083656+00:00 2021-03-24T12:00:10.814935+00:00 0:00:02.731279 11232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T12:00:05.738111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T10:00:00+00:00 TriggerDagRunOperator 2021-03-24T11:10:35.157555+00:00 2021-03-24T11:10:35.685506+00:00 0:00:00.527951 11224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:10:32.596782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T10:00:00+00:00 TriggerDagRunOperator 2021-03-24T11:10:35.102626+00:00 2021-03-24T11:10:35.542393+00:00 0:00:00.439767 11223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:10:32.596814+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:01:18.295013+00:00 2021-03-24T11:10:21.186474+00:00 0:09:02.891461 11219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:01:15.862674+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:00:55.908065+00:00 2021-03-24T11:00:57.607175+00:00 0:00:01.699110 11218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T11:00:53.736226+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:00:26.385783+00:00 2021-03-24T11:00:29.257746+00:00 0:00:02.871963 11217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T11:00:23.728064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T09:00:00+00:00 TriggerDagRunOperator 2021-03-24T10:10:13.965165+00:00 2021-03-24T10:10:14.498750+00:00 0:00:00.533585 11209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:10:11.631480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T09:00:00+00:00 TriggerDagRunOperator 2021-03-24T10:10:13.959410+00:00 2021-03-24T10:10:14.414180+00:00 0:00:00.454770 11208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:10:11.631451+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T09:00:00+00:00 EmrJobFlowSensor 2021-03-24T10:00:50.606476+00:00 2021-03-24T10:09:53.176774+00:00 0:09:02.570298 11204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:00:48.441017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:00:30.917730+00:00 2021-03-24T10:00:32.615047+00:00 0:00:01.697317 11203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T10:00:28.482179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T09:00:00+00:00 PythonOperator 2021-03-24T10:00:08.795350+00:00 2021-03-24T10:00:11.623989+00:00 0:00:02.828639 11202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T10:00:06.389438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T08:00:00+00:00 TriggerDagRunOperator 2021-03-24T09:11:18.598499+00:00 2021-03-24T09:11:19.018245+00:00 0:00:00.419746 11194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:11:16.302638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T08:00:00+00:00 TriggerDagRunOperator 2021-03-24T09:11:18.531044+00:00 2021-03-24T09:11:19.041488+00:00 0:00:00.510444 11193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:11:16.302586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:00:55.130767+00:00 2021-03-24T09:10:57.783478+00:00 0:10:02.652711 11189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:00:52.902688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:00:33.310815+00:00 2021-03-24T09:00:35.106140+00:00 0:00:01.795325 11188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T09:00:30.950081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:00:11.624755+00:00 2021-03-24T09:00:14.405301+00:00 0:00:02.780546 11187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T09:00:08.789147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T07:00:00+00:00 TriggerDagRunOperator 2021-03-24T08:10:08.155217+00:00 2021-03-24T08:10:08.594584+00:00 0:00:00.439367 11179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:10:05.623073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T07:00:00+00:00 TriggerDagRunOperator 2021-03-24T08:10:07.904770+00:00 2021-03-24T08:10:08.461302+00:00 0:00:00.556532 11178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:10:05.623045+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:00:59.019118+00:00 2021-03-24T08:10:01.650128+00:00 0:09:02.631010 11174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:00:56.424252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:00:36.957400+00:00 2021-03-24T08:00:38.772637+00:00 0:00:01.815237 11173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T08:00:34.474957+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:00:15.159478+00:00 2021-03-24T08:00:18.032593+00:00 0:00:02.873115 11172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T08:00:12.388039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T06:00:00+00:00 TriggerDagRunOperator 2021-03-24T07:10:31.297190+00:00 2021-03-24T07:10:31.720742+00:00 0:00:00.423552 11164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:10:28.576717+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T06:00:00+00:00 TriggerDagRunOperator 2021-03-24T07:10:31.296917+00:00 2021-03-24T07:10:31.833196+00:00 0:00:00.536279 11163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:10:28.576673+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T06:00:00+00:00 EmrJobFlowSensor 2021-03-24T07:01:03.750242+00:00 2021-03-24T07:10:06.620989+00:00 0:09:02.870747 11159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:01:01.459384+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:00:41.607449+00:00 2021-03-24T07:00:43.337219+00:00 0:00:01.729770 11158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T07:00:39.418209+00:00 2 default_pool