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-24T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T23:00:31.833304+00:00 2023-05-24T23:00:32.826744+00:00 0:00:00.993440 385303 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T23:00:29.560894+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T22:00:00+00:00 PythonOperator 2023-05-24T23:00:10.371236+00:00 2023-05-24T23:00:11.374004+00:00 0:00:01.002768 385300 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T23:00:07.539609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T21:00:00+00:00 TriggerDagRunOperator 2023-05-24T22:11:17.030335+00:00 2023-05-24T22:11:17.509960+00:00 0:00:00.479625 385290 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T22:11:14.514751+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T21:00:00+00:00 TriggerDagRunOperator 2023-05-24T22:11:16.998276+00:00 2023-05-24T22:11:17.468908+00:00 0:00:00.470632 385289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T22:11:14.514722+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T21:00:00+00:00 EmrJobFlowSensor 2023-05-24T22:00:51.020795+00:00 2023-05-24T22:10:53.325550+00:00 0:10:02.304755 385281 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T22:00:48.686468+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T22:00:29.037548+00:00 2023-05-24T22:00:30.370824+00:00 0:00:01.333276 385279 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T22:00:26.665934+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T21:00:00+00:00 PythonOperator 2023-05-24T22:00:09.091944+00:00 2023-05-24T22:00:10.271877+00:00 0:00:01.179933 385277 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T22:00:06.656111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T20:00:00+00:00 TriggerDagRunOperator 2023-05-24T21:11:19.930095+00:00 2023-05-24T21:11:20.444875+00:00 0:00:00.514780 385267 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T21:11:17.411745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T20:00:00+00:00 TriggerDagRunOperator 2023-05-24T21:11:19.899312+00:00 2023-05-24T21:11:20.357423+00:00 0:00:00.458111 385266 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T21:11:17.411718+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T20:00:00+00:00 EmrJobFlowSensor 2023-05-24T21:00:54.380802+00:00 2023-05-24T21:10:56.337863+00:00 0:10:01.957061 385258 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T21:00:52.024531+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T21:00:32.162300+00:00 2023-05-24T21:00:33.165884+00:00 0:00:01.003584 385256 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T21:00:29.955471+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T20:00:00+00:00 PythonOperator 2023-05-24T21:00:12.532859+00:00 2023-05-24T21:00:13.709179+00:00 0:00:01.176320 385254 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T21:00:09.926679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T19:00:00+00:00 TriggerDagRunOperator 2023-05-24T20:11:06.704617+00:00 2023-05-24T20:11:07.174815+00:00 0:00:00.470198 385244 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T20:11:04.003695+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T19:00:00+00:00 TriggerDagRunOperator 2023-05-24T20:11:06.647279+00:00 2023-05-24T20:11:07.135049+00:00 0:00:00.487770 385243 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T20:11:04.003666+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T19:00:00+00:00 EmrJobFlowSensor 2023-05-24T20:00:47.740104+00:00 2023-05-24T20:10:49.668051+00:00 0:10:01.927947 385235 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T20:00:45.285546+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T20:00:25.636142+00:00 2023-05-24T20:00:26.475074+00:00 0:00:00.838932 385233 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T20:00:23.110932+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T19:00:00+00:00 PythonOperator 2023-05-24T20:00:05.901920+00:00 2023-05-24T20:00:07.054190+00:00 0:00:01.152270 385231 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T20:00:02.805819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T18:00:00+00:00 TriggerDagRunOperator 2023-05-24T19:11:15.684770+00:00 2023-05-24T19:11:16.149886+00:00 0:00:00.465116 385219 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T19:11:13.210366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T18:00:00+00:00 TriggerDagRunOperator 2023-05-24T19:11:15.680981+00:00 2023-05-24T19:11:16.151592+00:00 0:00:00.470611 385218 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T19:11:13.210323+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T18:00:00+00:00 EmrJobFlowSensor 2023-05-24T19:00:54.488066+00:00 2023-05-24T19:10:56.524203+00:00 0:10:02.036137 385210 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T19:00:52.175063+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T19:00:32.513606+00:00 2023-05-24T19:00:33.546436+00:00 0:00:01.032830 385209 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T19:00:30.152401+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T18:00:00+00:00 PythonOperator 2023-05-24T19:00:12.787228+00:00 2023-05-24T19:00:13.975616+00:00 0:00:01.188388 385207 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T19:00:10.129999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T17:00:00+00:00 TriggerDagRunOperator 2023-05-24T18:11:10.287623+00:00 2023-05-24T18:11:10.781605+00:00 0:00:00.493982 385195 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T18:11:07.707664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T17:00:00+00:00 TriggerDagRunOperator 2023-05-24T18:11:10.291700+00:00 2023-05-24T18:11:10.743985+00:00 0:00:00.452285 385194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T18:11:07.707636+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T17:00:00+00:00 EmrJobFlowSensor 2023-05-24T18:01:02.943301+00:00 2023-05-24T18:11:04.989242+00:00 0:10:02.045941 385186 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T18:01:00.609182+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T18:00:42.891383+00:00 2023-05-24T18:00:43.841479+00:00 0:00:00.950096 385185 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T18:00:40.593524+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T17:00:00+00:00 PythonOperator 2023-05-24T18:00:17.462298+00:00 2023-05-24T18:00:18.666869+00:00 0:00:01.204571 385183 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T18:00:14.582590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T16:00:00+00:00 TriggerDagRunOperator 2023-05-24T17:11:10.462071+00:00 2023-05-24T17:11:10.972306+00:00 0:00:00.510235 385173 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T17:11:08.137067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T16:00:00+00:00 TriggerDagRunOperator 2023-05-24T17:11:10.418068+00:00 2023-05-24T17:11:10.913055+00:00 0:00:00.494987 385172 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T17:11:08.137038+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T16:00:00+00:00 EmrJobFlowSensor 2023-05-24T17:00:57.544980+00:00 2023-05-24T17:10:59.541692+00:00 0:10:01.996712 385163 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T17:00:55.308218+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T17:00:35.569763+00:00 2023-05-24T17:00:36.483141+00:00 0:00:00.913378 385162 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T17:00:33.248580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T16:00:00+00:00 PythonOperator 2023-05-24T17:00:15.515812+00:00 2023-05-24T17:00:16.696331+00:00 0:00:01.180519 385161 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T17:00:13.231666+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T15:00:00+00:00 TriggerDagRunOperator 2023-05-24T16:16:34.145993+00:00 2023-05-24T16:16:34.636273+00:00 0:00:00.490280 385150 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T16:16:31.393647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T15:00:00+00:00 TriggerDagRunOperator 2023-05-24T16:16:34.088919+00:00 2023-05-24T16:16:34.595662+00:00 0:00:00.506743 385149 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T16:16:31.393692+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T15:00:00+00:00 EmrJobFlowSensor 2023-05-24T16:06:09.144654+00:00 2023-05-24T16:16:11.300141+00:00 0:10:02.155487 385146 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T16:06:06.706173+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T16:05:46.972299+00:00 2023-05-24T16:05:48.149914+00:00 0:00:01.177615 385143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T16:05:44.675760+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T15:00:00+00:00 PythonOperator 2023-05-24T16:05:26.938842+00:00 2023-05-24T16:05:28.132328+00:00 0:00:01.193486 385140 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T16:05:24.657791+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T14:00:00+00:00 TriggerDagRunOperator 2023-05-24T15:11:10.565034+00:00 2023-05-24T15:11:11.055374+00:00 0:00:00.490340 385127 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T15:11:07.913506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T14:00:00+00:00 TriggerDagRunOperator 2023-05-24T15:11:10.517040+00:00 2023-05-24T15:11:10.975112+00:00 0:00:00.458072 385126 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T15:11:07.913479+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T14:00:00+00:00 EmrJobFlowSensor 2023-05-24T15:00:49.426950+00:00 2023-05-24T15:10:51.444500+00:00 0:10:02.017550 385119 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T15:00:46.795605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T15:00:27.040027+00:00 2023-05-24T15:00:28.093123+00:00 0:00:01.053096 385117 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T15:00:24.726255+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T14:00:00+00:00 PythonOperator 2023-05-24T15:00:07.045580+00:00 2023-05-24T15:00:08.086618+00:00 0:00:01.041038 385115 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T15:00:04.651884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T13:00:00+00:00 TriggerDagRunOperator 2023-05-24T14:11:11.748064+00:00 2023-05-24T14:11:12.207696+00:00 0:00:00.459632 385107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T14:11:09.087620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T13:00:00+00:00 TriggerDagRunOperator 2023-05-24T14:11:11.645390+00:00 2023-05-24T14:11:12.084830+00:00 0:00:00.439440 385106 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T14:11:09.087649+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T13:00:00+00:00 EmrJobFlowSensor 2023-05-24T14:00:55.803910+00:00 2023-05-24T14:10:57.953866+00:00 0:10:02.149956 385099 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T14:00:53.531218+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T14:00:33.752875+00:00 2023-05-24T14:00:34.836435+00:00 0:00:01.083560 385097 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T14:00:31.512637+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T13:00:00+00:00 PythonOperator 2023-05-24T14:00:12.346075+00:00 2023-05-24T14:00:13.544968+00:00 0:00:01.198893 385095 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T14:00:09.492530+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T12:00:00+00:00 TriggerDagRunOperator 2023-05-24T13:12:21.252715+00:00 2023-05-24T13:12:21.727828+00:00 0:00:00.475113 385086 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T13:12:18.755938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T12:00:00+00:00 TriggerDagRunOperator 2023-05-24T13:12:21.141736+00:00 2023-05-24T13:12:21.591505+00:00 0:00:00.449769 385085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T13:12:18.755909+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T12:00:00+00:00 EmrJobFlowSensor 2023-05-24T13:01:56.499557+00:00 2023-05-24T13:11:58.456999+00:00 0:10:01.957442 385078 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T13:01:53.911242+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T13:01:36.324878+00:00 2023-05-24T13:01:37.329435+00:00 0:00:01.004557 385076 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T13:01:33.880255+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T12:00:00+00:00 PythonOperator 2023-05-24T13:01:14.646086+00:00 2023-05-24T13:01:15.817218+00:00 0:00:01.171132 385074 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T13:01:11.888089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T11:00:00+00:00 TriggerDagRunOperator 2023-05-24T12:14:57.296104+00:00 2023-05-24T12:14:57.766992+00:00 0:00:00.470888 385068 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T12:14:54.340681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T11:00:00+00:00 TriggerDagRunOperator 2023-05-24T12:14:57.274334+00:00 2023-05-24T12:14:57.737878+00:00 0:00:00.463544 385067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T12:14:54.340726+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T11:00:00+00:00 EmrJobFlowSensor 2023-05-24T12:02:14.264962+00:00 2023-05-24T12:12:16.187485+00:00 0:10:01.922523 385060 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T12:02:11.988726+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T12:01:54.849697+00:00 2023-05-24T12:01:55.810689+00:00 0:00:00.960992 385058 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T12:01:51.984828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T11:00:00+00:00 PythonOperator 2023-05-24T12:00:16.167877+00:00 2023-05-24T12:00:17.174404+00:00 0:00:01.006527 385055 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T12:00:13.813867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T10:00:00+00:00 TriggerDagRunOperator 2023-05-24T11:11:10.339177+00:00 2023-05-24T11:11:10.803763+00:00 0:00:00.464586 385044 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T11:11:07.704417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T10:00:00+00:00 TriggerDagRunOperator 2023-05-24T11:11:10.035530+00:00 2023-05-24T11:11:10.516500+00:00 0:00:00.480970 385043 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T11:11:07.704386+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T10:00:00+00:00 EmrJobFlowSensor 2023-05-24T11:00:55.536792+00:00 2023-05-24T11:10:57.441385+00:00 0:10:01.904593 385038 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T11:00:53.115892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T11:00:33.404565+00:00 2023-05-24T11:00:34.414532+00:00 0:00:01.009967 385036 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T11:00:31.096281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T10:00:00+00:00 PythonOperator 2023-05-24T11:00:13.617683+00:00 2023-05-24T11:00:14.597852+00:00 0:00:00.980169 385034 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T11:00:11.053416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T09:00:00+00:00 TriggerDagRunOperator 2023-05-24T10:11:23.582813+00:00 2023-05-24T10:11:24.153746+00:00 0:00:00.570933 385026 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T10:11:21.022267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T09:00:00+00:00 TriggerDagRunOperator 2023-05-24T10:11:23.292212+00:00 2023-05-24T10:11:23.768863+00:00 0:00:00.476651 385025 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T10:11:21.022233+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T09:00:00+00:00 EmrJobFlowSensor 2023-05-24T10:01:06.814694+00:00 2023-05-24T10:11:08.706915+00:00 0:10:01.892221 385019 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T10:01:04.485053+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T10:00:44.678673+00:00 2023-05-24T10:00:45.643541+00:00 0:00:00.964868 385017 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T10:00:42.405824+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T09:00:00+00:00 PythonOperator 2023-05-24T10:00:24.665581+00:00 2023-05-24T10:00:25.706007+00:00 0:00:01.040426 385015 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T10:00:22.380324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T08:00:00+00:00 TriggerDagRunOperator 2023-05-24T09:20:30.493772+00:00 2023-05-24T09:20:31.018480+00:00 0:00:00.524708 385005 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T09:20:27.670582+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T08:00:00+00:00 TriggerDagRunOperator 2023-05-24T09:20:30.250988+00:00 2023-05-24T09:20:30.708036+00:00 0:00:00.457048 385004 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T09:20:27.670619+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T08:00:00+00:00 EmrJobFlowSensor 2023-05-24T09:07:19.383487+00:00 2023-05-24T09:17:21.589363+00:00 0:10:02.205876 385000 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T09:07:14.805139+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T09:06:57.184659+00:00 2023-05-24T09:06:58.301249+00:00 0:00:01.116590 384997 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T09:06:52.750236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T08:00:00+00:00 PythonOperator 2023-05-24T09:06:34.064564+00:00 2023-05-24T09:06:36.101940+00:00 0:00:02.037376 384994 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T09:06:30.734317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T07:00:00+00:00 TriggerDagRunOperator 2023-05-24T08:11:07.741313+00:00 2023-05-24T08:11:08.176933+00:00 0:00:00.435620 384984 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T08:11:04.782485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T07:00:00+00:00 TriggerDagRunOperator 2023-05-24T08:11:07.527335+00:00 2023-05-24T08:11:07.995441+00:00 0:00:00.468106 384983 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T08:11:04.782531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T07:00:00+00:00 EmrJobFlowSensor 2023-05-24T08:00:49.348891+00:00 2023-05-24T08:10:51.267315+00:00 0:10:01.918424 384977 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T08:00:47.020267+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T08:00:27.296004+00:00 2023-05-24T08:00:28.201746+00:00 0:00:00.905742 384974 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T08:00:25.001937+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T07:00:00+00:00 PythonOperator 2023-05-24T08:00:07.973296+00:00 2023-05-24T08:00:09.087685+00:00 0:00:01.114389 384973 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T08:00:04.980528+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T06:00:00+00:00 TriggerDagRunOperator 2023-05-24T07:10:57.649680+00:00 2023-05-24T07:10:58.152844+00:00 0:00:00.503164 384962 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T07:10:55.089924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T06:00:00+00:00 TriggerDagRunOperator 2023-05-24T07:10:57.643441+00:00 2023-05-24T07:10:58.094219+00:00 0:00:00.450778 384961 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T07:10:55.089954+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T06:00:00+00:00 EmrJobFlowSensor 2023-05-24T07:00:50.366550+00:00 2023-05-24T07:10:52.311497+00:00 0:10:01.944947 384954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T07:00:48.009357+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T07:00:28.250218+00:00 2023-05-24T07:00:29.208118+00:00 0:00:00.957900 384952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T07:00:25.942201+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T06:00:00+00:00 PythonOperator 2023-05-24T07:00:08.417291+00:00 2023-05-24T07:00:09.689258+00:00 0:00:01.271967 384950 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T07:00:05.925240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T05:00:00+00:00 TriggerDagRunOperator 2023-05-24T06:12:33.540509+00:00 2023-05-24T06:12:34.017942+00:00 0:00:00.477433 384940 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T06:12:31.078067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T05:00:00+00:00 TriggerDagRunOperator 2023-05-24T06:12:33.466683+00:00 2023-05-24T06:12:34.011614+00:00 0:00:00.544931 384939 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T06:12:31.078096+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T05:00:00+00:00 EmrJobFlowSensor 2023-05-24T06:01:16.135528+00:00 2023-05-24T06:12:18.245495+00:00 0:11:02.109967 384932 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T06:01:13.241053+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T06:00:32.516333+00:00 2023-05-24T06:00:33.459488+00:00 0:00:00.943155 384930 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T06:00:30.212366+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T05:00:00+00:00 PythonOperator 2023-05-24T06:00:10.326636+00:00 2023-05-24T06:00:11.518757+00:00 0:00:01.192121 384928 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T06:00:08.107880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T04:00:00+00:00 TriggerDagRunOperator 2023-05-24T05:11:07.605273+00:00 2023-05-24T05:11:08.095691+00:00 0:00:00.490418 384918 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T05:11:04.787911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T04:00:00+00:00 TriggerDagRunOperator 2023-05-24T05:11:07.335639+00:00 2023-05-24T05:11:07.786604+00:00 0:00:00.450965 384917 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T05:11:04.787964+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T04:00:00+00:00 EmrJobFlowSensor 2023-05-24T05:00:58.916685+00:00 2023-05-24T05:11:00.863172+00:00 0:10:01.946487 384910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T05:00:56.588371+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T05:00:37.239390+00:00 2023-05-24T05:00:38.213795+00:00 0:00:00.974405 384908 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T05:00:34.708064+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T04:00:00+00:00 PythonOperator 2023-05-24T05:00:15.610141+00:00 2023-05-24T05:00:16.794758+00:00 0:00:01.184617 384906 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T05:00:12.518372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T03:00:00+00:00 TriggerDagRunOperator 2023-05-24T04:11:17.747593+00:00 2023-05-24T04:11:18.207549+00:00 0:00:00.459956 384897 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T04:11:15.229643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T03:00:00+00:00 TriggerDagRunOperator 2023-05-24T04:11:17.689001+00:00 2023-05-24T04:11:18.253162+00:00 0:00:00.564161 384896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T04:11:15.229615+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T03:00:00+00:00 EmrJobFlowSensor 2023-05-24T04:01:05.850643+00:00 2023-05-24T04:11:07.825919+00:00 0:10:01.975276 384890 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T04:01:03.382585+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-24T04:00:43.607222+00:00 2023-05-24T04:00:44.616983+00:00 0:00:01.009761 384888 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-24T04:00:41.222957+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T03:00:00+00:00 PythonOperator 2023-05-24T04:00:23.462322+00:00 2023-05-24T04:00:24.647297+00:00 0:00:01.184975 384886 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-24T04:00:21.205507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T02:00:00+00:00 TriggerDagRunOperator 2023-05-24T03:11:12.741995+00:00 2023-05-24T03:11:13.198181+00:00 0:00:00.456186 384874 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T03:11:10.157093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T02:00:00+00:00 TriggerDagRunOperator 2023-05-24T03:11:12.715785+00:00 2023-05-24T03:11:13.178306+00:00 0:00:00.462521 384873 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T03:11:10.157051+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T02:00:00+00:00 EmrJobFlowSensor 2023-05-24T03:01:00.757911+00:00 2023-05-24T03:11:02.823020+00:00 0:10:02.065109 384866 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T03:00:58.417353+00:00 2 default_pool