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-04-29T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T23:00:26.676220+00:00 2023-04-29T23:00:27.484638+00:00 0:00:00.808418 370223 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T23:00:24.537299+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T22:00:00+00:00 PythonOperator 2023-04-29T23:00:07.109603+00:00 2023-04-29T23:00:07.979197+00:00 0:00:00.869594 370220 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T23:00:04.546850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T21:00:00+00:00 TriggerDagRunOperator 2023-04-29T22:11:24.103784+00:00 2023-04-29T22:11:24.560966+00:00 0:00:00.457182 370208 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T22:11:20.984565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T21:00:00+00:00 TriggerDagRunOperator 2023-04-29T22:11:23.961235+00:00 2023-04-29T22:11:24.326710+00:00 0:00:00.365475 370207 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T22:11:20.984519+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T21:00:00+00:00 EmrJobFlowSensor 2023-04-29T22:01:06.468986+00:00 2023-04-29T22:11:08.320512+00:00 0:10:01.851526 370200 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T22:01:03.887485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T22:00:43.935014+00:00 2023-04-29T22:00:44.848935+00:00 0:00:00.913921 370198 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T22:00:41.721760+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T21:00:00+00:00 PythonOperator 2023-04-29T22:00:23.838750+00:00 2023-04-29T22:00:24.762811+00:00 0:00:00.924061 370196 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T22:00:21.647695+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T20:00:00+00:00 TriggerDagRunOperator 2023-04-29T21:15:25.210049+00:00 2023-04-29T21:15:25.558199+00:00 0:00:00.348150 370183 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T21:15:22.138851+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T20:00:00+00:00 TriggerDagRunOperator 2023-04-29T21:15:25.215025+00:00 2023-04-29T21:15:25.678424+00:00 0:00:00.463399 370182 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T21:15:22.138807+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T20:00:00+00:00 EmrJobFlowSensor 2023-04-29T21:05:15.535920+00:00 2023-04-29T21:15:17.411668+00:00 0:10:01.875748 370177 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T21:05:13.114545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T21:04:55.274085+00:00 2023-04-29T21:04:56.084974+00:00 0:00:00.810889 370174 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T21:04:53.078162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T20:00:00+00:00 PythonOperator 2023-04-29T21:04:33.248522+00:00 2023-04-29T21:04:34.236362+00:00 0:00:00.987840 370172 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T21:04:31.052297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T19:00:00+00:00 TriggerDagRunOperator 2023-04-29T20:12:11.820857+00:00 2023-04-29T20:12:12.281960+00:00 0:00:00.461103 370156 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T20:12:09.085701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T19:00:00+00:00 TriggerDagRunOperator 2023-04-29T20:12:11.780734+00:00 2023-04-29T20:12:12.125668+00:00 0:00:00.344934 370155 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T20:12:09.085658+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T19:00:00+00:00 EmrJobFlowSensor 2023-04-29T20:02:02.817347+00:00 2023-04-29T20:12:04.641873+00:00 0:10:01.824526 370149 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T20:02:00.681182+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T20:01:42.774177+00:00 2023-04-29T20:01:43.555900+00:00 0:00:00.781723 370147 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T20:01:40.660803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T19:00:00+00:00 PythonOperator 2023-04-29T20:01:21.537818+00:00 2023-04-29T20:01:22.386609+00:00 0:00:00.848791 370145 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T20:01:18.645280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T18:00:00+00:00 TriggerDagRunOperator 2023-04-29T19:11:09.576197+00:00 2023-04-29T19:11:09.957044+00:00 0:00:00.380847 370129 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T19:11:07.110556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T18:00:00+00:00 TriggerDagRunOperator 2023-04-29T19:11:09.583264+00:00 2023-04-29T19:11:10.089940+00:00 0:00:00.506676 370128 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T19:11:07.110598+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T18:00:00+00:00 EmrJobFlowSensor 2023-04-29T19:01:01.429273+00:00 2023-04-29T19:11:03.385452+00:00 0:10:01.956179 370122 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T19:00:59.102236+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T19:00:39.448385+00:00 2023-04-29T19:00:40.293706+00:00 0:00:00.845321 370121 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T19:00:37.086123+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T18:00:00+00:00 PythonOperator 2023-04-29T19:00:19.619630+00:00 2023-04-29T19:00:20.470710+00:00 0:00:00.851080 370119 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T19:00:16.993803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T17:00:00+00:00 TriggerDagRunOperator 2023-04-29T18:12:00.381622+00:00 2023-04-29T18:12:00.739160+00:00 0:00:00.357538 370104 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T18:11:57.909453+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T17:00:00+00:00 TriggerDagRunOperator 2023-04-29T18:12:00.387118+00:00 2023-04-29T18:12:00.865868+00:00 0:00:00.478750 370103 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T18:11:57.909507+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T17:00:00+00:00 EmrJobFlowSensor 2023-04-29T18:01:38.667755+00:00 2023-04-29T18:11:40.564460+00:00 0:10:01.896705 370096 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T18:01:36.332984+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T18:01:18.686335+00:00 2023-04-29T18:01:19.596169+00:00 0:00:00.909834 370095 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T18:01:16.305649+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T17:00:00+00:00 PythonOperator 2023-04-29T18:00:56.462617+00:00 2023-04-29T18:00:57.378792+00:00 0:00:00.916175 370094 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T18:00:54.269086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T16:00:00+00:00 TriggerDagRunOperator 2023-04-29T17:12:34.765442+00:00 2023-04-29T17:12:35.259627+00:00 0:00:00.494185 370081 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T17:12:32.104066+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T16:00:00+00:00 TriggerDagRunOperator 2023-04-29T17:12:34.711388+00:00 2023-04-29T17:12:35.073114+00:00 0:00:00.361726 370080 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T17:12:32.104037+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T16:00:00+00:00 EmrJobFlowSensor 2023-04-29T17:00:57.136701+00:00 2023-04-29T17:10:58.936671+00:00 0:10:01.799970 370070 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T17:00:54.970157+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T17:00:35.134623+00:00 2023-04-29T17:00:35.909757+00:00 0:00:00.775134 370069 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T17:00:32.948858+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T16:00:00+00:00 PythonOperator 2023-04-29T17:00:15.681269+00:00 2023-04-29T17:00:16.568886+00:00 0:00:00.887617 370068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T17:00:12.932002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T15:00:00+00:00 TriggerDagRunOperator 2023-04-29T16:13:06.557224+00:00 2023-04-29T16:13:06.945828+00:00 0:00:00.388604 370055 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T16:13:03.858724+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T15:00:00+00:00 TriggerDagRunOperator 2023-04-29T16:13:06.550100+00:00 2023-04-29T16:13:07.028693+00:00 0:00:00.478593 370054 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T16:13:03.858686+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T15:00:00+00:00 EmrJobFlowSensor 2023-04-29T16:01:05.840722+00:00 2023-04-29T16:11:07.766768+00:00 0:10:01.926046 370050 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T16:01:03.514196+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T16:00:43.967623+00:00 2023-04-29T16:00:44.831419+00:00 0:00:00.863796 370048 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T16:00:41.580417+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T15:00:00+00:00 PythonOperator 2023-04-29T16:00:23.654317+00:00 2023-04-29T16:00:24.619372+00:00 0:00:00.965055 370046 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T16:00:21.416756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T14:00:00+00:00 TriggerDagRunOperator 2023-04-29T15:23:55.947178+00:00 2023-04-29T15:23:56.350160+00:00 0:00:00.402982 370034 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T15:23:53.086920+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T14:00:00+00:00 TriggerDagRunOperator 2023-04-29T15:23:55.932804+00:00 2023-04-29T15:23:56.396210+00:00 0:00:00.463406 370033 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T15:23:53.086878+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T14:00:00+00:00 EmrJobFlowSensor 2023-04-29T15:06:52.893898+00:00 2023-04-29T15:17:55.250535+00:00 0:11:02.356637 370028 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T15:06:50.401038+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T15:06:30.821689+00:00 2023-04-29T15:06:31.702573+00:00 0:00:00.880884 370025 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T15:06:28.323267+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T14:00:00+00:00 PythonOperator 2023-04-29T15:06:11.047596+00:00 2023-04-29T15:06:12.088585+00:00 0:00:01.040989 370022 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T15:06:08.306064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T13:00:00+00:00 TriggerDagRunOperator 2023-04-29T14:11:15.675398+00:00 2023-04-29T14:11:16.125269+00:00 0:00:00.449871 370010 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T14:11:13.182314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T13:00:00+00:00 TriggerDagRunOperator 2023-04-29T14:11:15.575221+00:00 2023-04-29T14:11:15.915605+00:00 0:00:00.340384 370009 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T14:11:13.182345+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T13:00:00+00:00 EmrJobFlowSensor 2023-04-29T14:00:59.155834+00:00 2023-04-29T14:11:01.095796+00:00 0:10:01.939962 370002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T14:00:56.902392+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T14:00:39.159831+00:00 2023-04-29T14:00:40.053589+00:00 0:00:00.893758 370000 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T14:00:36.850380+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T13:00:00+00:00 PythonOperator 2023-04-29T14:00:17.400618+00:00 2023-04-29T14:00:18.323055+00:00 0:00:00.922437 369998 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T14:00:14.830730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T12:00:00+00:00 TriggerDagRunOperator 2023-04-29T13:09:56.100706+00:00 2023-04-29T13:09:56.566962+00:00 0:00:00.466256 369985 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T13:09:53.509682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T12:00:00+00:00 TriggerDagRunOperator 2023-04-29T13:09:56.034272+00:00 2023-04-29T13:09:56.384600+00:00 0:00:00.350328 369984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T13:09:53.509751+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T12:00:00+00:00 EmrJobFlowSensor 2023-04-29T13:00:50.934319+00:00 2023-04-29T13:09:52.701915+00:00 0:09:01.767596 369977 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T13:00:48.486822+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T13:00:30.943024+00:00 2023-04-29T13:00:31.905576+00:00 0:00:00.962552 369975 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T13:00:28.482577+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T12:00:00+00:00 PythonOperator 2023-04-29T13:00:09.201520+00:00 2023-04-29T13:00:10.067459+00:00 0:00:00.865939 369974 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T13:00:06.400055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T11:00:00+00:00 TriggerDagRunOperator 2023-04-29T12:25:42.156136+00:00 2023-04-29T12:25:42.617394+00:00 0:00:00.461258 369964 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T12:25:39.352835+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T11:00:00+00:00 TriggerDagRunOperator 2023-04-29T12:25:42.063890+00:00 2023-04-29T12:25:42.405250+00:00 0:00:00.341360 369963 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T12:25:39.352807+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T11:00:00+00:00 EmrJobFlowSensor 2023-04-29T12:14:23.754614+00:00 2023-04-29T12:25:25.793482+00:00 0:11:02.038868 369958 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T12:14:21.562791+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T12:14:02.074233+00:00 2023-04-29T12:14:02.996843+00:00 0:00:00.922610 369955 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T12:13:59.543393+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T11:00:00+00:00 PythonOperator 2023-04-29T12:13:42.315610+00:00 2023-04-29T12:13:43.264239+00:00 0:00:00.948629 369952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T12:13:39.329050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T10:00:00+00:00 TriggerDagRunOperator 2023-04-29T11:11:14.774507+00:00 2023-04-29T11:11:15.261547+00:00 0:00:00.487040 369939 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T11:11:12.306928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T10:00:00+00:00 TriggerDagRunOperator 2023-04-29T11:11:14.647341+00:00 2023-04-29T11:11:15.014172+00:00 0:00:00.366831 369938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T11:11:12.306956+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T10:00:00+00:00 EmrJobFlowSensor 2023-04-29T11:01:07.758620+00:00 2023-04-29T11:11:09.670910+00:00 0:10:01.912290 369931 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T11:01:05.492110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T11:00:45.793781+00:00 2023-04-29T11:00:46.681584+00:00 0:00:00.887803 369929 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T11:00:43.417462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T10:00:00+00:00 PythonOperator 2023-04-29T11:00:25.656723+00:00 2023-04-29T11:00:27.093936+00:00 0:00:01.437213 369927 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T11:00:23.356126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T09:00:00+00:00 TriggerDagRunOperator 2023-04-29T10:29:10.154861+00:00 2023-04-29T10:29:10.542111+00:00 0:00:00.387250 369915 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T10:29:07.195783+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T09:00:00+00:00 TriggerDagRunOperator 2023-04-29T10:29:10.117396+00:00 2023-04-29T10:29:10.655255+00:00 0:00:00.537859 369914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T10:29:07.195827+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T09:00:00+00:00 EmrJobFlowSensor 2023-04-29T10:18:47.724671+00:00 2023-04-29T10:28:49.444203+00:00 0:10:01.719532 369910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T10:18:45.570456+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T10:18:28.444033+00:00 2023-04-29T10:18:29.431961+00:00 0:00:00.987928 369907 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T10:18:25.595514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T09:00:00+00:00 PythonOperator 2023-04-29T10:18:05.924129+00:00 2023-04-29T10:18:06.799183+00:00 0:00:00.875054 369904 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T10:18:03.625106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T08:00:00+00:00 TriggerDagRunOperator 2023-04-29T09:13:47.917793+00:00 2023-04-29T09:13:48.370758+00:00 0:00:00.452965 369892 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T09:13:45.722889+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T08:00:00+00:00 TriggerDagRunOperator 2023-04-29T09:13:47.830975+00:00 2023-04-29T09:13:48.178146+00:00 0:00:00.347171 369891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T09:13:45.722923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T08:00:00+00:00 EmrJobFlowSensor 2023-04-29T09:00:55.052178+00:00 2023-04-29T09:10:57.035353+00:00 0:10:01.983175 369884 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T09:00:52.601528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T09:00:32.990345+00:00 2023-04-29T09:00:33.804760+00:00 0:00:00.814415 369882 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T09:00:30.606012+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T08:00:00+00:00 PythonOperator 2023-04-29T09:00:13.225050+00:00 2023-04-29T09:00:14.162193+00:00 0:00:00.937143 369880 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T09:00:10.593130+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T07:00:00+00:00 TriggerDagRunOperator 2023-04-29T08:22:13.113647+00:00 2023-04-29T08:22:13.569149+00:00 0:00:00.455502 369869 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T08:22:10.135384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T07:00:00+00:00 TriggerDagRunOperator 2023-04-29T08:22:13.049846+00:00 2023-04-29T08:22:13.408592+00:00 0:00:00.358746 369868 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T08:22:10.135355+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T07:00:00+00:00 EmrJobFlowSensor 2023-04-29T08:11:49.645643+00:00 2023-04-29T08:21:51.402747+00:00 0:10:01.757104 369864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T08:11:47.506372+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T08:11:27.585579+00:00 2023-04-29T08:11:28.366643+00:00 0:00:00.781064 369861 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T08:11:25.460857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T07:00:00+00:00 PythonOperator 2023-04-29T08:11:07.758995+00:00 2023-04-29T08:11:08.724216+00:00 0:00:00.965221 369858 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T08:11:05.442287+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T06:00:00+00:00 TriggerDagRunOperator 2023-04-29T07:43:47.015461+00:00 2023-04-29T07:43:47.483693+00:00 0:00:00.468232 369848 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T07:43:44.482227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T06:00:00+00:00 TriggerDagRunOperator 2023-04-29T07:43:46.933053+00:00 2023-04-29T07:43:47.296540+00:00 0:00:00.363487 369847 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T07:43:44.482198+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T06:00:00+00:00 EmrJobFlowSensor 2023-04-29T07:08:45.503539+00:00 2023-04-29T07:18:47.402356+00:00 0:10:01.898817 369842 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T07:08:43.241882+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T07:08:23.422194+00:00 2023-04-29T07:08:24.299629+00:00 0:00:00.877435 369839 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T07:08:21.216963+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T06:00:00+00:00 PythonOperator 2023-04-29T07:08:03.914002+00:00 2023-04-29T07:08:04.788309+00:00 0:00:00.874307 369836 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T07:08:01.198548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T05:00:00+00:00 TriggerDagRunOperator 2023-04-29T06:11:12.221414+00:00 2023-04-29T06:11:12.685036+00:00 0:00:00.463622 369825 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T06:11:09.951073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T05:00:00+00:00 TriggerDagRunOperator 2023-04-29T06:11:12.171229+00:00 2023-04-29T06:11:12.533884+00:00 0:00:00.362655 369824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T06:11:09.951108+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T05:00:00+00:00 EmrJobFlowSensor 2023-04-29T06:00:54.689299+00:00 2023-04-29T06:10:56.519789+00:00 0:10:01.830490 369818 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T06:00:52.515134+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T06:00:34.874741+00:00 2023-04-29T06:00:35.630840+00:00 0:00:00.756099 369816 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T06:00:32.501487+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T05:00:00+00:00 PythonOperator 2023-04-29T06:00:12.573266+00:00 2023-04-29T06:00:13.426773+00:00 0:00:00.853507 369814 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T06:00:10.419324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T04:00:00+00:00 TriggerDagRunOperator 2023-04-29T05:17:19.059076+00:00 2023-04-29T05:17:19.502094+00:00 0:00:00.443018 369802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T05:17:16.370158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T04:00:00+00:00 TriggerDagRunOperator 2023-04-29T05:17:18.937298+00:00 2023-04-29T05:17:19.336926+00:00 0:00:00.399628 369801 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T05:17:16.370188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T04:00:00+00:00 EmrJobFlowSensor 2023-04-29T05:00:55.871714+00:00 2023-04-29T05:11:57.739839+00:00 0:11:01.868125 369794 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T05:00:53.147691+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T05:00:35.439630+00:00 2023-04-29T05:00:36.343291+00:00 0:00:00.903661 369792 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T05:00:33.125715+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T04:00:00+00:00 PythonOperator 2023-04-29T05:00:13.312190+00:00 2023-04-29T05:00:14.229536+00:00 0:00:00.917346 369790 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T05:00:11.109265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T03:00:00+00:00 TriggerDagRunOperator 2023-04-29T04:18:56.906366+00:00 2023-04-29T04:18:57.683601+00:00 0:00:00.777235 369778 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T04:18:53.514277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T03:00:00+00:00 TriggerDagRunOperator 2023-04-29T04:18:56.417542+00:00 2023-04-29T04:18:56.758493+00:00 0:00:00.340951 369777 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T04:18:53.514310+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T03:00:00+00:00 EmrJobFlowSensor 2023-04-29T04:00:52.868606+00:00 2023-04-29T04:10:54.837517+00:00 0:10:01.968911 369772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T04:00:50.596826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T04:00:30.776545+00:00 2023-04-29T04:00:31.618690+00:00 0:00:00.842145 369770 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T04:00:28.489295+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T03:00:00+00:00 PythonOperator 2023-04-29T04:00:10.840140+00:00 2023-04-29T04:00:11.786889+00:00 0:00:00.946749 369768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T04:00:08.486340+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T02:00:00+00:00 TriggerDagRunOperator 2023-04-29T03:11:06.613292+00:00 2023-04-29T03:11:07.034757+00:00 0:00:00.421465 369755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T03:11:04.100261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T02:00:00+00:00 TriggerDagRunOperator 2023-04-29T03:11:06.454660+00:00 2023-04-29T03:11:06.799592+00:00 0:00:00.344932 369754 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T03:11:04.100218+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T02:00:00+00:00 EmrJobFlowSensor 2023-04-29T03:00:48.822053+00:00 2023-04-29T03:10:50.681603+00:00 0:10:01.859550 369747 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T03:00:45.906549+00:00 2 default_pool