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 trigger_dagrun_booking-processing-job_v002 2023-03-23T23:00:00+00:00 TriggerDagRunOperator 2023-03-24T00:14:24.106681+00:00 2023-03-24T00:14:24.553434+00:00 0:00:00.446753 358233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-24T00:14:21.526638+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T23:00:00+00:00 EmrJobFlowSensor 2023-03-24T00:04:11.035749+00:00 2023-03-24T00:14:13.206818+00:00 0:10:02.171069 358226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-24T00:04:08.443368+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-24T00:03:48.642911+00:00 2023-03-24T00:03:49.514154+00:00 0:00:00.871243 358224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-24T00:03:46.420057+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T23:00:00+00:00 PythonOperator 2023-03-24T00:03:26.815701+00:00 2023-03-24T00:03:33.749071+00:00 0:00:06.933370 358222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-24T00:03:24.402609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T22:00:00+00:00 TriggerDagRunOperator 2023-03-23T23:11:16.971030+00:00 2023-03-23T23:11:17.466098+00:00 0:00:00.495068 358215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T23:11:14.345518+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T22:00:00+00:00 TriggerDagRunOperator 2023-03-23T23:11:16.795917+00:00 2023-03-23T23:11:17.263600+00:00 0:00:00.467683 358214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T23:11:14.345488+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T22:00:00+00:00 EmrJobFlowSensor 2023-03-23T23:01:01.855212+00:00 2023-03-23T23:11:03.721692+00:00 0:10:01.866480 358206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T23:00:59.350263+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T23:00:41.682042+00:00 2023-03-23T23:00:42.549004+00:00 0:00:00.866962 358203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T23:00:39.330493+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T22:00:00+00:00 PythonOperator 2023-03-23T23:00:17.505480+00:00 2023-03-23T23:00:22.307322+00:00 0:00:04.801842 358200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T23:00:15.251829+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T21:00:00+00:00 TriggerDagRunOperator 2023-03-23T22:11:19.389012+00:00 2023-03-23T22:11:19.965546+00:00 0:00:00.576534 358189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T22:11:16.676764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T21:00:00+00:00 TriggerDagRunOperator 2023-03-23T22:11:18.992770+00:00 2023-03-23T22:11:19.493711+00:00 0:00:00.500941 358188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T22:11:16.676793+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T21:00:00+00:00 EmrJobFlowSensor 2023-03-23T22:01:07.055470+00:00 2023-03-23T22:11:08.906551+00:00 0:10:01.851081 358181 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T22:01:04.389290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T22:00:44.761395+00:00 2023-03-23T22:00:45.942404+00:00 0:00:01.181009 358179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T22:00:42.370398+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T21:00:00+00:00 PythonOperator 2023-03-23T22:00:22.724142+00:00 2023-03-23T22:00:26.826762+00:00 0:00:04.102620 358177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T22:00:20.401971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T20:00:00+00:00 TriggerDagRunOperator 2023-03-23T21:11:25.795061+00:00 2023-03-23T21:11:26.472177+00:00 0:00:00.677116 358166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T21:11:23.330347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T20:00:00+00:00 TriggerDagRunOperator 2023-03-23T21:11:25.569392+00:00 2023-03-23T21:11:26.340558+00:00 0:00:00.771166 358165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T21:11:23.330313+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T20:00:00+00:00 EmrJobFlowSensor 2023-03-23T21:01:06.024785+00:00 2023-03-23T21:11:07.944043+00:00 0:10:01.919258 358159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T21:01:03.504533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T21:00:43.801994+00:00 2023-03-23T21:00:44.659448+00:00 0:00:00.857454 358156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T21:00:41.485574+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T20:00:00+00:00 PythonOperator 2023-03-23T21:00:24.164710+00:00 2023-03-23T21:00:28.181863+00:00 0:00:04.017153 358154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T21:00:21.471676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T19:00:00+00:00 TriggerDagRunOperator 2023-03-23T20:11:20.267530+00:00 2023-03-23T20:11:20.775055+00:00 0:00:00.507525 358144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T20:11:17.854372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T19:00:00+00:00 TriggerDagRunOperator 2023-03-23T20:11:20.236525+00:00 2023-03-23T20:11:20.713938+00:00 0:00:00.477413 358143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T20:11:17.854400+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T19:00:00+00:00 EmrJobFlowSensor 2023-03-23T20:00:54.866354+00:00 2023-03-23T20:10:56.922075+00:00 0:10:02.055721 358137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T20:00:52.607074+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T20:00:35.698745+00:00 2023-03-23T20:00:36.870287+00:00 0:00:01.171542 358135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T20:00:30.501552+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T19:00:00+00:00 PythonOperator 2023-03-23T20:00:10.661419+00:00 2023-03-23T20:00:14.270225+00:00 0:00:03.608806 358133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T20:00:08.446070+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T18:00:00+00:00 TriggerDagRunOperator 2023-03-23T19:11:24.047883+00:00 2023-03-23T19:11:24.531653+00:00 0:00:00.483770 358121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T19:11:21.308319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T18:00:00+00:00 TriggerDagRunOperator 2023-03-23T19:11:23.911249+00:00 2023-03-23T19:11:24.383042+00:00 0:00:00.471793 358120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T19:11:21.308395+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T18:00:00+00:00 EmrJobFlowSensor 2023-03-23T19:00:58.885192+00:00 2023-03-23T19:11:00.708641+00:00 0:10:01.823449 358113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T19:00:56.596183+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T19:00:36.748834+00:00 2023-03-23T19:00:37.722127+00:00 0:00:00.973293 358111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T19:00:34.495621+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T18:00:00+00:00 PythonOperator 2023-03-23T19:00:16.973240+00:00 2023-03-23T19:00:20.306976+00:00 0:00:03.333736 358109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T19:00:14.445267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T17:00:00+00:00 TriggerDagRunOperator 2023-03-23T18:29:48.288462+00:00 2023-03-23T18:29:48.787752+00:00 0:00:00.499290 358101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T18:29:45.307367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T17:00:00+00:00 TriggerDagRunOperator 2023-03-23T18:29:48.141395+00:00 2023-03-23T18:29:48.584157+00:00 0:00:00.442762 358100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T18:29:45.307399+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T17:00:00+00:00 EmrJobFlowSensor 2023-03-23T18:06:14.639747+00:00 2023-03-23T18:16:16.345032+00:00 0:10:01.705285 358095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T18:06:12.463317+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T18:05:52.822206+00:00 2023-03-23T18:05:53.738522+00:00 0:00:00.916316 358092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T18:05:50.443937+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T17:00:00+00:00 PythonOperator 2023-03-23T18:05:31.107117+00:00 2023-03-23T18:05:34.663168+00:00 0:00:03.556051 358089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T18:05:28.477922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T16:00:00+00:00 TriggerDagRunOperator 2023-03-23T17:16:30.902855+00:00 2023-03-23T17:16:31.405570+00:00 0:00:00.502715 358081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T17:16:28.363867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T16:00:00+00:00 TriggerDagRunOperator 2023-03-23T17:16:30.901873+00:00 2023-03-23T17:16:31.417279+00:00 0:00:00.515406 358080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T17:16:28.363896+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T16:00:00+00:00 EmrJobFlowSensor 2023-03-23T17:06:17.691472+00:00 2023-03-23T17:16:19.471233+00:00 0:10:01.779761 358076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T17:06:15.071926+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T17:05:55.998113+00:00 2023-03-23T17:05:57.018796+00:00 0:00:01.020683 358072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T17:05:53.114916+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T16:00:00+00:00 PythonOperator 2023-03-23T17:05:35.661565+00:00 2023-03-23T17:05:39.869398+00:00 0:00:04.207833 358069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T17:05:32.663590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T15:00:00+00:00 TriggerDagRunOperator 2023-03-23T16:15:17.418638+00:00 2023-03-23T16:15:17.915194+00:00 0:00:00.496556 358061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T16:15:15.024472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T15:00:00+00:00 TriggerDagRunOperator 2023-03-23T16:15:17.296814+00:00 2023-03-23T16:15:17.791804+00:00 0:00:00.494990 358060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T16:15:15.024444+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T15:00:00+00:00 EmrJobFlowSensor 2023-03-23T16:04:54.313465+00:00 2023-03-23T16:14:56.206412+00:00 0:10:01.892947 358054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T16:04:51.947261+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T16:04:32.176263+00:00 2023-03-23T16:04:33.019572+00:00 0:00:00.843309 358052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T16:04:29.929066+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T15:00:00+00:00 PythonOperator 2023-03-23T16:04:10.230878+00:00 2023-03-23T16:04:13.397783+00:00 0:00:03.166905 358050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T16:04:07.889138+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T14:00:00+00:00 TriggerDagRunOperator 2023-03-23T15:11:14.250660+00:00 2023-03-23T15:11:14.745141+00:00 0:00:00.494481 358038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T15:11:11.941500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T14:00:00+00:00 TriggerDagRunOperator 2023-03-23T15:11:14.110845+00:00 2023-03-23T15:11:14.574346+00:00 0:00:00.463501 358037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T15:11:11.941552+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T14:00:00+00:00 EmrJobFlowSensor 2023-03-23T15:00:47.847960+00:00 2023-03-23T15:10:49.982898+00:00 0:10:02.134938 358030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T15:00:45.595618+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T15:00:26.023818+00:00 2023-03-23T15:00:26.888852+00:00 0:00:00.865034 358028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T15:00:23.576981+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T14:00:00+00:00 PythonOperator 2023-03-23T15:00:06.542776+00:00 2023-03-23T15:00:10.064757+00:00 0:00:03.521981 358026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T15:00:03.563109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T13:00:00+00:00 TriggerDagRunOperator 2023-03-23T14:17:41.224456+00:00 2023-03-23T14:17:41.759429+00:00 0:00:00.534973 358019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T14:17:38.459078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T13:00:00+00:00 TriggerDagRunOperator 2023-03-23T14:17:41.052927+00:00 2023-03-23T14:17:41.633648+00:00 0:00:00.580721 358018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T14:17:38.459106+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T13:00:00+00:00 EmrJobFlowSensor 2023-03-23T14:00:58.035817+00:00 2023-03-23T14:11:00.282115+00:00 0:10:02.246298 358010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T14:00:55.426252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T14:00:37.675618+00:00 2023-03-23T14:00:38.527346+00:00 0:00:00.851728 358008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T14:00:35.389802+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T13:00:00+00:00 PythonOperator 2023-03-23T14:00:14.274467+00:00 2023-03-23T14:00:17.603569+00:00 0:00:03.329102 358006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T14:00:11.394527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T12:00:00+00:00 TriggerDagRunOperator 2023-03-23T13:29:04.214548+00:00 2023-03-23T13:29:04.686044+00:00 0:00:00.471496 358000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T13:29:01.412440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T12:00:00+00:00 TriggerDagRunOperator 2023-03-23T13:29:03.951728+00:00 2023-03-23T13:29:04.413028+00:00 0:00:00.461300 357999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T13:29:01.412468+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T12:00:00+00:00 EmrJobFlowSensor 2023-03-23T13:04:16.140902+00:00 2023-03-23T13:14:17.885073+00:00 0:10:01.744171 357992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T13:04:13.868368+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T13:03:54.100301+00:00 2023-03-23T13:03:55.258170+00:00 0:00:01.157869 357990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T13:03:51.846457+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T12:00:00+00:00 PythonOperator 2023-03-23T13:03:34.555580+00:00 2023-03-23T13:03:38.557904+00:00 0:00:04.002324 357988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T13:03:31.833454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T11:00:00+00:00 TriggerDagRunOperator 2023-03-23T12:21:05.015759+00:00 2023-03-23T12:21:05.502422+00:00 0:00:00.486663 357983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T12:21:02.596171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T11:00:00+00:00 TriggerDagRunOperator 2023-03-23T12:21:05.006022+00:00 2023-03-23T12:21:05.484021+00:00 0:00:00.477999 357982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T12:21:02.596142+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T11:00:00+00:00 EmrJobFlowSensor 2023-03-23T12:01:36.794548+00:00 2023-03-23T12:11:38.594527+00:00 0:10:01.799979 357976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T12:01:34.521066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T12:01:14.655706+00:00 2023-03-23T12:01:15.503121+00:00 0:00:00.847415 357974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T12:01:12.495242+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T11:00:00+00:00 PythonOperator 2023-03-23T12:00:52.995684+00:00 2023-03-23T12:00:56.336200+00:00 0:00:03.340516 357972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T12:00:50.520059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T10:00:00+00:00 TriggerDagRunOperator 2023-03-23T11:12:02.919904+00:00 2023-03-23T11:12:03.720117+00:00 0:00:00.800213 357960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T11:11:58.923450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T10:00:00+00:00 TriggerDagRunOperator 2023-03-23T11:12:01.485646+00:00 2023-03-23T11:12:02.000491+00:00 0:00:00.514845 357959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T11:11:58.923406+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T10:00:00+00:00 EmrJobFlowSensor 2023-03-23T11:00:52.850999+00:00 2023-03-23T11:10:54.864125+00:00 0:10:02.013126 357954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T11:00:50.436914+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T11:00:30.737130+00:00 2023-03-23T11:00:31.941712+00:00 0:00:01.204582 357952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T11:00:28.337224+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T10:00:00+00:00 PythonOperator 2023-03-23T11:00:08.715862+00:00 2023-03-23T11:00:13.077283+00:00 0:00:04.361421 357950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T11:00:06.298828+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T09:00:00+00:00 TriggerDagRunOperator 2023-03-23T10:11:16.256888+00:00 2023-03-23T10:11:16.723177+00:00 0:00:00.466289 357943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T10:11:13.836566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T09:00:00+00:00 TriggerDagRunOperator 2023-03-23T10:11:16.150498+00:00 2023-03-23T10:11:16.614502+00:00 0:00:00.464004 357942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T10:11:13.836534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T09:00:00+00:00 EmrJobFlowSensor 2023-03-23T10:01:06.682850+00:00 2023-03-23T10:11:08.454575+00:00 0:10:01.771725 357936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T10:01:04.411022+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T10:00:44.886614+00:00 2023-03-23T10:00:45.827205+00:00 0:00:00.940591 357934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T10:00:42.389876+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T09:00:00+00:00 PythonOperator 2023-03-23T10:00:23.724054+00:00 2023-03-23T10:00:27.326594+00:00 0:00:03.602540 357932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T10:00:20.409445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T08:00:00+00:00 TriggerDagRunOperator 2023-03-23T09:54:59.835140+00:00 2023-03-23T09:55:00.509410+00:00 0:00:00.674270 357926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T09:54:57.301554+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T08:00:00+00:00 TriggerDagRunOperator 2023-03-23T09:54:59.601753+00:00 2023-03-23T09:55:00.239971+00:00 0:00:00.638218 357925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T09:54:57.301525+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T08:00:00+00:00 EmrJobFlowSensor 2023-03-23T09:44:48.569034+00:00 2023-03-23T09:54:50.508924+00:00 0:10:01.939890 357920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T09:44:46.376482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T09:44:26.658585+00:00 2023-03-23T09:44:27.580632+00:00 0:00:00.922047 357917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T09:44:24.350135+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T08:00:00+00:00 PythonOperator 2023-03-23T09:44:06.966206+00:00 2023-03-23T09:44:10.330785+00:00 0:00:03.364579 357914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T09:44:04.381569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T07:00:00+00:00 TriggerDagRunOperator 2023-03-23T08:20:47.894531+00:00 2023-03-23T08:20:48.381007+00:00 0:00:00.486476 357907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T08:20:45.168426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T07:00:00+00:00 TriggerDagRunOperator 2023-03-23T08:20:47.745392+00:00 2023-03-23T08:20:48.225031+00:00 0:00:00.479639 357906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T08:20:45.168454+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T07:00:00+00:00 EmrJobFlowSensor 2023-03-23T08:08:48.349414+00:00 2023-03-23T08:18:50.293824+00:00 0:10:01.944410 357902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T08:08:46.056139+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T08:08:30.220336+00:00 2023-03-23T08:08:32.212661+00:00 0:00:01.992325 357899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T08:08:26.040569+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T07:00:00+00:00 PythonOperator 2023-03-23T08:08:07.823456+00:00 2023-03-23T08:08:14.507286+00:00 0:00:06.683830 357896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T08:08:03.988855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T06:00:00+00:00 TriggerDagRunOperator 2023-03-23T07:53:05.497303+00:00 2023-03-23T07:53:06.048834+00:00 0:00:00.551531 357890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T07:53:03.053697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T06:00:00+00:00 TriggerDagRunOperator 2023-03-23T07:53:05.445831+00:00 2023-03-23T07:53:05.993658+00:00 0:00:00.547827 357889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T07:53:03.053724+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T06:00:00+00:00 EmrJobFlowSensor 2023-03-23T07:15:43.261609+00:00 2023-03-23T07:25:44.956154+00:00 0:10:01.694545 357885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T07:15:41.011275+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T07:15:21.172048+00:00 2023-03-23T07:15:22.640237+00:00 0:00:01.468189 357882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T07:15:18.983369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T06:00:00+00:00 PythonOperator 2023-03-23T07:14:59.160855+00:00 2023-03-23T07:15:03.672431+00:00 0:00:04.511576 357879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T07:14:56.955538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T05:00:00+00:00 TriggerDagRunOperator 2023-03-23T06:23:46.193786+00:00 2023-03-23T06:23:46.714200+00:00 0:00:00.520414 357873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T06:23:43.526696+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T05:00:00+00:00 TriggerDagRunOperator 2023-03-23T06:23:46.079952+00:00 2023-03-23T06:23:46.558601+00:00 0:00:00.478649 357872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T06:23:43.526667+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T05:00:00+00:00 EmrJobFlowSensor 2023-03-23T06:13:38.646162+00:00 2023-03-23T06:23:40.312407+00:00 0:10:01.666245 357869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T06:13:36.425496+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T06:13:16.643551+00:00 2023-03-23T06:13:17.583264+00:00 0:00:00.939713 357866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T06:13:14.374386+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T05:00:00+00:00 PythonOperator 2023-03-23T06:12:57.400174+00:00 2023-03-23T06:13:00.654408+00:00 0:00:03.254234 357863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T06:12:52.362992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T04:00:00+00:00 TriggerDagRunOperator 2023-03-23T05:22:10.961378+00:00 2023-03-23T05:22:11.469931+00:00 0:00:00.508553 357855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T05:22:08.036949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T04:00:00+00:00 TriggerDagRunOperator 2023-03-23T05:22:10.739693+00:00 2023-03-23T05:22:11.318176+00:00 0:00:00.578483 357854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T05:22:08.036977+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T04:00:00+00:00 EmrJobFlowSensor 2023-03-23T05:02:47.221467+00:00 2023-03-23T05:12:49.084050+00:00 0:10:01.862583 357848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T05:02:44.735394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T05:02:29.107169+00:00 2023-03-23T05:02:30.268899+00:00 0:00:01.161730 357846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T05:02:24.654816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T04:00:00+00:00 PythonOperator 2023-03-23T05:02:05.005767+00:00 2023-03-23T05:02:08.473971+00:00 0:00:03.468204 357844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T05:02:02.633552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T03:00:00+00:00 TriggerDagRunOperator 2023-03-23T04:30:32.446995+00:00 2023-03-23T04:30:33.218687+00:00 0:00:00.771692 357836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T04:30:28.669691+00:00 2 default_pool