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_cluster_and_add_emr_steps 2023-05-09T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T03:00:28.881092+00:00 2023-05-09T03:00:29.792176+00:00 0:00:00.911084 375737 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T03:00:26.507636+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T02:00:00+00:00 PythonOperator 2023-05-09T03:00:09.251272+00:00 2023-05-09T03:00:10.292434+00:00 0:00:01.041162 375735 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T03:00:06.503298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T01:00:00+00:00 TriggerDagRunOperator 2023-05-09T02:10:59.868964+00:00 2023-05-09T02:11:00.499208+00:00 0:00:00.630244 375722 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T02:10:57.080619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T01:00:00+00:00 TriggerDagRunOperator 2023-05-09T02:10:59.670507+00:00 2023-05-09T02:11:00.281508+00:00 0:00:00.611001 375721 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T02:10:57.080589+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T01:00:00+00:00 EmrJobFlowSensor 2023-05-09T02:00:51.224078+00:00 2023-05-09T02:10:53.131336+00:00 0:10:01.907258 375714 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T02:00:49.149283+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T02:00:29.317014+00:00 2023-05-09T02:00:30.154523+00:00 0:00:00.837509 375712 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T02:00:27.135618+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T01:00:00+00:00 PythonOperator 2023-05-09T02:00:07.917174+00:00 2023-05-09T02:00:08.914903+00:00 0:00:00.997729 375710 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T02:00:05.186029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T00:00:00+00:00 TriggerDagRunOperator 2023-05-09T01:11:08.847668+00:00 2023-05-09T01:11:09.361162+00:00 0:00:00.513494 375690 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T01:11:06.214930+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T00:00:00+00:00 TriggerDagRunOperator 2023-05-09T01:11:08.692676+00:00 2023-05-09T01:11:09.133010+00:00 0:00:00.440334 375689 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T01:11:06.214961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T00:00:00+00:00 EmrJobFlowSensor 2023-05-09T01:00:57.819036+00:00 2023-05-09T01:10:59.645771+00:00 0:10:01.826735 375682 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T01:00:55.748832+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T01:00:36.372975+00:00 2023-05-09T01:00:37.254342+00:00 0:00:00.881367 375680 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T01:00:33.886116+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T00:00:00+00:00 PythonOperator 2023-05-09T01:00:13.878762+00:00 2023-05-09T01:00:14.860342+00:00 0:00:00.981580 375678 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T01:00:11.711781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T23:00:00+00:00 TriggerDagRunOperator 2023-05-09T00:11:03.799434+00:00 2023-05-09T00:11:04.410851+00:00 0:00:00.611417 375664 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T00:11:00.225619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T23:00:00+00:00 TriggerDagRunOperator 2023-05-09T00:11:02.949199+00:00 2023-05-09T00:11:03.286897+00:00 0:00:00.337698 375663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T00:11:00.225651+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T23:00:00+00:00 EmrJobFlowSensor 2023-05-09T00:00:49.068887+00:00 2023-05-09T00:10:51.039042+00:00 0:10:01.970155 375655 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T00:00:46.666971+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T00:00:26.851477+00:00 2023-05-09T00:00:27.836813+00:00 0:00:00.985336 375653 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T00:00:24.582507+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T23:00:00+00:00 PythonOperator 2023-05-09T00:00:05.374057+00:00 2023-05-09T00:00:06.383727+00:00 0:00:01.009670 375651 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T00:00:02.596358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T22:00:00+00:00 TriggerDagRunOperator 2023-05-08T23:11:16.074659+00:00 2023-05-08T23:11:16.539463+00:00 0:00:00.464804 375635 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T23:11:13.410109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T22:00:00+00:00 TriggerDagRunOperator 2023-05-08T23:11:16.010571+00:00 2023-05-08T23:11:16.341735+00:00 0:00:00.331164 375634 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T23:11:13.410066+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T22:00:00+00:00 EmrJobFlowSensor 2023-05-08T23:01:06.101506+00:00 2023-05-08T23:11:07.847225+00:00 0:10:01.745719 375627 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T23:01:03.904454+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T23:00:46.079287+00:00 2023-05-08T23:00:46.830956+00:00 0:00:00.751669 375624 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T23:00:43.862138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T22:00:00+00:00 PythonOperator 2023-05-08T23:00:24.102730+00:00 2023-05-08T23:00:25.111914+00:00 0:00:01.009184 375621 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T23:00:21.844456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T21:00:00+00:00 TriggerDagRunOperator 2023-05-08T22:11:18.231838+00:00 2023-05-08T22:11:18.649544+00:00 0:00:00.417706 375606 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T22:11:15.829116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T21:00:00+00:00 TriggerDagRunOperator 2023-05-08T22:11:18.208011+00:00 2023-05-08T22:11:18.724940+00:00 0:00:00.516929 375605 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T22:11:15.829160+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T21:00:00+00:00 EmrJobFlowSensor 2023-05-08T22:01:01.165848+00:00 2023-05-08T22:11:03.061541+00:00 0:10:01.895693 375598 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T22:00:58.922491+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T22:00:39.152865+00:00 2023-05-08T22:00:39.994996+00:00 0:00:00.842131 375595 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T22:00:36.902610+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T21:00:00+00:00 PythonOperator 2023-05-08T22:00:19.406637+00:00 2023-05-08T22:00:20.424844+00:00 0:00:01.018207 375594 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T22:00:16.881840+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T20:00:00+00:00 TriggerDagRunOperator 2023-05-08T21:11:29.446808+00:00 2023-05-08T21:11:30.129212+00:00 0:00:00.682404 375580 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T21:11:26.715708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T20:00:00+00:00 TriggerDagRunOperator 2023-05-08T21:11:29.342677+00:00 2023-05-08T21:11:29.692610+00:00 0:00:00.349933 375579 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T21:11:26.715753+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T20:00:00+00:00 EmrJobFlowSensor 2023-05-08T21:01:04.022642+00:00 2023-05-08T21:11:05.926909+00:00 0:10:01.904267 375571 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T21:01:01.594921+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T21:00:41.750646+00:00 2023-05-08T21:00:42.595977+00:00 0:00:00.845331 375569 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T21:00:39.522416+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T20:00:00+00:00 PythonOperator 2023-05-08T21:00:20.136451+00:00 2023-05-08T21:00:21.092741+00:00 0:00:00.956290 375567 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T21:00:17.446260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T19:00:00+00:00 TriggerDagRunOperator 2023-05-08T20:11:08.315658+00:00 2023-05-08T20:11:08.935378+00:00 0:00:00.619720 375553 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T20:11:05.613519+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T19:00:00+00:00 TriggerDagRunOperator 2023-05-08T20:11:08.276786+00:00 2023-05-08T20:11:08.760251+00:00 0:00:00.483465 375552 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T20:11:05.613476+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T19:00:00+00:00 EmrJobFlowSensor 2023-05-08T20:01:01.933062+00:00 2023-05-08T20:11:03.815923+00:00 0:10:01.882861 375545 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T20:00:59.738351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T20:00:41.948770+00:00 2023-05-08T20:00:42.833080+00:00 0:00:00.884310 375543 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T20:00:39.709878+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T19:00:00+00:00 PythonOperator 2023-05-08T20:00:20.161546+00:00 2023-05-08T20:00:21.145599+00:00 0:00:00.984053 375541 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T20:00:17.696482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T18:00:00+00:00 TriggerDagRunOperator 2023-05-08T19:11:05.345518+00:00 2023-05-08T19:11:05.791158+00:00 0:00:00.445640 375523 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T19:11:02.811694+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T18:00:00+00:00 TriggerDagRunOperator 2023-05-08T19:11:05.246792+00:00 2023-05-08T19:11:05.587821+00:00 0:00:00.341029 375522 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T19:11:02.811738+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T18:00:00+00:00 EmrJobFlowSensor 2023-05-08T19:00:55.919069+00:00 2023-05-08T19:10:57.791919+00:00 0:10:01.872850 375514 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T19:00:53.772550+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T19:00:35.932141+00:00 2023-05-08T19:00:36.741775+00:00 0:00:00.809634 375513 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T19:00:33.752568+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T18:00:00+00:00 PythonOperator 2023-05-08T19:00:14.220731+00:00 2023-05-08T19:00:15.248662+00:00 0:00:01.027931 375512 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T19:00:11.733077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T17:00:00+00:00 TriggerDagRunOperator 2023-05-08T18:11:23.239531+00:00 2023-05-08T18:11:23.695492+00:00 0:00:00.455961 375495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T18:11:20.926334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T17:00:00+00:00 TriggerDagRunOperator 2023-05-08T18:11:23.077925+00:00 2023-05-08T18:11:23.434901+00:00 0:00:00.356976 375494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T18:11:20.926305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T17:00:00+00:00 EmrJobFlowSensor 2023-05-08T18:01:07.562100+00:00 2023-05-08T18:11:09.480531+00:00 0:10:01.918431 375486 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T18:01:05.205507+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T18:00:45.451672+00:00 2023-05-08T18:00:46.308081+00:00 0:00:00.856409 375485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T18:00:43.124588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T17:00:00+00:00 PythonOperator 2023-05-08T18:00:25.318112+00:00 2023-05-08T18:00:26.353793+00:00 0:00:01.035681 375484 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T18:00:23.106639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T16:00:00+00:00 TriggerDagRunOperator 2023-05-08T17:11:22.624024+00:00 2023-05-08T17:11:23.000348+00:00 0:00:00.376324 375469 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T17:11:20.029168+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T16:00:00+00:00 TriggerDagRunOperator 2023-05-08T17:11:22.534912+00:00 2023-05-08T17:11:23.009539+00:00 0:00:00.474627 375468 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T17:11:20.029196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T16:00:00+00:00 EmrJobFlowSensor 2023-05-08T17:01:02.873285+00:00 2023-05-08T17:11:04.686809+00:00 0:10:01.813524 375458 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T17:01:00.736571+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T17:00:40.932353+00:00 2023-05-08T17:00:41.786909+00:00 0:00:00.854556 375457 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T17:00:38.715097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T16:00:00+00:00 PythonOperator 2023-05-08T17:00:18.890142+00:00 2023-05-08T17:00:19.970173+00:00 0:00:01.080031 375456 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T17:00:16.693683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T15:00:00+00:00 TriggerDagRunOperator 2023-05-08T16:11:22.154402+00:00 2023-05-08T16:11:22.538029+00:00 0:00:00.383627 375442 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T16:11:19.875329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T15:00:00+00:00 TriggerDagRunOperator 2023-05-08T16:11:22.155409+00:00 2023-05-08T16:11:22.654664+00:00 0:00:00.499255 375441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T16:11:19.875361+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T15:00:00+00:00 EmrJobFlowSensor 2023-05-08T16:00:58.412835+00:00 2023-05-08T16:11:00.420409+00:00 0:10:02.007574 375435 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T16:00:56.098194+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T16:00:36.559858+00:00 2023-05-08T16:00:37.691074+00:00 0:00:01.131216 375433 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T16:00:34.089802+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T15:00:00+00:00 PythonOperator 2023-05-08T16:00:16.474595+00:00 2023-05-08T16:00:17.583209+00:00 0:00:01.108614 375431 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T16:00:14.014154+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T14:00:00+00:00 TriggerDagRunOperator 2023-05-08T15:11:28.369330+00:00 2023-05-08T15:11:29.063414+00:00 0:00:00.694084 375417 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T15:11:24.790781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T14:00:00+00:00 TriggerDagRunOperator 2023-05-08T15:11:27.725124+00:00 2023-05-08T15:11:28.051965+00:00 0:00:00.326841 375416 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T15:11:24.790819+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T14:00:00+00:00 EmrJobFlowSensor 2023-05-08T15:01:06.755675+00:00 2023-05-08T15:11:08.968673+00:00 0:10:02.212998 375410 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T15:01:04.405284+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T15:00:44.680210+00:00 2023-05-08T15:00:45.588019+00:00 0:00:00.907809 375408 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T15:00:42.392146+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T14:00:00+00:00 PythonOperator 2023-05-08T15:00:24.490977+00:00 2023-05-08T15:00:25.514959+00:00 0:00:01.023982 375406 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T15:00:22.318187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T13:00:00+00:00 TriggerDagRunOperator 2023-05-08T14:11:29.046199+00:00 2023-05-08T14:11:29.497250+00:00 0:00:00.451051 375391 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T14:11:25.134972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T13:00:00+00:00 TriggerDagRunOperator 2023-05-08T14:11:27.457816+00:00 2023-05-08T14:11:27.815167+00:00 0:00:00.357351 375390 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T14:11:25.135008+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T13:00:00+00:00 EmrJobFlowSensor 2023-05-08T14:00:54.408508+00:00 2023-05-08T14:10:56.363869+00:00 0:10:01.955361 375386 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T14:00:52.107345+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T14:00:32.418796+00:00 2023-05-08T14:00:33.281280+00:00 0:00:00.862484 375383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T14:00:30.191683+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T13:00:00+00:00 PythonOperator 2023-05-08T14:00:10.655672+00:00 2023-05-08T14:00:11.720970+00:00 0:00:01.065298 375382 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T14:00:08.054180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T12:00:00+00:00 TriggerDagRunOperator 2023-05-08T13:11:05.850256+00:00 2023-05-08T13:11:06.316018+00:00 0:00:00.465762 375369 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T13:11:03.383078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T12:00:00+00:00 TriggerDagRunOperator 2023-05-08T13:11:05.773283+00:00 2023-05-08T13:11:06.112407+00:00 0:00:00.339124 375368 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T13:11:03.383036+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T12:00:00+00:00 EmrJobFlowSensor 2023-05-08T13:00:49.713929+00:00 2023-05-08T13:10:51.533363+00:00 0:10:01.819434 375361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T13:00:47.389763+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T13:00:27.635535+00:00 2023-05-08T13:00:28.419983+00:00 0:00:00.784448 375359 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T13:00:25.281191+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T12:00:00+00:00 PythonOperator 2023-05-08T13:00:05.672672+00:00 2023-05-08T13:00:06.717497+00:00 0:00:01.044825 375357 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T13:00:03.205281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T11:00:00+00:00 TriggerDagRunOperator 2023-05-08T12:11:20.346131+00:00 2023-05-08T12:11:20.773508+00:00 0:00:00.427377 375342 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T12:11:17.135023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T11:00:00+00:00 TriggerDagRunOperator 2023-05-08T12:11:19.584375+00:00 2023-05-08T12:11:19.921868+00:00 0:00:00.337493 375341 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T12:11:17.135057+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T11:00:00+00:00 EmrJobFlowSensor 2023-05-08T12:00:59.638511+00:00 2023-05-08T12:11:01.761718+00:00 0:10:02.123207 375336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T12:00:57.195652+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T12:00:35.452610+00:00 2023-05-08T12:00:36.354908+00:00 0:00:00.902298 375334 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T12:00:33.034842+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T11:00:00+00:00 PythonOperator 2023-05-08T12:00:14.016948+00:00 2023-05-08T12:00:15.203733+00:00 0:00:01.186785 375332 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T12:00:10.986310+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T10:00:00+00:00 TriggerDagRunOperator 2023-05-08T11:22:23.085085+00:00 2023-05-08T11:22:23.540706+00:00 0:00:00.455621 375321 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T11:22:20.129304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T10:00:00+00:00 TriggerDagRunOperator 2023-05-08T11:22:22.986022+00:00 2023-05-08T11:22:23.335180+00:00 0:00:00.349158 375320 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T11:22:20.129270+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T10:00:00+00:00 EmrJobFlowSensor 2023-05-08T11:01:03.725752+00:00 2023-05-08T11:11:05.707244+00:00 0:10:01.981492 375313 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T11:01:01.329696+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T11:00:43.576260+00:00 2023-05-08T11:00:44.529741+00:00 0:00:00.953481 375311 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T11:00:41.310949+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T10:00:00+00:00 PythonOperator 2023-05-08T11:00:21.488837+00:00 2023-05-08T11:00:22.515398+00:00 0:00:01.026561 375309 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T11:00:19.251665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T09:00:00+00:00 TriggerDagRunOperator 2023-05-08T10:11:35.625765+00:00 2023-05-08T10:11:36.115066+00:00 0:00:00.489301 375296 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T10:11:32.997028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T09:00:00+00:00 TriggerDagRunOperator 2023-05-08T10:11:35.426952+00:00 2023-05-08T10:11:35.770731+00:00 0:00:00.343779 375295 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T10:11:32.997056+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T09:00:00+00:00 EmrJobFlowSensor 2023-05-08T10:00:52.340991+00:00 2023-05-08T10:10:54.160069+00:00 0:10:01.819078 375288 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T10:00:50.108847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T10:00:30.477149+00:00 2023-05-08T10:00:31.350161+00:00 0:00:00.873012 375286 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T10:00:28.083420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T09:00:00+00:00 PythonOperator 2023-05-08T10:00:10.361309+00:00 2023-05-08T10:00:11.310206+00:00 0:00:00.948897 375284 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T10:00:08.013596+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T08:00:00+00:00 TriggerDagRunOperator 2023-05-08T09:11:07.962699+00:00 2023-05-08T09:11:08.320032+00:00 0:00:00.357333 375269 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T09:11:05.697637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T08:00:00+00:00 TriggerDagRunOperator 2023-05-08T09:11:07.968652+00:00 2023-05-08T09:11:08.454628+00:00 0:00:00.485976 375268 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T09:11:05.697606+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T08:00:00+00:00 EmrJobFlowSensor 2023-05-08T09:00:47.592452+00:00 2023-05-08T09:10:49.537243+00:00 0:10:01.944791 375261 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T09:00:45.225807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T09:00:27.472031+00:00 2023-05-08T09:00:28.348003+00:00 0:00:00.875972 375259 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T09:00:25.204583+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T08:00:00+00:00 PythonOperator 2023-05-08T09:00:05.754780+00:00 2023-05-08T09:00:06.746485+00:00 0:00:00.991705 375257 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T09:00:03.119408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T07:00:00+00:00 TriggerDagRunOperator 2023-05-08T08:20:56.992700+00:00 2023-05-08T08:20:57.590447+00:00 0:00:00.597747 375245 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T08:20:54.000238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T07:00:00+00:00 TriggerDagRunOperator 2023-05-08T08:20:56.852565+00:00 2023-05-08T08:20:57.229288+00:00 0:00:00.376723 375244 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T08:20:54.000276+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T07:00:00+00:00 EmrJobFlowSensor 2023-05-08T08:01:13.563127+00:00 2023-05-08T08:10:15.387466+00:00 0:09:01.824339 375237 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T08:01:11.041088+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-08T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-08T08:00:26.938440+00:00 2023-05-08T08:00:27.912754+00:00 0:00:00.974314 375234 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-08T08:00:24.653082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-08T07:00:00+00:00 PythonOperator 2023-05-08T08:00:05.334347+00:00 2023-05-08T08:00:06.398725+00:00 0:00:01.064378 375232 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-08T08:00:02.633143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-08T06:00:00+00:00 TriggerDagRunOperator 2023-05-08T07:11:03.617440+00:00 2023-05-08T07:11:04.073593+00:00 0:00:00.456153 375219 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T07:11:00.912216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-08T06:00:00+00:00 TriggerDagRunOperator 2023-05-08T07:11:03.395254+00:00 2023-05-08T07:11:03.786849+00:00 0:00:00.391595 375218 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-08T07:11:00.912270+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-08T06:00:00+00:00 EmrJobFlowSensor 2023-05-08T07:00:56.863211+00:00 2023-05-08T07:10:58.825339+00:00 0:10:01.962128 375211 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-08T07:00:54.546997+00:00 2 default_pool