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-07T05:00:00+00:00 PythonOperator 2021-04-07T06:00:22.136366+00:00 2021-04-07T06:00:24.904330+00:00 0:00:02.767964 14463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T06:00:19.943916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T04:00:00+00:00 TriggerDagRunOperator 2021-04-07T05:09:25.373078+00:00 2021-04-07T05:09:25.965227+00:00 0:00:00.592149 14456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:09:22.858225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T04:00:00+00:00 TriggerDagRunOperator 2021-04-07T05:09:25.293550+00:00 2021-04-07T05:09:25.754076+00:00 0:00:00.460526 14455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:09:22.858178+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T04:00:00+00:00 EmrJobFlowSensor 2021-04-07T05:01:00.830257+00:00 2021-04-07T05:09:03.523447+00:00 0:08:02.693190 14450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T05:00:58.269532+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T05:00:38.297702+00:00 2021-04-07T05:00:40.038036+00:00 0:00:01.740334 14449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T05:00:36.062097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T04:00:00+00:00 PythonOperator 2021-04-07T05:00:16.541401+00:00 2021-04-07T05:00:19.336471+00:00 0:00:02.795070 14448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T05:00:14.065589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T03:00:00+00:00 TriggerDagRunOperator 2021-04-07T04:12:56.808488+00:00 2021-04-07T04:12:57.219945+00:00 0:00:00.411457 14441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T04:12:54.529821+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T03:00:00+00:00 TriggerDagRunOperator 2021-04-07T04:12:56.797770+00:00 2021-04-07T04:12:57.328101+00:00 0:00:00.530331 14440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T04:12:54.529785+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T03:00:00+00:00 EmrJobFlowSensor 2021-04-07T04:03:28.350722+00:00 2021-04-07T04:12:31.096640+00:00 0:09:02.745918 14436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T04:03:25.988742+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T04:03:06.114639+00:00 2021-04-07T04:03:07.822804+00:00 0:00:01.708165 14435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T04:03:03.918735+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T03:00:00+00:00 PythonOperator 2021-04-07T04:02:46.224204+00:00 2021-04-07T04:02:48.972487+00:00 0:00:02.748283 14434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T04:02:43.899629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T02:00:00+00:00 TriggerDagRunOperator 2021-04-07T03:11:13.891901+00:00 2021-04-07T03:11:14.420647+00:00 0:00:00.528746 14426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T03:11:11.248065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T02:00:00+00:00 TriggerDagRunOperator 2021-04-07T03:11:13.548785+00:00 2021-04-07T03:11:13.965330+00:00 0:00:00.416545 14425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T03:11:11.248112+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T02:00:00+00:00 EmrJobFlowSensor 2021-04-07T03:00:54.386881+00:00 2021-04-07T03:10:57.296112+00:00 0:10:02.909231 14421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T03:00:52.041205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T03:00:34.435619+00:00 2021-04-07T03:00:36.258462+00:00 0:00:01.822843 14420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T03:00:32.025024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T02:00:00+00:00 PythonOperator 2021-04-07T03:00:12.889991+00:00 2021-04-07T03:00:15.718642+00:00 0:00:02.828651 14419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T03:00:10.066211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T01:00:00+00:00 TriggerDagRunOperator 2021-04-07T02:21:25.535791+00:00 2021-04-07T02:21:25.946149+00:00 0:00:00.410358 14410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T02:21:22.758993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T01:00:00+00:00 TriggerDagRunOperator 2021-04-07T02:21:25.536545+00:00 2021-04-07T02:21:26.102239+00:00 0:00:00.565694 14409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T02:21:22.759035+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T01:00:00+00:00 EmrJobFlowSensor 2021-04-07T02:01:05.504262+00:00 2021-04-07T02:21:09.814001+00:00 0:20:04.309739 14405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T02:01:02.866839+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T02:00:43.244637+00:00 2021-04-07T02:00:44.939789+00:00 0:00:01.695152 14404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T02:00:40.861729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T01:00:00+00:00 PythonOperator 2021-04-07T02:00:23.281330+00:00 2021-04-07T02:00:26.174917+00:00 0:00:02.893587 14403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T02:00:20.751910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T00:00:00+00:00 TriggerDagRunOperator 2021-04-07T01:11:00.841463+00:00 2021-04-07T01:11:01.349191+00:00 0:00:00.507728 14395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:10:57.865665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T00:00:00+00:00 TriggerDagRunOperator 2021-04-07T01:11:00.414675+00:00 2021-04-07T01:11:00.895462+00:00 0:00:00.480787 14394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T01:10:57.865617+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T00:00:00+00:00 EmrJobFlowSensor 2021-04-07T01:00:51.019454+00:00 2021-04-07T01:10:53.954185+00:00 0:10:02.934731 14390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T01:00:48.605201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T01:00:29.026822+00:00 2021-04-07T01:00:30.708903+00:00 0:00:01.682081 14389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T01:00:26.578250+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T00:00:00+00:00 PythonOperator 2021-04-07T01:00:09.146184+00:00 2021-04-07T01:00:11.991896+00:00 0:00:02.845712 14388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T01:00:06.579285+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T23:00:00+00:00 TriggerDagRunOperator 2021-04-07T00:10:24.393230+00:00 2021-04-07T00:10:24.970999+00:00 0:00:00.577769 14380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:10:21.757638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T23:00:00+00:00 TriggerDagRunOperator 2021-04-07T00:10:24.205991+00:00 2021-04-07T00:10:24.718727+00:00 0:00:00.512736 14379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T00:10:21.757667+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T23:00:00+00:00 EmrJobFlowSensor 2021-04-07T00:01:05.264674+00:00 2021-04-07T00:10:07.938612+00:00 0:09:02.673938 14375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T00:01:02.910477+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T00:00:45.129125+00:00 2021-04-07T00:00:46.878677+00:00 0:00:01.749552 14374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T00:00:42.891691+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T23:00:00+00:00 PythonOperator 2021-04-07T00:00:23.263202+00:00 2021-04-07T00:00:26.221567+00:00 0:00:02.958365 14373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T00:00:20.817701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T22:00:00+00:00 TriggerDagRunOperator 2021-04-06T23:10:33.441296+00:00 2021-04-06T23:10:34.004279+00:00 0:00:00.562983 14365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:10:31.016177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T22:00:00+00:00 TriggerDagRunOperator 2021-04-06T23:10:33.278624+00:00 2021-04-06T23:10:33.720065+00:00 0:00:00.441441 14364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T23:10:31.016213+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T22:00:00+00:00 EmrJobFlowSensor 2021-04-06T23:01:06.481665+00:00 2021-04-06T23:10:09.176994+00:00 0:09:02.695329 14360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T23:01:04.195763+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T23:00:46.474989+00:00 2021-04-06T23:00:48.311760+00:00 0:00:01.836771 14359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T23:00:44.153667+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T22:00:00+00:00 PythonOperator 2021-04-06T23:00:25.046294+00:00 2021-04-06T23:00:27.768465+00:00 0:00:02.722171 14358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T23:00:22.132487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T21:00:00+00:00 TriggerDagRunOperator 2021-04-06T22:09:17.759744+00:00 2021-04-06T22:09:18.364132+00:00 0:00:00.604388 14350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:09:15.317947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T21:00:00+00:00 TriggerDagRunOperator 2021-04-06T22:09:17.506103+00:00 2021-04-06T22:09:17.922635+00:00 0:00:00.416532 14349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T22:09:15.317910+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T21:00:00+00:00 EmrJobFlowSensor 2021-04-06T22:01:06.979253+00:00 2021-04-06T22:09:09.567298+00:00 0:08:02.588045 14345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T22:01:04.553060+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T22:00:44.919184+00:00 2021-04-06T22:00:46.724077+00:00 0:00:01.804893 14344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T22:00:42.548679+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T21:00:00+00:00 PythonOperator 2021-04-06T22:00:24.747489+00:00 2021-04-06T22:00:27.542703+00:00 0:00:02.795214 14343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T22:00:22.411275+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T20:00:00+00:00 TriggerDagRunOperator 2021-04-06T21:10:25.927584+00:00 2021-04-06T21:10:26.495444+00:00 0:00:00.567860 14335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:10:23.613054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T20:00:00+00:00 TriggerDagRunOperator 2021-04-06T21:10:25.908191+00:00 2021-04-06T21:10:26.328119+00:00 0:00:00.419928 14334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T21:10:23.613023+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T20:00:00+00:00 EmrJobFlowSensor 2021-04-06T21:01:05.266487+00:00 2021-04-06T21:10:07.903192+00:00 0:09:02.636705 14330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T21:01:02.773883+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T21:00:42.946132+00:00 2021-04-06T21:00:44.749600+00:00 0:00:01.803468 14329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T21:00:40.688721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T20:00:00+00:00 PythonOperator 2021-04-06T21:00:23.135839+00:00 2021-04-06T21:00:26.487466+00:00 0:00:03.351627 14328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T21:00:20.658486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T19:00:00+00:00 TriggerDagRunOperator 2021-04-06T20:10:28.612786+00:00 2021-04-06T20:10:29.131088+00:00 0:00:00.518302 14320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:10:26.071178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T19:00:00+00:00 TriggerDagRunOperator 2021-04-06T20:10:28.413455+00:00 2021-04-06T20:10:28.862405+00:00 0:00:00.448950 14319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T20:10:26.071217+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T19:00:00+00:00 EmrJobFlowSensor 2021-04-06T20:01:07.370937+00:00 2021-04-06T20:10:10.125106+00:00 0:09:02.754169 14315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T20:01:05.167627+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T20:00:43.376481+00:00 2021-04-06T20:00:45.192442+00:00 0:00:01.815961 14314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T20:00:41.105375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T19:00:00+00:00 PythonOperator 2021-04-06T20:00:15.911929+00:00 2021-04-06T20:00:18.640750+00:00 0:00:02.728821 14313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T20:00:13.152395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T18:00:00+00:00 TriggerDagRunOperator 2021-04-06T19:11:19.312315+00:00 2021-04-06T19:11:19.756437+00:00 0:00:00.444122 14305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:11:16.844691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T18:00:00+00:00 TriggerDagRunOperator 2021-04-06T19:11:19.222396+00:00 2021-04-06T19:11:19.779832+00:00 0:00:00.557436 14304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T19:11:16.844720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T18:00:00+00:00 EmrJobFlowSensor 2021-04-06T19:00:56.151334+00:00 2021-04-06T19:10:59.060697+00:00 0:10:02.909363 14300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T19:00:53.883008+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T19:00:36.113845+00:00 2021-04-06T19:00:37.777288+00:00 0:00:01.663443 14299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T19:00:33.857345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T18:00:00+00:00 PythonOperator 2021-04-06T19:00:12.597726+00:00 2021-04-06T19:00:15.488982+00:00 0:00:02.891256 14298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T19:00:09.790649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T17:00:00+00:00 TriggerDagRunOperator 2021-04-06T18:10:26.856097+00:00 2021-04-06T18:10:27.280328+00:00 0:00:00.424231 14290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:10:24.496809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T17:00:00+00:00 TriggerDagRunOperator 2021-04-06T18:10:26.843482+00:00 2021-04-06T18:10:27.372307+00:00 0:00:00.528825 14289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T18:10:24.496781+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T17:00:00+00:00 EmrJobFlowSensor 2021-04-06T18:01:04.054468+00:00 2021-04-06T18:10:06.887176+00:00 0:09:02.832708 14285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T18:01:01.655696+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T18:00:30.089162+00:00 2021-04-06T18:00:31.899599+00:00 0:00:01.810437 14284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T18:00:27.652479+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T17:00:00+00:00 PythonOperator 2021-04-06T18:00:08.400428+00:00 2021-04-06T18:00:11.240143+00:00 0:00:02.839715 14283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T18:00:05.609970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T16:00:00+00:00 TriggerDagRunOperator 2021-04-06T17:09:22.596280+00:00 2021-04-06T17:09:23.124097+00:00 0:00:00.527817 14274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:09:20.229775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T16:00:00+00:00 TriggerDagRunOperator 2021-04-06T17:09:22.449184+00:00 2021-04-06T17:09:22.908696+00:00 0:00:00.459512 14273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T17:09:20.229810+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T16:00:00+00:00 EmrJobFlowSensor 2021-04-06T17:00:55.998810+00:00 2021-04-06T17:08:58.407249+00:00 0:08:02.408439 14269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:00:53.666362+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:00:36.046022+00:00 2021-04-06T17:00:37.869881+00:00 0:00:01.823859 14268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T17:00:33.661745+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T16:00:00+00:00 PythonOperator 2021-04-06T17:00:14.452079+00:00 2021-04-06T17:00:17.330953+00:00 0:00:02.878874 14267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T17:00:11.594035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T15:00:00+00:00 TriggerDagRunOperator 2021-04-06T16:10:18.430264+00:00 2021-04-06T16:10:18.961118+00:00 0:00:00.530854 14259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:10:15.543812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T15:00:00+00:00 TriggerDagRunOperator 2021-04-06T16:10:18.290923+00:00 2021-04-06T16:10:18.698856+00:00 0:00:00.407933 14258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:10:15.543776+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:00:54.820690+00:00 2021-04-06T16:09:57.524526+00:00 0:09:02.703836 14254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:00:52.375248+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:00:34.525273+00:00 2021-04-06T16:00:36.228858+00:00 0:00:01.703585 14253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T16:00:32.284725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:00:12.790476+00:00 2021-04-06T16:00:15.538256+00:00 0:00:02.747780 14252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T16:00:10.220164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T14:00:00+00:00 TriggerDagRunOperator 2021-04-06T15:11:12.741542+00:00 2021-04-06T15:11:13.169844+00:00 0:00:00.428302 14244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:10.216527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T14:00:00+00:00 TriggerDagRunOperator 2021-04-06T15:11:12.438966+00:00 2021-04-06T15:11:12.975269+00:00 0:00:00.536303 14243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:10.216563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:01:03.403842+00:00 2021-04-06T15:11:06.241145+00:00 0:10:02.837303 14239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:01:01.209764+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:00:41.295407+00:00 2021-04-06T15:00:42.973155+00:00 0:00:01.677748 14238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T15:00:39.191796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:00:19.708132+00:00 2021-04-06T15:00:22.419543+00:00 0:00:02.711411 14237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T15:00:17.167560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T13:00:00+00:00 TriggerDagRunOperator 2021-04-06T14:10:21.902817+00:00 2021-04-06T14:10:22.348604+00:00 0:00:00.445787 14229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:10:19.293274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T13:00:00+00:00 TriggerDagRunOperator 2021-04-06T14:10:21.516489+00:00 2021-04-06T14:10:22.081194+00:00 0:00:00.564705 14228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:10:19.293308+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T13:00:00+00:00 EmrJobFlowSensor 2021-04-06T14:01:04.476420+00:00 2021-04-06T14:10:07.215175+00:00 0:09:02.738755 14224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:01:02.182357+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:00:42.376226+00:00 2021-04-06T14:00:44.233770+00:00 0:00:01.857544 14223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T14:00:40.110709+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T13:00:00+00:00 PythonOperator 2021-04-06T14:00:20.629453+00:00 2021-04-06T14:00:23.373684+00:00 0:00:02.744231 14222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T14:00:18.152110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T12:00:00+00:00 TriggerDagRunOperator 2021-04-06T13:10:58.635597+00:00 2021-04-06T13:10:59.105489+00:00 0:00:00.469892 14214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:10:56.217300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T12:00:00+00:00 TriggerDagRunOperator 2021-04-06T13:10:58.606947+00:00 2021-04-06T13:10:59.153463+00:00 0:00:00.546516 14213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:10:56.217351+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T12:00:00+00:00 EmrJobFlowSensor 2021-04-06T13:00:51.353659+00:00 2021-04-06T13:10:54.116046+00:00 0:10:02.762387 14209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:00:49.187214+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:00:31.384569+00:00 2021-04-06T13:00:33.095708+00:00 0:00:01.711139 14208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T13:00:29.173474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T12:00:00+00:00 PythonOperator 2021-04-06T13:00:09.612227+00:00 2021-04-06T13:00:12.404216+00:00 0:00:02.791989 14207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T13:00:07.151790+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T11:00:00+00:00 TriggerDagRunOperator 2021-04-06T12:10:12.246389+00:00 2021-04-06T12:10:12.695707+00:00 0:00:00.449318 14199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:10:09.946545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T11:00:00+00:00 TriggerDagRunOperator 2021-04-06T12:10:12.210780+00:00 2021-04-06T12:10:12.785913+00:00 0:00:00.575133 14198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:10:09.946512+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:00:49.514231+00:00 2021-04-06T12:09:52.177904+00:00 0:09:02.663673 14194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:00:47.051977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:00:29.605969+00:00 2021-04-06T12:00:31.395737+00:00 0:00:01.789768 14193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T12:00:26.954757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:00:05.416338+00:00 2021-04-06T12:00:08.392730+00:00 0:00:02.976392 14192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T12:00:02.868626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T10:00:00+00:00 TriggerDagRunOperator 2021-04-06T11:10:33.352416+00:00 2021-04-06T11:10:33.893248+00:00 0:00:00.540832 14184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:10:30.847204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T10:00:00+00:00 TriggerDagRunOperator 2021-04-06T11:10:33.146857+00:00 2021-04-06T11:10:33.598181+00:00 0:00:00.451324 14183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:10:30.847168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:01:06.163732+00:00 2021-04-06T11:10:08.881531+00:00 0:09:02.717799 14179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:01:03.934967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:00:44.354819+00:00 2021-04-06T11:00:46.106480+00:00 0:00:01.751661 14178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T11:00:41.910941+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T10:00:00+00:00 PythonOperator 2021-04-06T11:00:24.454400+00:00 2021-04-06T11:00:27.285951+00:00 0:00:02.831551 14177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T11:00:21.891723+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T09:00:00+00:00 TriggerDagRunOperator 2021-04-06T10:11:35.246121+00:00 2021-04-06T10:11:35.767321+00:00 0:00:00.521200 14169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:11:32.889712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T09:00:00+00:00 TriggerDagRunOperator 2021-04-06T10:11:35.127424+00:00 2021-04-06T10:11:35.569186+00:00 0:00:00.441762 14168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:11:32.889745+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T09:00:00+00:00 EmrJobFlowSensor 2021-04-06T10:01:06.339987+00:00 2021-04-06T10:11:09.270902+00:00 0:10:02.930915 14164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:01:03.785518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:00:44.278503+00:00 2021-04-06T10:00:46.063086+00:00 0:00:01.784583 14163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T10:00:41.718736+00:00 2 default_pool