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-05-13T01:00:00+00:00 PythonOperator 2021-05-13T02:00:15.556053+00:00 2021-05-13T02:00:18.703828+00:00 0:00:03.147775 27474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T02:00:13.252252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T00:00:00+00:00 TriggerDagRunOperator 2021-05-13T01:35:19.238466+00:00 2021-05-13T01:35:19.745415+00:00 0:00:00.506949 27467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T01:35:16.497764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T00:00:00+00:00 TriggerDagRunOperator 2021-05-13T01:35:19.014266+00:00 2021-05-13T01:35:19.436012+00:00 0:00:00.421746 27466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T01:35:16.497735+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T00:00:00+00:00 EmrJobFlowSensor 2021-05-13T01:01:01.982351+00:00 2021-05-13T01:29:07.367232+00:00 0:28:05.384881 27461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T01:00:59.836912+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T01:00:40.185282+00:00 2021-05-13T01:00:41.927066+00:00 0:00:01.741784 27460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T01:00:37.815471+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T00:00:00+00:00 PythonOperator 2021-05-13T01:00:18.275671+00:00 2021-05-13T01:00:21.431573+00:00 0:00:03.155902 27459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T01:00:15.852089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T23:00:00+00:00 TriggerDagRunOperator 2021-05-13T00:11:17.374203+00:00 2021-05-13T00:11:17.779376+00:00 0:00:00.405173 27451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T00:11:14.868912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T23:00:00+00:00 TriggerDagRunOperator 2021-05-13T00:11:17.148708+00:00 2021-05-13T00:11:17.685821+00:00 0:00:00.537113 27450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T00:11:14.868945+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T23:00:00+00:00 EmrJobFlowSensor 2021-05-13T00:01:06.083891+00:00 2021-05-13T00:11:08.890860+00:00 0:10:02.806969 27446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T00:01:03.849687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T00:00:45.879979+00:00 2021-05-13T00:00:47.645935+00:00 0:00:01.765956 27445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T00:00:43.699643+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T23:00:00+00:00 PythonOperator 2021-05-13T00:00:23.827915+00:00 2021-05-13T00:00:27.145361+00:00 0:00:03.317446 27444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T00:00:21.631356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T22:00:00+00:00 TriggerDagRunOperator 2021-05-12T23:11:29.683824+00:00 2021-05-12T23:11:30.209883+00:00 0:00:00.526059 27436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T23:11:27.275239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T22:00:00+00:00 TriggerDagRunOperator 2021-05-12T23:11:29.507323+00:00 2021-05-12T23:11:29.906336+00:00 0:00:00.399013 27435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T23:11:27.275193+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T22:00:00+00:00 EmrJobFlowSensor 2021-05-12T23:01:06.436930+00:00 2021-05-12T23:11:09.234910+00:00 0:10:02.797980 27431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T23:01:04.316509+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T23:00:44.604589+00:00 2021-05-12T23:00:46.301105+00:00 0:00:01.696516 27429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T23:00:42.366592+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T22:00:00+00:00 PythonOperator 2021-05-12T23:00:24.635798+00:00 2021-05-12T23:00:27.749969+00:00 0:00:03.114171 27427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T23:00:22.292079+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T21:00:00+00:00 TriggerDagRunOperator 2021-05-12T22:09:22.030474+00:00 2021-05-12T22:09:22.619387+00:00 0:00:00.588913 27418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T22:09:19.731479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T21:00:00+00:00 TriggerDagRunOperator 2021-05-12T22:09:21.959563+00:00 2021-05-12T22:09:22.387358+00:00 0:00:00.427795 27417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T22:09:19.731446+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T21:00:00+00:00 EmrJobFlowSensor 2021-05-12T22:01:09.319296+00:00 2021-05-12T22:09:12.046482+00:00 0:08:02.727186 27413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T22:01:06.955525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T22:00:43.195401+00:00 2021-05-12T22:00:45.124812+00:00 0:00:01.929411 27412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T22:00:40.828910+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T21:00:00+00:00 PythonOperator 2021-05-12T22:00:17.096434+00:00 2021-05-12T22:00:20.250639+00:00 0:00:03.154205 27411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T22:00:14.805970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T20:00:00+00:00 TriggerDagRunOperator 2021-05-12T21:10:16.006680+00:00 2021-05-12T21:10:16.538186+00:00 0:00:00.531506 27403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T21:10:13.619575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T20:00:00+00:00 TriggerDagRunOperator 2021-05-12T21:10:15.855338+00:00 2021-05-12T21:10:16.301933+00:00 0:00:00.446595 27402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T21:10:13.619607+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T20:00:00+00:00 EmrJobFlowSensor 2021-05-12T21:00:56.551989+00:00 2021-05-12T21:09:59.468352+00:00 0:09:02.916363 27398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T21:00:54.331829+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T21:00:36.546437+00:00 2021-05-12T21:00:38.358481+00:00 0:00:01.812044 27397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T21:00:34.314240+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T20:00:00+00:00 PythonOperator 2021-05-12T21:00:14.523733+00:00 2021-05-12T21:00:17.738843+00:00 0:00:03.215110 27396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T21:00:12.294034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T19:00:00+00:00 TriggerDagRunOperator 2021-05-12T20:12:34.185453+00:00 2021-05-12T20:12:34.730216+00:00 0:00:00.544763 27389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T20:12:31.468673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T19:00:00+00:00 TriggerDagRunOperator 2021-05-12T20:12:33.852452+00:00 2021-05-12T20:12:34.305632+00:00 0:00:00.453180 27388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T20:12:31.468700+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T19:00:00+00:00 EmrJobFlowSensor 2021-05-12T20:01:50.091818+00:00 2021-05-12T20:11:52.878969+00:00 0:10:02.787151 27383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T20:01:47.822598+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T20:01:28.028067+00:00 2021-05-12T20:01:29.716672+00:00 0:00:01.688605 27382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T20:01:25.809161+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T19:00:00+00:00 PythonOperator 2021-05-12T20:00:08.331837+00:00 2021-05-12T20:00:11.487274+00:00 0:00:03.155437 27381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T20:00:05.720266+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T18:00:00+00:00 TriggerDagRunOperator 2021-05-12T19:09:19.701832+00:00 2021-05-12T19:09:20.260556+00:00 0:00:00.558724 27373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T19:09:17.297723+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T18:00:00+00:00 TriggerDagRunOperator 2021-05-12T19:09:19.662357+00:00 2021-05-12T19:09:20.110609+00:00 0:00:00.448252 27372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T19:09:17.297756+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T18:00:00+00:00 EmrJobFlowSensor 2021-05-12T19:01:06.713463+00:00 2021-05-12T19:09:09.279125+00:00 0:08:02.565662 27368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T19:01:04.469229+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T19:00:46.754316+00:00 2021-05-12T19:00:48.568445+00:00 0:00:01.814129 27367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T19:00:44.457184+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T18:00:00+00:00 PythonOperator 2021-05-12T19:00:16.417344+00:00 2021-05-12T19:00:19.555141+00:00 0:00:03.137797 27366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T19:00:14.331289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T17:00:00+00:00 TriggerDagRunOperator 2021-05-12T18:11:11.422296+00:00 2021-05-12T18:11:12.019344+00:00 0:00:00.597048 27359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T18:11:08.894221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T17:00:00+00:00 TriggerDagRunOperator 2021-05-12T18:11:11.386376+00:00 2021-05-12T18:11:11.769903+00:00 0:00:00.383527 27358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T18:11:08.894193+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T17:00:00+00:00 EmrJobFlowSensor 2021-05-12T18:01:53.860357+00:00 2021-05-12T18:10:56.548914+00:00 0:09:02.688557 27353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T18:01:51.729106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T18:01:31.878416+00:00 2021-05-12T18:01:33.553525+00:00 0:00:01.675109 27352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T18:01:29.707651+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T17:00:00+00:00 PythonOperator 2021-05-12T18:01:11.893341+00:00 2021-05-12T18:01:15.069304+00:00 0:00:03.175963 27351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T18:01:09.689821+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T16:00:00+00:00 TriggerDagRunOperator 2021-05-12T17:11:00.937249+00:00 2021-05-12T17:11:01.444622+00:00 0:00:00.507373 27344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T17:10:58.363150+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T16:00:00+00:00 TriggerDagRunOperator 2021-05-12T17:11:00.741627+00:00 2021-05-12T17:11:01.137254+00:00 0:00:00.395627 27343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T17:10:58.363109+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T16:00:00+00:00 EmrJobFlowSensor 2021-05-12T17:00:46.319187+00:00 2021-05-12T17:10:49.097022+00:00 0:10:02.777835 27338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T17:00:44.060410+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T17:00:26.298733+00:00 2021-05-12T17:00:28.282527+00:00 0:00:01.983794 27337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T17:00:23.967922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T16:00:00+00:00 PythonOperator 2021-05-12T17:00:04.152572+00:00 2021-05-12T17:00:07.288846+00:00 0:00:03.136274 27336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T17:00:01.945003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T15:00:00+00:00 TriggerDagRunOperator 2021-05-12T16:10:19.457912+00:00 2021-05-12T16:10:19.986589+00:00 0:00:00.528677 27329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T16:10:16.822109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T15:00:00+00:00 TriggerDagRunOperator 2021-05-12T16:10:19.080892+00:00 2021-05-12T16:10:19.491402+00:00 0:00:00.410510 27328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T16:10:16.822076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T15:00:00+00:00 EmrJobFlowSensor 2021-05-12T16:01:04.298445+00:00 2021-05-12T16:10:07.009121+00:00 0:09:02.710676 27323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T16:01:01.983235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T16:00:42.200968+00:00 2021-05-12T16:00:43.970312+00:00 0:00:01.769344 27322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T16:00:39.951755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T15:00:00+00:00 PythonOperator 2021-05-12T16:00:20.123633+00:00 2021-05-12T16:00:23.291428+00:00 0:00:03.167795 27321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T16:00:17.905427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T14:00:00+00:00 TriggerDagRunOperator 2021-05-12T15:11:33.546941+00:00 2021-05-12T15:11:34.081983+00:00 0:00:00.535042 27314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T15:11:31.153575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T14:00:00+00:00 TriggerDagRunOperator 2021-05-12T15:11:33.388419+00:00 2021-05-12T15:11:33.818722+00:00 0:00:00.430303 27313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T15:11:31.153523+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T14:00:00+00:00 EmrJobFlowSensor 2021-05-12T15:01:04.913587+00:00 2021-05-12T15:11:07.875654+00:00 0:10:02.962067 27308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T15:01:02.291747+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T15:00:42.475052+00:00 2021-05-12T15:00:44.217974+00:00 0:00:01.742922 27307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T15:00:40.265495+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T14:00:00+00:00 PythonOperator 2021-05-12T15:00:20.564459+00:00 2021-05-12T15:00:23.684015+00:00 0:00:03.119556 27306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T15:00:18.255263+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T13:00:00+00:00 TriggerDagRunOperator 2021-05-12T14:10:45.379258+00:00 2021-05-12T14:10:45.883357+00:00 0:00:00.504099 27299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T14:10:42.996246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T13:00:00+00:00 TriggerDagRunOperator 2021-05-12T14:10:45.178023+00:00 2021-05-12T14:10:45.595522+00:00 0:00:00.417499 27298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T14:10:42.996280+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T13:00:00+00:00 EmrJobFlowSensor 2021-05-12T14:02:30.841717+00:00 2021-05-12T14:10:33.380887+00:00 0:08:02.539170 27294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T14:02:28.540914+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T14:02:10.609534+00:00 2021-05-12T14:02:12.427859+00:00 0:00:01.818325 27293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T14:02:08.389692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T13:00:00+00:00 PythonOperator 2021-05-12T14:01:48.701981+00:00 2021-05-12T14:01:51.828921+00:00 0:00:03.126940 27292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T14:01:46.356922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T12:00:00+00:00 TriggerDagRunOperator 2021-05-12T13:10:09.284318+00:00 2021-05-12T13:10:09.862508+00:00 0:00:00.578190 27284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T13:10:06.749309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T12:00:00+00:00 TriggerDagRunOperator 2021-05-12T13:10:08.969412+00:00 2021-05-12T13:10:09.482908+00:00 0:00:00.513496 27283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T13:10:06.749345+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T12:00:00+00:00 EmrJobFlowSensor 2021-05-12T13:01:00.478186+00:00 2021-05-12T13:10:03.345568+00:00 0:09:02.867382 27279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T13:00:57.992414+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T13:00:38.117283+00:00 2021-05-12T13:00:39.834674+00:00 0:00:01.717391 27278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T13:00:35.951542+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T12:00:00+00:00 PythonOperator 2021-05-12T13:00:18.658773+00:00 2021-05-12T13:00:21.789698+00:00 0:00:03.130925 27277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T13:00:15.936934+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T11:00:00+00:00 TriggerDagRunOperator 2021-05-12T12:11:22.982381+00:00 2021-05-12T12:11:23.517724+00:00 0:00:00.535343 27269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T12:11:20.625992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T11:00:00+00:00 TriggerDagRunOperator 2021-05-12T12:11:22.884894+00:00 2021-05-12T12:11:23.322165+00:00 0:00:00.437271 27268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T12:11:20.626022+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T11:00:00+00:00 EmrJobFlowSensor 2021-05-12T12:00:54.007584+00:00 2021-05-12T12:10:57.005323+00:00 0:10:02.997739 27264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T12:00:51.402205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T12:00:31.502234+00:00 2021-05-12T12:00:33.221622+00:00 0:00:01.719388 27263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T12:00:29.386865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T11:00:00+00:00 PythonOperator 2021-05-12T12:00:11.565344+00:00 2021-05-12T12:00:14.714562+00:00 0:00:03.149218 27262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T12:00:09.343073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T10:00:00+00:00 TriggerDagRunOperator 2021-05-12T11:10:23.287691+00:00 2021-05-12T11:10:23.832518+00:00 0:00:00.544827 27254 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:10:20.266334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T10:00:00+00:00 TriggerDagRunOperator 2021-05-12T11:10:22.637323+00:00 2021-05-12T11:10:23.014399+00:00 0:00:00.377076 27253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:10:20.266303+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T10:00:00+00:00 EmrJobFlowSensor 2021-05-12T11:01:11.453830+00:00 2021-05-12T11:10:14.307739+00:00 0:09:02.853909 27249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T11:01:09.256608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T11:00:45.686220+00:00 2021-05-12T11:00:47.510761+00:00 0:00:01.824541 27248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T11:00:43.234852+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T10:00:00+00:00 PythonOperator 2021-05-12T11:00:24.090270+00:00 2021-05-12T11:00:27.221181+00:00 0:00:03.130911 27247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T11:00:21.251059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T09:00:00+00:00 TriggerDagRunOperator 2021-05-12T10:23:09.891651+00:00 2021-05-12T10:23:10.439262+00:00 0:00:00.547611 27239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T10:23:07.518997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T09:00:00+00:00 TriggerDagRunOperator 2021-05-12T10:23:09.644067+00:00 2021-05-12T10:23:10.045920+00:00 0:00:00.401853 27238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T10:23:07.518966+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T09:00:00+00:00 EmrJobFlowSensor 2021-05-12T10:00:49.494893+00:00 2021-05-12T10:22:54.043062+00:00 0:22:04.548169 27234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T10:00:47.166463+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T10:00:29.399666+00:00 2021-05-12T10:00:31.119522+00:00 0:00:01.719856 27233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T10:00:27.146767+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T09:00:00+00:00 PythonOperator 2021-05-12T10:00:07.489998+00:00 2021-05-12T10:00:10.631784+00:00 0:00:03.141786 27232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T10:00:05.039410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T08:00:00+00:00 TriggerDagRunOperator 2021-05-12T09:10:20.488695+00:00 2021-05-12T09:10:21.006966+00:00 0:00:00.518271 27224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T09:10:18.004615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T08:00:00+00:00 TriggerDagRunOperator 2021-05-12T09:10:20.370380+00:00 2021-05-12T09:10:20.758143+00:00 0:00:00.387763 27223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T09:10:18.004569+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T08:00:00+00:00 EmrJobFlowSensor 2021-05-12T09:00:59.454187+00:00 2021-05-12T09:10:02.253588+00:00 0:09:02.799401 27219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T09:00:57.173246+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T09:00:39.493586+00:00 2021-05-12T09:00:41.182029+00:00 0:00:01.688443 27218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T09:00:37.167268+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T08:00:00+00:00 PythonOperator 2021-05-12T09:00:17.611892+00:00 2021-05-12T09:00:20.695699+00:00 0:00:03.083807 27217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T09:00:15.143617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T07:00:00+00:00 TriggerDagRunOperator 2021-05-12T08:13:30.456316+00:00 2021-05-12T08:13:30.968350+00:00 0:00:00.512034 27209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T08:13:27.957863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T07:00:00+00:00 TriggerDagRunOperator 2021-05-12T08:13:30.374063+00:00 2021-05-12T08:13:30.759979+00:00 0:00:00.385916 27208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T08:13:27.957834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T07:00:00+00:00 EmrJobFlowSensor 2021-05-12T08:01:04.920320+00:00 2021-05-12T08:13:08.199673+00:00 0:12:03.279353 27204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T08:01:02.783705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T08:00:42.908258+00:00 2021-05-12T08:00:44.742290+00:00 0:00:01.834032 27203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T08:00:40.715278+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T07:00:00+00:00 PythonOperator 2021-05-12T08:00:21.047333+00:00 2021-05-12T08:00:24.129401+00:00 0:00:03.082068 27202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T08:00:18.700051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T06:00:00+00:00 TriggerDagRunOperator 2021-05-12T07:11:10.208263+00:00 2021-05-12T07:11:10.737010+00:00 0:00:00.528747 27194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T07:11:07.827093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T06:00:00+00:00 TriggerDagRunOperator 2021-05-12T07:11:10.046190+00:00 2021-05-12T07:11:10.450338+00:00 0:00:00.404148 27193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T07:11:07.827127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T06:00:00+00:00 EmrJobFlowSensor 2021-05-12T07:00:53.209673+00:00 2021-05-12T07:10:56.135611+00:00 0:10:02.925938 27189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T07:00:50.815251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T07:00:27.026715+00:00 2021-05-12T07:00:28.745289+00:00 0:00:01.718574 27188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T07:00:24.788534+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T06:00:00+00:00 PythonOperator 2021-05-12T07:00:06.885827+00:00 2021-05-12T07:00:09.998159+00:00 0:00:03.112332 27187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T07:00:04.686605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T05:00:00+00:00 TriggerDagRunOperator 2021-05-12T06:11:36.832509+00:00 2021-05-12T06:11:37.370467+00:00 0:00:00.537958 27179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T06:11:34.485710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T05:00:00+00:00 TriggerDagRunOperator 2021-05-12T06:11:36.661771+00:00 2021-05-12T06:11:37.074752+00:00 0:00:00.412981 27178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T06:11:34.485752+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T05:00:00+00:00 EmrJobFlowSensor 2021-05-12T06:01:07.197048+00:00 2021-05-12T06:11:10.158940+00:00 0:10:02.961892 27174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T06:01:05.097907+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T06:00:45.664214+00:00 2021-05-12T06:00:47.535307+00:00 0:00:01.871093 27173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T06:00:43.078296+00:00 2 default_pool