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-09T17:00:00+00:00 PythonOperator 2021-05-09T18:00:07.022973+00:00 2021-05-09T18:00:10.110882+00:00 0:00:03.087909 26262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T18:00:04.598203+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T16:00:00+00:00 TriggerDagRunOperator 2021-05-09T17:11:30.207028+00:00 2021-05-09T17:11:30.787307+00:00 0:00:00.580279 26255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:11:27.691111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T16:00:00+00:00 TriggerDagRunOperator 2021-05-09T17:11:30.083031+00:00 2021-05-09T17:11:30.542121+00:00 0:00:00.459090 26254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:11:27.691084+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:00:58.487607+00:00 2021-05-09T17:11:01.282573+00:00 0:10:02.794966 26249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:00:56.256488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:00:38.440436+00:00 2021-05-09T17:00:40.173798+00:00 0:00:01.733362 26248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T17:00:36.201696+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:00:16.328572+00:00 2021-05-09T17:00:19.382894+00:00 0:00:03.054322 26247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T17:00:14.190661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T15:00:00+00:00 TriggerDagRunOperator 2021-05-09T16:10:15.824255+00:00 2021-05-09T16:10:16.348532+00:00 0:00:00.524277 26240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:10:12.747300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T15:00:00+00:00 TriggerDagRunOperator 2021-05-09T16:10:15.676104+00:00 2021-05-09T16:10:16.065492+00:00 0:00:00.389388 26239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T16:10:12.747345+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T15:00:00+00:00 EmrJobFlowSensor 2021-05-09T16:00:58.609670+00:00 2021-05-09T16:10:01.452578+00:00 0:09:02.842908 26234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T16:00:56.278393+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T16:00:38.400875+00:00 2021-05-09T16:00:40.094965+00:00 0:00:01.694090 26233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T16:00:36.248751+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T15:00:00+00:00 PythonOperator 2021-05-09T16:00:16.471192+00:00 2021-05-09T16:00:19.589059+00:00 0:00:03.117867 26232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T16:00:14.226084+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T14:00:00+00:00 TriggerDagRunOperator 2021-05-09T15:11:25.418392+00:00 2021-05-09T15:11:25.916866+00:00 0:00:00.498474 26225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:11:23.103881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T14:00:00+00:00 TriggerDagRunOperator 2021-05-09T15:11:25.289698+00:00 2021-05-09T15:11:25.685375+00:00 0:00:00.395677 26224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T15:11:23.103847+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T14:00:00+00:00 EmrJobFlowSensor 2021-05-09T15:00:49.828413+00:00 2021-05-09T15:10:52.604670+00:00 0:10:02.776257 26219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T15:00:47.644940+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T15:00:27.901541+00:00 2021-05-09T15:00:29.687680+00:00 0:00:01.786139 26218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T15:00:25.614711+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T14:00:00+00:00 PythonOperator 2021-05-09T15:00:06.217727+00:00 2021-05-09T15:00:09.332720+00:00 0:00:03.114993 26217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T15:00:03.647861+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T13:00:00+00:00 TriggerDagRunOperator 2021-05-09T14:13:18.795375+00:00 2021-05-09T14:13:19.302828+00:00 0:00:00.507453 26210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T14:13:16.393276+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T13:00:00+00:00 TriggerDagRunOperator 2021-05-09T14:13:18.581953+00:00 2021-05-09T14:13:18.993051+00:00 0:00:00.411098 26209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T14:13:16.393232+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T13:00:00+00:00 EmrJobFlowSensor 2021-05-09T14:04:11.493783+00:00 2021-05-09T14:13:14.254327+00:00 0:09:02.760544 26205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T14:04:09.373558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T14:03:51.465750+00:00 2021-05-09T14:03:53.154825+00:00 0:00:01.689075 26204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T14:03:49.306514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T13:00:00+00:00 PythonOperator 2021-05-09T14:03:29.900679+00:00 2021-05-09T14:03:33.055893+00:00 0:00:03.155214 26203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T14:03:27.226894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T12:00:00+00:00 TriggerDagRunOperator 2021-05-09T13:10:17.522399+00:00 2021-05-09T13:10:18.098459+00:00 0:00:00.576060 26195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T13:10:15.056227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T12:00:00+00:00 TriggerDagRunOperator 2021-05-09T13:10:17.477610+00:00 2021-05-09T13:10:17.887525+00:00 0:00:00.409915 26194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T13:10:15.056197+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T12:00:00+00:00 EmrJobFlowSensor 2021-05-09T13:00:54.390255+00:00 2021-05-09T13:09:56.995509+00:00 0:09:02.605254 26190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T13:00:52.050590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T13:00:34.269745+00:00 2021-05-09T13:00:36.152263+00:00 0:00:01.882518 26189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T13:00:31.925129+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T12:00:00+00:00 PythonOperator 2021-05-09T13:00:12.562018+00:00 2021-05-09T13:00:15.745269+00:00 0:00:03.183251 26188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T13:00:09.904912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T11:00:00+00:00 TriggerDagRunOperator 2021-05-09T12:10:14.251794+00:00 2021-05-09T12:10:14.791756+00:00 0:00:00.539962 26180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:10:11.679983+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T11:00:00+00:00 TriggerDagRunOperator 2021-05-09T12:10:13.926435+00:00 2021-05-09T12:10:14.378142+00:00 0:00:00.451707 26179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T12:10:11.679952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T11:00:00+00:00 EmrJobFlowSensor 2021-05-09T12:01:05.030532+00:00 2021-05-09T12:10:07.793102+00:00 0:09:02.762570 26175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T12:01:02.684084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T12:00:43.066492+00:00 2021-05-09T12:00:44.994980+00:00 0:00:01.928488 26174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T12:00:40.669118+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T11:00:00+00:00 PythonOperator 2021-05-09T12:00:21.048312+00:00 2021-05-09T12:00:24.152582+00:00 0:00:03.104270 26173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T12:00:18.608207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T10:00:00+00:00 TriggerDagRunOperator 2021-05-09T11:09:18.333899+00:00 2021-05-09T11:09:18.840532+00:00 0:00:00.506633 26165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:09:15.749271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T10:00:00+00:00 TriggerDagRunOperator 2021-05-09T11:09:18.104109+00:00 2021-05-09T11:09:18.515278+00:00 0:00:00.411169 26164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:09:15.749328+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T10:00:00+00:00 EmrJobFlowSensor 2021-05-09T11:00:55.081251+00:00 2021-05-09T11:08:57.711607+00:00 0:08:02.630356 26160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:00:52.801176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:00:33.320923+00:00 2021-05-09T11:00:35.151808+00:00 0:00:01.830885 26159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T11:00:30.851450+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T10:00:00+00:00 PythonOperator 2021-05-09T11:00:12.823660+00:00 2021-05-09T11:00:15.884933+00:00 0:00:03.061273 26158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T11:00:10.584905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T09:00:00+00:00 TriggerDagRunOperator 2021-05-09T10:10:17.037027+00:00 2021-05-09T10:10:17.600441+00:00 0:00:00.563414 26150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:10:14.690065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T09:00:00+00:00 TriggerDagRunOperator 2021-05-09T10:10:16.874836+00:00 2021-05-09T10:10:17.291533+00:00 0:00:00.416697 26149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:10:14.690097+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T09:00:00+00:00 EmrJobFlowSensor 2021-05-09T10:00:54.062801+00:00 2021-05-09T10:09:56.908691+00:00 0:09:02.845890 26145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:00:51.814151+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:00:31.967138+00:00 2021-05-09T10:00:33.680852+00:00 0:00:01.713714 26144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T10:00:29.793955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T09:00:00+00:00 PythonOperator 2021-05-09T10:00:10.144396+00:00 2021-05-09T10:00:13.319368+00:00 0:00:03.174972 26143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T10:00:07.756875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T08:00:00+00:00 TriggerDagRunOperator 2021-05-09T09:10:23.449290+00:00 2021-05-09T09:10:23.977531+00:00 0:00:00.528241 26135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:10:21.116775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T08:00:00+00:00 TriggerDagRunOperator 2021-05-09T09:10:23.313181+00:00 2021-05-09T09:10:23.715137+00:00 0:00:00.401956 26134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:10:21.116806+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T08:00:00+00:00 EmrJobFlowSensor 2021-05-09T09:00:56.392259+00:00 2021-05-09T09:09:59.294094+00:00 0:09:02.901835 26130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:00:54.151316+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:00:34.196862+00:00 2021-05-09T09:00:35.936645+00:00 0:00:01.739783 26129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T09:00:32.042497+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T08:00:00+00:00 PythonOperator 2021-05-09T09:00:12.787072+00:00 2021-05-09T09:00:15.839224+00:00 0:00:03.052152 26128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T09:00:10.052327+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T07:00:00+00:00 TriggerDagRunOperator 2021-05-09T08:10:33.533639+00:00 2021-05-09T08:10:34.065300+00:00 0:00:00.531661 26120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:10:30.910465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T07:00:00+00:00 TriggerDagRunOperator 2021-05-09T08:10:33.264706+00:00 2021-05-09T08:10:33.683621+00:00 0:00:00.418915 26119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:10:30.910428+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T07:00:00+00:00 EmrJobFlowSensor 2021-05-09T08:01:06.305022+00:00 2021-05-09T08:10:09.258914+00:00 0:09:02.953892 26115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:01:03.866211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:00:46.091937+00:00 2021-05-09T08:00:47.788594+00:00 0:00:01.696657 26114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T08:00:43.805661+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T07:00:00+00:00 PythonOperator 2021-05-09T08:00:24.099260+00:00 2021-05-09T08:00:27.170871+00:00 0:00:03.071611 26113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T08:00:21.789521+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T06:00:00+00:00 TriggerDagRunOperator 2021-05-09T07:10:24.920489+00:00 2021-05-09T07:10:25.441324+00:00 0:00:00.520835 26105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:10:22.283047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T06:00:00+00:00 TriggerDagRunOperator 2021-05-09T07:10:24.660357+00:00 2021-05-09T07:10:25.096084+00:00 0:00:00.435727 26104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:10:22.283011+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T06:00:00+00:00 EmrJobFlowSensor 2021-05-09T07:00:57.743369+00:00 2021-05-09T07:10:00.517716+00:00 0:09:02.774347 26100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:00:55.454666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:00:35.855755+00:00 2021-05-09T07:00:37.735721+00:00 0:00:01.879966 26099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T07:00:33.455929+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T06:00:00+00:00 PythonOperator 2021-05-09T07:00:13.837588+00:00 2021-05-09T07:00:17.014482+00:00 0:00:03.176894 26098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T07:00:11.379998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T05:00:00+00:00 TriggerDagRunOperator 2021-05-09T06:22:22.465000+00:00 2021-05-09T06:22:22.985810+00:00 0:00:00.520810 26090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:22:20.127610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T05:00:00+00:00 TriggerDagRunOperator 2021-05-09T06:22:22.305466+00:00 2021-05-09T06:22:22.741228+00:00 0:00:00.435762 26089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:22:20.127580+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T05:00:00+00:00 EmrJobFlowSensor 2021-05-09T06:01:04.159477+00:00 2021-05-09T06:22:08.549001+00:00 0:21:04.389524 26085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T06:01:02.019378+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T06:00:40.479704+00:00 2021-05-09T06:00:42.325569+00:00 0:00:01.845865 26084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T06:00:38.060324+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T05:00:00+00:00 PythonOperator 2021-05-09T06:00:18.316188+00:00 2021-05-09T06:00:21.483668+00:00 0:00:03.167480 26083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T06:00:15.957360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T04:00:00+00:00 TriggerDagRunOperator 2021-05-09T05:10:31.622761+00:00 2021-05-09T05:10:32.120939+00:00 0:00:00.498178 26075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T05:10:29.174175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T04:00:00+00:00 TriggerDagRunOperator 2021-05-09T05:10:31.463821+00:00 2021-05-09T05:10:31.886335+00:00 0:00:00.422514 26074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T05:10:29.174120+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T04:00:00+00:00 EmrJobFlowSensor 2021-05-09T05:01:04.469828+00:00 2021-05-09T05:10:07.310834+00:00 0:09:02.841006 26070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T05:01:02.109283+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T05:00:42.299591+00:00 2021-05-09T05:00:44.061059+00:00 0:00:01.761468 26069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T05:00:40.090276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T04:00:00+00:00 PythonOperator 2021-05-09T05:00:18.586203+00:00 2021-05-09T05:00:21.677507+00:00 0:00:03.091304 26068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T05:00:16.017522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T03:00:00+00:00 TriggerDagRunOperator 2021-05-09T04:09:55.151714+00:00 2021-05-09T04:09:55.697058+00:00 0:00:00.545344 26060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:09:52.694621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T03:00:00+00:00 TriggerDagRunOperator 2021-05-09T04:09:55.030580+00:00 2021-05-09T04:09:55.472466+00:00 0:00:00.441886 26059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:09:52.694664+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T03:00:00+00:00 EmrJobFlowSensor 2021-05-09T04:00:46.176818+00:00 2021-05-09T04:09:48.922270+00:00 0:09:02.745452 26055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T04:00:43.853386+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T04:00:26.365193+00:00 2021-05-09T04:00:28.169513+00:00 0:00:01.804320 26054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T04:00:23.859946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T03:00:00+00:00 PythonOperator 2021-05-09T04:00:04.443283+00:00 2021-05-09T04:00:07.567333+00:00 0:00:03.124050 26053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T04:00:01.644780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T02:00:00+00:00 TriggerDagRunOperator 2021-05-09T03:11:23.383167+00:00 2021-05-09T03:11:23.929127+00:00 0:00:00.545960 26045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T03:11:20.916036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T02:00:00+00:00 TriggerDagRunOperator 2021-05-09T03:11:23.225822+00:00 2021-05-09T03:11:23.677853+00:00 0:00:00.452031 26044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T03:11:20.915991+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T02:00:00+00:00 EmrJobFlowSensor 2021-05-09T03:00:56.050949+00:00 2021-05-09T03:10:59.013710+00:00 0:10:02.962761 26040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T03:00:53.631608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T03:00:30.186459+00:00 2021-05-09T03:00:32.054668+00:00 0:00:01.868209 26039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T03:00:27.607807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T02:00:00+00:00 PythonOperator 2021-05-09T03:00:08.247314+00:00 2021-05-09T03:00:11.457540+00:00 0:00:03.210226 26038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T03:00:05.598947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T01:00:00+00:00 TriggerDagRunOperator 2021-05-09T02:11:13.649158+00:00 2021-05-09T02:11:14.165823+00:00 0:00:00.516665 26030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T02:11:11.297676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T01:00:00+00:00 TriggerDagRunOperator 2021-05-09T02:11:13.526994+00:00 2021-05-09T02:11:13.946146+00:00 0:00:00.419152 26029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T02:11:11.297640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T01:00:00+00:00 EmrJobFlowSensor 2021-05-09T02:01:51.880469+00:00 2021-05-09T02:10:54.840997+00:00 0:09:02.960528 26025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T02:01:49.547634+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T02:00:33.581301+00:00 2021-05-09T02:00:35.275921+00:00 0:00:01.694620 26024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T02:00:31.438407+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T01:00:00+00:00 PythonOperator 2021-05-09T02:00:11.683483+00:00 2021-05-09T02:00:14.792717+00:00 0:00:03.109234 26023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T02:00:09.353386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T00:00:00+00:00 TriggerDagRunOperator 2021-05-09T01:10:20.496863+00:00 2021-05-09T01:10:21.017900+00:00 0:00:00.521037 26015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T01:10:18.159734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T00:00:00+00:00 TriggerDagRunOperator 2021-05-09T01:10:20.393474+00:00 2021-05-09T01:10:20.798967+00:00 0:00:00.405493 26014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T01:10:18.159699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T00:00:00+00:00 EmrJobFlowSensor 2021-05-09T01:01:03.242642+00:00 2021-05-09T01:10:06.087392+00:00 0:09:02.844750 26010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T01:01:01.040865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T01:00:41.231910+00:00 2021-05-09T01:00:43.066425+00:00 0:00:01.834515 26009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T01:00:38.894024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T00:00:00+00:00 PythonOperator 2021-05-09T01:00:19.681073+00:00 2021-05-09T01:00:22.748757+00:00 0:00:03.067684 26008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T01:00:16.864757+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T23:00:00+00:00 TriggerDagRunOperator 2021-05-09T00:12:10.911892+00:00 2021-05-09T00:12:11.439006+00:00 0:00:00.527114 26000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T00:12:08.444637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T23:00:00+00:00 TriggerDagRunOperator 2021-05-09T00:12:10.667878+00:00 2021-05-09T00:12:11.096665+00:00 0:00:00.428787 25999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T00:12:08.444580+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T23:00:00+00:00 EmrJobFlowSensor 2021-05-09T00:00:56.716889+00:00 2021-05-09T00:11:59.608359+00:00 0:11:02.891470 25995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T00:00:54.608422+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T00:00:36.846469+00:00 2021-05-09T00:00:38.670554+00:00 0:00:01.824085 25994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T00:00:34.587410+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T23:00:00+00:00 PythonOperator 2021-05-09T00:00:13.092383+00:00 2021-05-09T00:00:16.256207+00:00 0:00:03.163824 25993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T00:00:10.577686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T22:00:00+00:00 TriggerDagRunOperator 2021-05-08T23:10:11.583401+00:00 2021-05-08T23:10:12.163927+00:00 0:00:00.580526 25985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:10:09.169629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T22:00:00+00:00 TriggerDagRunOperator 2021-05-08T23:10:11.455366+00:00 2021-05-08T23:10:11.875563+00:00 0:00:00.420197 25984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:10:09.169589+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T22:00:00+00:00 EmrJobFlowSensor 2021-05-08T23:00:50.191338+00:00 2021-05-08T23:09:52.846641+00:00 0:09:02.655303 25979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:00:47.661414+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:00:28.375082+00:00 2021-05-08T23:00:30.061291+00:00 0:00:01.686209 25977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T23:00:25.563000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T22:00:00+00:00 PythonOperator 2021-05-08T23:00:06.016047+00:00 2021-05-08T23:00:09.162547+00:00 0:00:03.146500 25975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T23:00:03.578766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T21:00:00+00:00 TriggerDagRunOperator 2021-05-08T22:22:23.313139+00:00 2021-05-08T22:22:23.752925+00:00 0:00:00.439786 25968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:22:20.461679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T21:00:00+00:00 TriggerDagRunOperator 2021-05-08T22:22:23.323843+00:00 2021-05-08T22:22:23.918953+00:00 0:00:00.595110 25967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:22:20.461633+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T21:00:00+00:00 EmrJobFlowSensor 2021-05-08T22:00:58.078640+00:00 2021-05-08T22:22:02.509657+00:00 0:21:04.431017 25962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:00:55.927653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:00:36.103674+00:00 2021-05-08T22:00:37.805932+00:00 0:00:01.702258 25961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T22:00:33.844214+00:00 2 default_pool