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-09T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T23:00:44.286495+00:00 2023-05-09T23:00:45.247957+00:00 0:00:00.961462 376245 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T23:00:42.106316+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T22:00:00+00:00 PythonOperator 2023-05-09T23:00:24.180989+00:00 2023-05-09T23:00:25.155144+00:00 0:00:00.974155 376243 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T23:00:22.029196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T21:00:00+00:00 TriggerDagRunOperator 2023-05-09T22:11:09.134509+00:00 2023-05-09T22:11:09.596651+00:00 0:00:00.462142 376226 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T22:11:06.813074+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T21:00:00+00:00 TriggerDagRunOperator 2023-05-09T22:11:09.109490+00:00 2023-05-09T22:11:09.450069+00:00 0:00:00.340579 376225 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T22:11:06.813107+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T21:00:00+00:00 EmrJobFlowSensor 2023-05-09T22:00:55.185930+00:00 2023-05-09T22:10:57.042070+00:00 0:10:01.856140 376219 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T22:00:52.085520+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T22:00:32.364383+00:00 2023-05-09T22:00:33.295263+00:00 0:00:00.930880 376217 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T22:00:30.118236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T21:00:00+00:00 PythonOperator 2023-05-09T22:00:12.870537+00:00 2023-05-09T22:00:13.902541+00:00 0:00:01.032004 376215 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T22:00:09.998020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T20:00:00+00:00 TriggerDagRunOperator 2023-05-09T21:11:18.207071+00:00 2023-05-09T21:11:18.664063+00:00 0:00:00.456992 376199 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T21:11:15.409817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T20:00:00+00:00 TriggerDagRunOperator 2023-05-09T21:11:17.709228+00:00 2023-05-09T21:11:18.158864+00:00 0:00:00.449636 376198 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T21:11:15.409786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T20:00:00+00:00 EmrJobFlowSensor 2023-05-09T21:01:00.841566+00:00 2023-05-09T21:11:02.782199+00:00 0:10:01.940633 376191 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T21:00:58.384231+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T21:00:38.803901+00:00 2023-05-09T21:00:39.778913+00:00 0:00:00.975012 376189 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T21:00:36.295526+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T20:00:00+00:00 PythonOperator 2023-05-09T21:00:18.801746+00:00 2023-05-09T21:00:20.885496+00:00 0:00:02.083750 376187 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T21:00:16.293260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T19:00:00+00:00 TriggerDagRunOperator 2023-05-09T20:11:17.370335+00:00 2023-05-09T20:11:17.734133+00:00 0:00:00.363798 376173 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T20:11:14.791232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T19:00:00+00:00 TriggerDagRunOperator 2023-05-09T20:11:17.219226+00:00 2023-05-09T20:11:17.691758+00:00 0:00:00.472532 376172 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T20:11:14.791265+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T19:00:00+00:00 EmrJobFlowSensor 2023-05-09T20:00:56.580454+00:00 2023-05-09T20:10:58.700377+00:00 0:10:02.119923 376166 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T20:00:54.217471+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T20:00:36.329717+00:00 2023-05-09T20:00:37.092794+00:00 0:00:00.763077 376164 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T20:00:34.172057+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T19:00:00+00:00 PythonOperator 2023-05-09T20:00:14.458178+00:00 2023-05-09T20:00:15.534846+00:00 0:00:01.076668 376162 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T20:00:12.153482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T18:00:00+00:00 TriggerDagRunOperator 2023-05-09T19:11:20.329951+00:00 2023-05-09T19:11:20.678273+00:00 0:00:00.348322 376145 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T19:11:17.801152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T18:00:00+00:00 TriggerDagRunOperator 2023-05-09T19:11:20.307376+00:00 2023-05-09T19:11:20.763436+00:00 0:00:00.456060 376144 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T19:11:17.801100+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T18:00:00+00:00 EmrJobFlowSensor 2023-05-09T19:01:04.254845+00:00 2023-05-09T19:11:05.983408+00:00 0:10:01.728563 376137 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T19:01:01.895399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T19:00:42.152170+00:00 2023-05-09T19:00:43.069052+00:00 0:00:00.916882 376136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T19:00:39.804031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T18:00:00+00:00 PythonOperator 2023-05-09T19:00:21.921397+00:00 2023-05-09T19:00:22.919994+00:00 0:00:00.998597 376135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T19:00:19.780726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T17:00:00+00:00 TriggerDagRunOperator 2023-05-09T18:11:01.308997+00:00 2023-05-09T18:11:01.651592+00:00 0:00:00.342595 376118 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T18:10:59.008955+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T17:00:00+00:00 TriggerDagRunOperator 2023-05-09T18:11:01.322574+00:00 2023-05-09T18:11:01.792764+00:00 0:00:00.470190 376117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T18:10:59.008986+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T17:00:00+00:00 EmrJobFlowSensor 2023-05-09T18:00:53.298752+00:00 2023-05-09T18:10:55.507496+00:00 0:10:02.208744 376110 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T18:00:50.599550+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T18:00:32.804490+00:00 2023-05-09T18:00:33.604372+00:00 0:00:00.799882 376109 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T18:00:30.515991+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T17:00:00+00:00 PythonOperator 2023-05-09T18:00:10.657548+00:00 2023-05-09T18:00:11.616733+00:00 0:00:00.959185 376108 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T18:00:08.470827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T16:00:00+00:00 TriggerDagRunOperator 2023-05-09T17:11:08.819755+00:00 2023-05-09T17:11:09.248070+00:00 0:00:00.428315 376093 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T17:11:06.284886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T16:00:00+00:00 TriggerDagRunOperator 2023-05-09T17:11:08.720579+00:00 2023-05-09T17:11:09.095273+00:00 0:00:00.374694 376092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T17:11:06.284833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T16:00:00+00:00 EmrJobFlowSensor 2023-05-09T17:00:57.311401+00:00 2023-05-09T17:10:59.149584+00:00 0:10:01.838183 376083 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T17:00:55.093689+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T17:00:35.340936+00:00 2023-05-09T17:00:36.172319+00:00 0:00:00.831383 376082 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T17:00:33.008183+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T16:00:00+00:00 PythonOperator 2023-05-09T17:00:15.178939+00:00 2023-05-09T17:00:16.257834+00:00 0:00:01.078895 376081 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T17:00:12.969320+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T15:00:00+00:00 TriggerDagRunOperator 2023-05-09T16:20:17.415515+00:00 2023-05-09T16:20:17.845093+00:00 0:00:00.429578 376068 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T16:20:14.802034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T15:00:00+00:00 TriggerDagRunOperator 2023-05-09T16:20:17.309288+00:00 2023-05-09T16:20:17.650653+00:00 0:00:00.341365 376067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T16:20:14.802005+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T15:00:00+00:00 EmrJobFlowSensor 2023-05-09T16:08:04.469284+00:00 2023-05-09T16:18:06.707274+00:00 0:10:02.237990 376063 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T16:08:02.242790+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T16:07:45.350432+00:00 2023-05-09T16:07:46.365293+00:00 0:00:01.014861 376061 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T16:07:42.283828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T15:00:00+00:00 PythonOperator 2023-05-09T16:07:22.913528+00:00 2023-05-09T16:07:23.967059+00:00 0:00:01.053531 376057 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T16:07:20.203440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T14:00:00+00:00 TriggerDagRunOperator 2023-05-09T15:11:13.327340+00:00 2023-05-09T15:11:13.778280+00:00 0:00:00.450940 376044 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T15:11:11.013323+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T14:00:00+00:00 TriggerDagRunOperator 2023-05-09T15:11:13.215229+00:00 2023-05-09T15:11:13.577714+00:00 0:00:00.362485 376043 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T15:11:11.013293+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T14:00:00+00:00 EmrJobFlowSensor 2023-05-09T15:01:00.781724+00:00 2023-05-09T15:11:02.685235+00:00 0:10:01.903511 376036 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T15:00:58.330152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T15:00:38.752934+00:00 2023-05-09T15:00:40.013357+00:00 0:00:01.260423 376034 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T15:00:36.381152+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T14:00:00+00:00 PythonOperator 2023-05-09T15:00:18.960832+00:00 2023-05-09T15:00:20.000029+00:00 0:00:01.039197 376032 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T15:00:15.988745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T13:00:00+00:00 TriggerDagRunOperator 2023-05-09T14:15:57.321526+00:00 2023-05-09T14:15:57.680583+00:00 0:00:00.359057 376018 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T14:15:54.598847+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T13:00:00+00:00 TriggerDagRunOperator 2023-05-09T14:15:57.317520+00:00 2023-05-09T14:15:57.778311+00:00 0:00:00.460791 376017 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T14:15:54.598818+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T13:00:00+00:00 EmrJobFlowSensor 2023-05-09T14:00:49.951165+00:00 2023-05-09T14:10:52.102305+00:00 0:10:02.151140 376013 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T14:00:47.606191+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T14:00:30.113416+00:00 2023-05-09T14:00:30.960467+00:00 0:00:00.847051 376011 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T14:00:27.600793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T13:00:00+00:00 PythonOperator 2023-05-09T14:00:09.864402+00:00 2023-05-09T14:00:11.892485+00:00 0:00:02.028083 376009 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T14:00:05.597979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T12:00:00+00:00 TriggerDagRunOperator 2023-05-09T13:15:30.362367+00:00 2023-05-09T13:15:30.796046+00:00 0:00:00.433679 375998 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T13:15:27.155247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T12:00:00+00:00 TriggerDagRunOperator 2023-05-09T13:15:30.301098+00:00 2023-05-09T13:15:30.750280+00:00 0:00:00.449182 375997 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T13:15:27.155279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T12:00:00+00:00 EmrJobFlowSensor 2023-05-09T13:01:29.053400+00:00 2023-05-09T13:11:30.969116+00:00 0:10:01.915716 375990 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T13:01:26.821080+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T13:01:07.482965+00:00 2023-05-09T13:01:08.428020+00:00 0:00:00.945055 375988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T13:01:04.854234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T12:00:00+00:00 PythonOperator 2023-05-09T13:00:18.779978+00:00 2023-05-09T13:00:19.827252+00:00 0:00:01.047274 375986 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T13:00:16.620853+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T11:00:00+00:00 TriggerDagRunOperator 2023-05-09T12:14:50.390663+00:00 2023-05-09T12:14:50.872591+00:00 0:00:00.481928 375975 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T12:14:47.660681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T11:00:00+00:00 TriggerDagRunOperator 2023-05-09T12:14:50.339551+00:00 2023-05-09T12:14:50.694882+00:00 0:00:00.355331 375974 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T12:14:47.660708+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T11:00:00+00:00 EmrJobFlowSensor 2023-05-09T12:02:15.252752+00:00 2023-05-09T12:12:17.201786+00:00 0:10:01.949034 375967 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T12:02:12.814798+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T12:01:55.215152+00:00 2023-05-09T12:01:56.180913+00:00 0:00:00.965761 375965 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T12:01:52.773534+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T11:00:00+00:00 PythonOperator 2023-05-09T12:01:33.475757+00:00 2023-05-09T12:01:34.484468+00:00 0:00:01.008711 375963 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T12:01:30.760098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T10:00:00+00:00 TriggerDagRunOperator 2023-05-09T11:19:24.279622+00:00 2023-05-09T11:19:24.697458+00:00 0:00:00.417836 375953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T11:19:20.906883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T10:00:00+00:00 TriggerDagRunOperator 2023-05-09T11:19:23.790106+00:00 2023-05-09T11:19:24.247632+00:00 0:00:00.457526 375952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T11:19:20.906927+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T10:00:00+00:00 EmrJobFlowSensor 2023-05-09T11:09:00.303952+00:00 2023-05-09T11:19:02.285539+00:00 0:10:01.981587 375948 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T11:08:57.578229+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T11:08:39.344074+00:00 2023-05-09T11:08:40.474096+00:00 0:00:01.130022 375944 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T11:08:35.556856+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T10:00:00+00:00 PythonOperator 2023-05-09T11:08:18.369069+00:00 2023-05-09T11:08:19.449947+00:00 0:00:01.080878 375942 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T11:08:15.408724+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T09:00:00+00:00 TriggerDagRunOperator 2023-05-09T10:11:57.021682+00:00 2023-05-09T10:11:57.529206+00:00 0:00:00.507524 375928 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T10:11:54.583593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T09:00:00+00:00 TriggerDagRunOperator 2023-05-09T10:11:56.905176+00:00 2023-05-09T10:11:57.230977+00:00 0:00:00.325801 375927 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T10:11:54.583563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T09:00:00+00:00 EmrJobFlowSensor 2023-05-09T10:00:48.936509+00:00 2023-05-09T10:11:50.989928+00:00 0:11:02.053419 375920 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T10:00:46.385432+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T10:00:28.823540+00:00 2023-05-09T10:00:30.030926+00:00 0:00:01.207386 375918 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T10:00:26.311023+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T09:00:00+00:00 PythonOperator 2023-05-09T10:00:06.750823+00:00 2023-05-09T10:00:07.740379+00:00 0:00:00.989556 375915 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T10:00:04.230167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T08:00:00+00:00 TriggerDagRunOperator 2023-05-09T09:11:10.722530+00:00 2023-05-09T09:11:11.170720+00:00 0:00:00.448190 375903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T09:11:08.318306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T08:00:00+00:00 TriggerDagRunOperator 2023-05-09T09:11:10.624535+00:00 2023-05-09T09:11:10.953283+00:00 0:00:00.328748 375902 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T09:11:08.318271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T08:00:00+00:00 EmrJobFlowSensor 2023-05-09T09:00:54.038998+00:00 2023-05-09T09:10:55.801636+00:00 0:10:01.762638 375895 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T09:00:51.845845+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T09:00:32.062374+00:00 2023-05-09T09:00:32.842779+00:00 0:00:00.780405 375893 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T09:00:29.902358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T08:00:00+00:00 PythonOperator 2023-05-09T09:00:12.289280+00:00 2023-05-09T09:00:14.154851+00:00 0:00:01.865571 375891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T09:00:09.807598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T07:00:00+00:00 TriggerDagRunOperator 2023-05-09T08:12:12.788238+00:00 2023-05-09T08:12:13.223828+00:00 0:00:00.435590 375878 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T08:12:09.714251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T07:00:00+00:00 TriggerDagRunOperator 2023-05-09T08:12:12.625468+00:00 2023-05-09T08:12:12.960200+00:00 0:00:00.334732 375877 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T08:12:09.714196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T07:00:00+00:00 EmrJobFlowSensor 2023-05-09T08:00:58.865799+00:00 2023-05-09T08:12:00.852033+00:00 0:11:01.986234 375869 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T08:00:55.900860+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T08:00:38.193081+00:00 2023-05-09T08:00:38.996260+00:00 0:00:00.803179 375867 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T08:00:35.891551+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T07:00:00+00:00 PythonOperator 2023-05-09T08:00:17.225003+00:00 2023-05-09T08:00:19.188774+00:00 0:00:01.963771 375865 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T08:00:13.882529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T06:00:00+00:00 TriggerDagRunOperator 2023-05-09T07:11:38.819602+00:00 2023-05-09T07:11:39.295781+00:00 0:00:00.476179 375852 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T07:11:36.192709+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T06:00:00+00:00 TriggerDagRunOperator 2023-05-09T07:11:38.701038+00:00 2023-05-09T07:11:39.092785+00:00 0:00:00.391747 375851 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T07:11:36.192738+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T06:00:00+00:00 EmrJobFlowSensor 2023-05-09T07:01:06.892830+00:00 2023-05-09T07:11:08.766281+00:00 0:10:01.873451 375844 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T07:01:04.483817+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T07:00:44.572063+00:00 2023-05-09T07:00:45.386518+00:00 0:00:00.814455 375842 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T07:00:42.386097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T06:00:00+00:00 PythonOperator 2023-05-09T07:00:24.590709+00:00 2023-05-09T07:00:25.566936+00:00 0:00:00.976227 375840 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T07:00:22.339039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T05:00:00+00:00 TriggerDagRunOperator 2023-05-09T06:12:22.737959+00:00 2023-05-09T06:12:23.175036+00:00 0:00:00.437077 375826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T06:12:20.250363+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T05:00:00+00:00 TriggerDagRunOperator 2023-05-09T06:12:22.619860+00:00 2023-05-09T06:12:22.951706+00:00 0:00:00.331846 375825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T06:12:20.250391+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T05:00:00+00:00 EmrJobFlowSensor 2023-05-09T06:00:55.742344+00:00 2023-05-09T06:11:57.894980+00:00 0:11:02.152636 375818 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T06:00:53.307170+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T06:00:35.639341+00:00 2023-05-09T06:00:36.416681+00:00 0:00:00.777340 375816 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T06:00:33.293617+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T05:00:00+00:00 PythonOperator 2023-05-09T06:00:13.565411+00:00 2023-05-09T06:00:14.570519+00:00 0:00:01.005108 375814 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T06:00:11.212214+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T04:00:00+00:00 TriggerDagRunOperator 2023-05-09T05:13:28.763800+00:00 2023-05-09T05:13:29.212080+00:00 0:00:00.448280 375802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T05:13:25.836480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T04:00:00+00:00 TriggerDagRunOperator 2023-05-09T05:13:28.604115+00:00 2023-05-09T05:13:28.988046+00:00 0:00:00.383931 375801 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T05:13:25.836533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T04:00:00+00:00 EmrJobFlowSensor 2023-05-09T05:00:58.608901+00:00 2023-05-09T05:11:00.501532+00:00 0:10:01.892631 375795 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T05:00:56.322959+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T05:00:36.632433+00:00 2023-05-09T05:00:37.601261+00:00 0:00:00.968828 375793 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T05:00:34.325660+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T04:00:00+00:00 PythonOperator 2023-05-09T05:00:14.364531+00:00 2023-05-09T05:00:15.337782+00:00 0:00:00.973251 375791 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T05:00:12.250357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T03:00:00+00:00 TriggerDagRunOperator 2023-05-09T04:11:11.725448+00:00 2023-05-09T04:11:12.209299+00:00 0:00:00.483851 375774 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T04:11:08.810072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T03:00:00+00:00 TriggerDagRunOperator 2023-05-09T04:11:11.514221+00:00 2023-05-09T04:11:11.851388+00:00 0:00:00.337167 375773 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T04:11:08.810117+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T03:00:00+00:00 EmrJobFlowSensor 2023-05-09T04:00:56.751981+00:00 2023-05-09T04:10:58.840767+00:00 0:10:02.088786 375766 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T04:00:54.297293+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-09T04:00:34.467021+00:00 2023-05-09T04:00:35.307105+00:00 0:00:00.840084 375764 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-09T04:00:32.213481+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T03:00:00+00:00 PythonOperator 2023-05-09T04:00:14.600878+00:00 2023-05-09T04:00:15.573526+00:00 0:00:00.972648 375762 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-09T04:00:12.186245+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T02:00:00+00:00 TriggerDagRunOperator 2023-05-09T03:10:38.235047+00:00 2023-05-09T03:10:38.778378+00:00 0:00:00.543331 375748 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T03:10:35.740533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T02:00:00+00:00 TriggerDagRunOperator 2023-05-09T03:10:38.044939+00:00 2023-05-09T03:10:38.407171+00:00 0:00:00.362232 375747 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T03:10:35.740504+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T02:00:00+00:00 EmrJobFlowSensor 2023-05-09T03:01:22.725091+00:00 2023-05-09T03:10:24.512475+00:00 0:09:01.787384 375740 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T03:01:20.442688+00:00 2 default_pool