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-04-25T13:00:00+00:00 PythonOperator 2021-04-25T14:00:10.915040+00:00 2021-04-25T14:00:13.951063+00:00 0:00:03.036023 21120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T14:00:07.948489+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T12:00:00+00:00 TriggerDagRunOperator 2021-04-25T13:11:30.578513+00:00 2021-04-25T13:11:31.157860+00:00 0:00:00.579347 21112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T13:11:27.975512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T12:00:00+00:00 TriggerDagRunOperator 2021-04-25T13:11:30.367068+00:00 2021-04-25T13:11:30.825357+00:00 0:00:00.458289 21111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T13:11:27.975470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T12:00:00+00:00 EmrJobFlowSensor 2021-04-25T13:01:07.177051+00:00 2021-04-25T13:11:10.091391+00:00 0:10:02.914340 21107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T13:01:04.555931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T13:00:42.692671+00:00 2021-04-25T13:00:44.479271+00:00 0:00:01.786600 21106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T13:00:40.395177+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T12:00:00+00:00 PythonOperator 2021-04-25T13:00:22.505734+00:00 2021-04-25T13:00:25.482913+00:00 0:00:02.977179 21105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T13:00:20.382987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T11:00:00+00:00 TriggerDagRunOperator 2021-04-25T12:30:19.176660+00:00 2021-04-25T12:30:19.591020+00:00 0:00:00.414360 21098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T12:30:16.575426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T11:00:00+00:00 TriggerDagRunOperator 2021-04-25T12:30:18.889954+00:00 2021-04-25T12:30:19.419596+00:00 0:00:00.529642 21097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T12:30:16.575456+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T11:00:00+00:00 EmrJobFlowSensor 2021-04-25T12:20:55.711263+00:00 2021-04-25T12:29:58.390748+00:00 0:09:02.679485 21095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T12:20:53.270575+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T12:20:33.518939+00:00 2021-04-25T12:20:35.320514+00:00 0:00:01.801575 21093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T12:20:31.186087+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T11:00:00+00:00 PythonOperator 2021-04-25T12:20:14.009680+00:00 2021-04-25T12:20:17.010665+00:00 0:00:03.000985 21091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T12:20:11.172139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T10:00:00+00:00 TriggerDagRunOperator 2021-04-25T11:09:10.389963+00:00 2021-04-25T11:09:10.828938+00:00 0:00:00.438975 21083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T11:09:08.046665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T10:00:00+00:00 TriggerDagRunOperator 2021-04-25T11:09:10.390738+00:00 2021-04-25T11:09:10.937524+00:00 0:00:00.546786 21082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T11:09:08.046632+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T10:00:00+00:00 EmrJobFlowSensor 2021-04-25T11:00:57.434426+00:00 2021-04-25T11:08:59.974196+00:00 0:08:02.539770 21078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T11:00:55.305784+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T11:00:29.579560+00:00 2021-04-25T11:00:31.359342+00:00 0:00:01.779782 21077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T11:00:27.288739+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T10:00:00+00:00 PythonOperator 2021-04-25T11:00:09.554968+00:00 2021-04-25T11:00:12.508650+00:00 0:00:02.953682 21076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T11:00:07.227083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T09:00:00+00:00 TriggerDagRunOperator 2021-04-25T10:11:18.803277+00:00 2021-04-25T10:11:19.211274+00:00 0:00:00.407997 21067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T10:11:15.944676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T09:00:00+00:00 TriggerDagRunOperator 2021-04-25T10:11:18.476212+00:00 2021-04-25T10:11:18.978263+00:00 0:00:00.502051 21066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T10:11:15.944711+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T09:00:00+00:00 EmrJobFlowSensor 2021-04-25T10:01:07.262001+00:00 2021-04-25T10:11:10.112106+00:00 0:10:02.850105 21062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T10:01:04.848866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T10:00:45.206967+00:00 2021-04-25T10:00:46.998646+00:00 0:00:01.791679 21061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T10:00:42.773451+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T09:00:00+00:00 PythonOperator 2021-04-25T10:00:24.991362+00:00 2021-04-25T10:00:27.997369+00:00 0:00:03.006007 21060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T10:00:22.704718+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T08:00:00+00:00 TriggerDagRunOperator 2021-04-25T09:10:19.189712+00:00 2021-04-25T09:10:19.597363+00:00 0:00:00.407651 21052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T09:10:16.903869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T08:00:00+00:00 TriggerDagRunOperator 2021-04-25T09:10:19.213675+00:00 2021-04-25T09:10:19.746983+00:00 0:00:00.533308 21051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T09:10:16.903903+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T08:00:00+00:00 EmrJobFlowSensor 2021-04-25T09:01:08.210925+00:00 2021-04-25T09:10:10.887592+00:00 0:09:02.676667 21047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T09:01:06.014601+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T09:00:46.393104+00:00 2021-04-25T09:00:48.157860+00:00 0:00:01.764756 21046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T09:00:44.068732+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T08:00:00+00:00 PythonOperator 2021-04-25T09:00:24.701266+00:00 2021-04-25T09:00:27.664946+00:00 0:00:02.963680 21045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T09:00:21.960449+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T07:00:00+00:00 TriggerDagRunOperator 2021-04-25T08:09:14.900109+00:00 2021-04-25T08:09:15.401014+00:00 0:00:00.500905 21037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T08:09:12.053508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T07:00:00+00:00 TriggerDagRunOperator 2021-04-25T08:09:14.481904+00:00 2021-04-25T08:09:14.889845+00:00 0:00:00.407941 21036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T08:09:12.053450+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T07:00:00+00:00 EmrJobFlowSensor 2021-04-25T08:01:03.768836+00:00 2021-04-25T08:09:06.466251+00:00 0:08:02.697415 21032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T08:01:01.291501+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T08:00:39.697887+00:00 2021-04-25T08:00:41.498939+00:00 0:00:01.801052 21031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T08:00:37.264444+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T07:00:00+00:00 PythonOperator 2021-04-25T08:00:17.581805+00:00 2021-04-25T08:00:20.592388+00:00 0:00:03.010583 21030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T08:00:15.220833+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T06:00:00+00:00 TriggerDagRunOperator 2021-04-25T07:10:22.735199+00:00 2021-04-25T07:10:23.167901+00:00 0:00:00.432702 21022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T07:10:20.200552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T06:00:00+00:00 TriggerDagRunOperator 2021-04-25T07:10:22.705141+00:00 2021-04-25T07:10:23.263826+00:00 0:00:00.558685 21021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T07:10:20.200579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T06:00:00+00:00 EmrJobFlowSensor 2021-04-25T07:01:01.758574+00:00 2021-04-25T07:10:04.737057+00:00 0:09:02.978483 21017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T07:00:59.440924+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T07:00:39.910794+00:00 2021-04-25T07:00:41.709384+00:00 0:00:01.798590 21016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T07:00:37.427912+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T06:00:00+00:00 PythonOperator 2021-04-25T07:00:17.998374+00:00 2021-04-25T07:00:20.985981+00:00 0:00:02.987607 21015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T07:00:15.467720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T05:00:00+00:00 TriggerDagRunOperator 2021-04-25T06:11:13.264396+00:00 2021-04-25T06:11:13.854700+00:00 0:00:00.590304 21007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T06:11:10.946281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T05:00:00+00:00 TriggerDagRunOperator 2021-04-25T06:11:13.204297+00:00 2021-04-25T06:11:13.609778+00:00 0:00:00.405481 21006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T06:11:10.946316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T05:00:00+00:00 EmrJobFlowSensor 2021-04-25T06:00:54.430273+00:00 2021-04-25T06:10:57.318506+00:00 0:10:02.888233 21002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T06:00:51.980006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T06:00:34.425148+00:00 2021-04-25T06:00:36.236348+00:00 0:00:01.811200 21001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T06:00:31.947291+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T05:00:00+00:00 PythonOperator 2021-04-25T06:00:12.447116+00:00 2021-04-25T06:00:15.407700+00:00 0:00:02.960584 21000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T06:00:09.952800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T04:00:00+00:00 TriggerDagRunOperator 2021-04-25T05:10:16.098175+00:00 2021-04-25T05:10:16.512062+00:00 0:00:00.413887 20992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T05:10:13.787139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T04:00:00+00:00 TriggerDagRunOperator 2021-04-25T05:10:16.011786+00:00 2021-04-25T05:10:16.564818+00:00 0:00:00.553032 20991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T05:10:13.787106+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T04:00:00+00:00 EmrJobFlowSensor 2021-04-25T05:00:54.934683+00:00 2021-04-25T05:09:57.663958+00:00 0:09:02.729275 20987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T05:00:52.618735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T05:00:32.825252+00:00 2021-04-25T05:00:34.475035+00:00 0:00:01.649783 20986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T05:00:30.585697+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T04:00:00+00:00 PythonOperator 2021-04-25T05:00:11.216252+00:00 2021-04-25T05:00:14.206226+00:00 0:00:02.989974 20985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T05:00:08.564329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T03:00:00+00:00 TriggerDagRunOperator 2021-04-25T04:11:16.826999+00:00 2021-04-25T04:11:17.245192+00:00 0:00:00.418193 20977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T04:11:14.026949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T03:00:00+00:00 TriggerDagRunOperator 2021-04-25T04:11:16.515353+00:00 2021-04-25T04:11:17.054982+00:00 0:00:00.539629 20976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T04:11:14.026999+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T03:00:00+00:00 EmrJobFlowSensor 2021-04-25T04:01:05.337674+00:00 2021-04-25T04:11:08.324493+00:00 0:10:02.986819 20972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T04:01:02.984613+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T04:00:43.279081+00:00 2021-04-25T04:00:44.959048+00:00 0:00:01.679967 20971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T04:00:40.922001+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T03:00:00+00:00 PythonOperator 2021-04-25T04:00:21.362454+00:00 2021-04-25T04:00:24.385733+00:00 0:00:03.023279 20970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T04:00:18.903919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T02:00:00+00:00 TriggerDagRunOperator 2021-04-25T03:10:21.254194+00:00 2021-04-25T03:10:21.821619+00:00 0:00:00.567425 20962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T03:10:18.924849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T02:00:00+00:00 TriggerDagRunOperator 2021-04-25T03:10:21.159992+00:00 2021-04-25T03:10:21.616440+00:00 0:00:00.456448 20961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T03:10:18.924817+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T02:00:00+00:00 EmrJobFlowSensor 2021-04-25T03:01:04.509136+00:00 2021-04-25T03:10:07.373723+00:00 0:09:02.864587 20957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T03:01:02.066928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T03:00:42.421950+00:00 2021-04-25T03:00:44.160873+00:00 0:00:01.738923 20956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T03:00:40.061516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T02:00:00+00:00 PythonOperator 2021-04-25T03:00:22.316952+00:00 2021-04-25T03:00:25.292960+00:00 0:00:02.976008 20955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T03:00:19.974335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T01:00:00+00:00 TriggerDagRunOperator 2021-04-25T02:10:11.411382+00:00 2021-04-25T02:10:12.043497+00:00 0:00:00.632115 20947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T02:10:09.190693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T01:00:00+00:00 TriggerDagRunOperator 2021-04-25T02:10:11.386920+00:00 2021-04-25T02:10:11.872849+00:00 0:00:00.485929 20946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T02:10:09.190728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T01:00:00+00:00 EmrJobFlowSensor 2021-04-25T02:01:02.618543+00:00 2021-04-25T02:10:05.424025+00:00 0:09:02.805482 20942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T02:01:00.290164+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T02:00:42.412106+00:00 2021-04-25T02:00:44.098405+00:00 0:00:01.686299 20941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T02:00:40.244891+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T01:00:00+00:00 PythonOperator 2021-04-25T02:00:20.547114+00:00 2021-04-25T02:00:23.551176+00:00 0:00:03.004062 20940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T02:00:18.226888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T00:00:00+00:00 TriggerDagRunOperator 2021-04-25T01:10:13.468433+00:00 2021-04-25T01:10:14.000856+00:00 0:00:00.532423 20932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T01:10:11.096268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T00:00:00+00:00 TriggerDagRunOperator 2021-04-25T01:10:13.279900+00:00 2021-04-25T01:10:13.708520+00:00 0:00:00.428620 20931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T01:10:11.096301+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T00:00:00+00:00 EmrJobFlowSensor 2021-04-25T01:00:50.179499+00:00 2021-04-25T01:09:52.739382+00:00 0:09:02.559883 20927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T01:00:47.937307+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T01:00:28.128537+00:00 2021-04-25T01:00:29.895852+00:00 0:00:01.767315 20926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T01:00:25.908435+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T00:00:00+00:00 PythonOperator 2021-04-25T01:00:08.237839+00:00 2021-04-25T01:00:11.268211+00:00 0:00:03.030372 20925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T01:00:05.889124+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T23:00:00+00:00 TriggerDagRunOperator 2021-04-25T00:10:21.853752+00:00 2021-04-25T00:10:22.405205+00:00 0:00:00.551453 20917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T00:10:19.536460+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T23:00:00+00:00 TriggerDagRunOperator 2021-04-25T00:10:21.724241+00:00 2021-04-25T00:10:22.127474+00:00 0:00:00.403233 20916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T00:10:19.536430+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T23:00:00+00:00 EmrJobFlowSensor 2021-04-25T00:00:54.792492+00:00 2021-04-25T00:09:57.537049+00:00 0:09:02.744557 20912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T00:00:52.596529+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T00:00:35.178233+00:00 2021-04-25T00:00:36.908392+00:00 0:00:01.730159 20911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T00:00:32.655578+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T23:00:00+00:00 PythonOperator 2021-04-25T00:00:12.995663+00:00 2021-04-25T00:00:16.028064+00:00 0:00:03.032401 20910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T00:00:10.519567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T22:00:00+00:00 TriggerDagRunOperator 2021-04-24T23:10:13.229640+00:00 2021-04-24T23:10:13.647805+00:00 0:00:00.418165 20902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T23:10:10.927615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T22:00:00+00:00 TriggerDagRunOperator 2021-04-24T23:10:13.234497+00:00 2021-04-24T23:10:13.794804+00:00 0:00:00.560307 20901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T23:10:10.927588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T22:00:00+00:00 EmrJobFlowSensor 2021-04-24T23:00:52.305559+00:00 2021-04-24T23:09:55.187413+00:00 0:09:02.881854 20896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T23:00:49.999587+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T23:00:30.502667+00:00 2021-04-24T23:00:32.182141+00:00 0:00:01.679474 20894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T23:00:28.064489+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T22:00:00+00:00 PythonOperator 2021-04-24T23:00:10.416221+00:00 2021-04-24T23:00:13.399665+00:00 0:00:02.983444 20892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T23:00:07.979862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T21:00:00+00:00 TriggerDagRunOperator 2021-04-24T22:09:12.873187+00:00 2021-04-24T22:09:13.402698+00:00 0:00:00.529511 20884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T22:09:10.517912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T21:00:00+00:00 TriggerDagRunOperator 2021-04-24T22:09:12.767885+00:00 2021-04-24T22:09:13.170782+00:00 0:00:00.402897 20883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T22:09:10.517885+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T21:00:00+00:00 EmrJobFlowSensor 2021-04-24T22:00:58.117834+00:00 2021-04-24T22:09:00.762487+00:00 0:08:02.644653 20879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T22:00:55.769728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T22:00:36.093100+00:00 2021-04-24T22:00:37.810094+00:00 0:00:01.716994 20878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T22:00:33.763708+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T21:00:00+00:00 PythonOperator 2021-04-24T22:00:14.214905+00:00 2021-04-24T22:00:17.218766+00:00 0:00:03.003861 20877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T22:00:11.651623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T20:00:00+00:00 TriggerDagRunOperator 2021-04-24T21:10:33.594018+00:00 2021-04-24T21:10:34.162600+00:00 0:00:00.568582 20869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T21:10:31.232077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T20:00:00+00:00 TriggerDagRunOperator 2021-04-24T21:10:33.430970+00:00 2021-04-24T21:10:33.849686+00:00 0:00:00.418716 20868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T21:10:31.232127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T20:00:00+00:00 EmrJobFlowSensor 2021-04-24T21:01:04.506536+00:00 2021-04-24T21:10:07.529073+00:00 0:09:03.022537 20864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T21:01:02.260701+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T21:00:42.455431+00:00 2021-04-24T21:00:44.286453+00:00 0:00:01.831022 20863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T21:00:40.190571+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T20:00:00+00:00 PythonOperator 2021-04-24T21:00:22.777297+00:00 2021-04-24T21:00:25.769372+00:00 0:00:02.992075 20862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T21:00:20.117592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T19:00:00+00:00 TriggerDagRunOperator 2021-04-24T20:10:26.807583+00:00 2021-04-24T20:10:27.330036+00:00 0:00:00.522453 20854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T20:10:24.412938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T19:00:00+00:00 TriggerDagRunOperator 2021-04-24T20:10:26.690189+00:00 2021-04-24T20:10:27.109389+00:00 0:00:00.419200 20853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T20:10:24.412905+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T19:00:00+00:00 EmrJobFlowSensor 2021-04-24T20:01:03.720931+00:00 2021-04-24T20:10:06.479297+00:00 0:09:02.758366 20849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T20:01:01.488235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T20:00:41.639870+00:00 2021-04-24T20:00:43.354442+00:00 0:00:01.714572 20848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T20:00:39.457353+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T19:00:00+00:00 PythonOperator 2021-04-24T20:00:21.742428+00:00 2021-04-24T20:00:24.774088+00:00 0:00:03.031660 20847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T20:00:19.439348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T18:00:00+00:00 TriggerDagRunOperator 2021-04-24T19:10:59.075707+00:00 2021-04-24T19:10:59.613598+00:00 0:00:00.537891 20839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T19:10:56.389587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T18:00:00+00:00 TriggerDagRunOperator 2021-04-24T19:10:58.975856+00:00 2021-04-24T19:10:59.396539+00:00 0:00:00.420683 20838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T19:10:56.389534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T18:00:00+00:00 EmrJobFlowSensor 2021-04-24T19:00:48.159445+00:00 2021-04-24T19:10:51.113527+00:00 0:10:02.954082 20834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T19:00:45.647284+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T19:00:25.780400+00:00 2021-04-24T19:00:27.459821+00:00 0:00:01.679421 20833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T19:00:23.487350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T18:00:00+00:00 PythonOperator 2021-04-24T19:00:06.108047+00:00 2021-04-24T19:00:09.128332+00:00 0:00:03.020285 20832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T19:00:03.470194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T17:00:00+00:00 TriggerDagRunOperator 2021-04-24T18:10:17.380501+00:00 2021-04-24T18:10:17.946105+00:00 0:00:00.565604 20824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:10:14.959674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T17:00:00+00:00 TriggerDagRunOperator 2021-04-24T18:10:17.140781+00:00 2021-04-24T18:10:17.538638+00:00 0:00:00.397857 20823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:10:14.959724+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T17:00:00+00:00 EmrJobFlowSensor 2021-04-24T18:01:04.917433+00:00 2021-04-24T18:10:07.782257+00:00 0:09:02.864824 20819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:01:02.167161+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:00:42.229219+00:00 2021-04-24T18:00:43.884489+00:00 0:00:01.655270 20818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T18:00:40.077959+00:00 2 default_pool