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-05T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T19:00:25.158196+00:00 2023-05-05T19:00:25.921501+00:00 0:00:00.763305 373675 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T19:00:22.439791+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T18:00:00+00:00 PythonOperator 2023-05-05T19:00:04.812705+00:00 2023-05-05T19:00:05.794502+00:00 0:00:00.981797 373673 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T19:00:02.414477+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T17:00:00+00:00 TriggerDagRunOperator 2023-05-05T18:11:23.414398+00:00 2023-05-05T18:11:23.904061+00:00 0:00:00.489663 373658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T18:11:20.911196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T17:00:00+00:00 TriggerDagRunOperator 2023-05-05T18:11:23.341362+00:00 2023-05-05T18:11:23.704285+00:00 0:00:00.362923 373657 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T18:11:20.911150+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T17:00:00+00:00 EmrJobFlowSensor 2023-05-05T18:01:04.559516+00:00 2023-05-05T18:11:06.354248+00:00 0:10:01.794732 373649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T18:01:02.295498+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T18:00:42.576667+00:00 2023-05-05T18:00:43.344984+00:00 0:00:00.768317 373648 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T18:00:40.282389+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T17:00:00+00:00 PythonOperator 2023-05-05T18:00:22.352626+00:00 2023-05-05T18:00:23.349712+00:00 0:00:00.997086 373647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T18:00:20.174202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T16:00:00+00:00 TriggerDagRunOperator 2023-05-05T17:11:16.933362+00:00 2023-05-05T17:11:17.389569+00:00 0:00:00.456207 373633 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T17:11:14.424982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T16:00:00+00:00 TriggerDagRunOperator 2023-05-05T17:11:16.835703+00:00 2023-05-05T17:11:17.169192+00:00 0:00:00.333489 373632 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T17:11:14.425011+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T16:00:00+00:00 EmrJobFlowSensor 2023-05-05T17:01:01.558862+00:00 2023-05-05T17:11:03.542734+00:00 0:10:01.983872 373622 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T17:00:59.295045+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T17:00:39.554044+00:00 2023-05-05T17:00:40.354737+00:00 0:00:00.800693 373621 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T17:00:37.216396+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T16:00:00+00:00 PythonOperator 2023-05-05T17:00:17.351374+00:00 2023-05-05T17:00:18.260329+00:00 0:00:00.908955 373620 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T17:00:15.175964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T15:00:00+00:00 TriggerDagRunOperator 2023-05-05T16:18:16.965358+00:00 2023-05-05T16:18:17.433803+00:00 0:00:00.468445 373607 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T16:18:14.316680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T15:00:00+00:00 TriggerDagRunOperator 2023-05-05T16:18:16.949864+00:00 2023-05-05T16:18:17.480021+00:00 0:00:00.530157 373606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T16:18:14.316710+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T15:00:00+00:00 EmrJobFlowSensor 2023-05-05T16:00:58.162201+00:00 2023-05-05T16:11:00.175049+00:00 0:10:02.012848 373598 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T16:00:55.983011+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T16:00:36.117392+00:00 2023-05-05T16:00:36.888596+00:00 0:00:00.771204 373596 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T16:00:33.955544+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T15:00:00+00:00 PythonOperator 2023-05-05T16:00:16.464075+00:00 2023-05-05T16:00:17.455558+00:00 0:00:00.991483 373594 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T16:00:14.011630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T14:00:00+00:00 TriggerDagRunOperator 2023-05-05T15:13:28.806464+00:00 2023-05-05T15:13:29.418949+00:00 0:00:00.612485 373584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T15:13:25.301337+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T14:00:00+00:00 TriggerDagRunOperator 2023-05-05T15:13:27.814350+00:00 2023-05-05T15:13:28.145358+00:00 0:00:00.331008 373583 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T15:13:25.301309+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T14:00:00+00:00 EmrJobFlowSensor 2023-05-05T15:02:13.072269+00:00 2023-05-05T15:13:15.011758+00:00 0:11:01.939489 373576 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T15:02:10.924758+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T15:01:53.022432+00:00 2023-05-05T15:01:54.031543+00:00 0:00:01.009111 373574 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T15:01:50.891201+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T14:00:00+00:00 PythonOperator 2023-05-05T15:01:31.251749+00:00 2023-05-05T15:01:32.196607+00:00 0:00:00.944858 373572 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T15:01:28.900109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T13:00:00+00:00 TriggerDagRunOperator 2023-05-05T14:29:08.239099+00:00 2023-05-05T14:29:08.752163+00:00 0:00:00.513064 373561 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T14:29:05.909851+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T13:00:00+00:00 TriggerDagRunOperator 2023-05-05T14:29:08.142400+00:00 2023-05-05T14:29:08.503123+00:00 0:00:00.360723 373560 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T14:29:05.909880+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T13:00:00+00:00 EmrJobFlowSensor 2023-05-05T14:18:59.250451+00:00 2023-05-05T14:29:01.372421+00:00 0:10:02.121970 373557 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T14:18:57.042262+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T14:18:39.348614+00:00 2023-05-05T14:18:40.178061+00:00 0:00:00.829447 373554 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T14:18:37.025367+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T13:00:00+00:00 PythonOperator 2023-05-05T14:18:17.428958+00:00 2023-05-05T14:18:18.399100+00:00 0:00:00.970142 373551 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T14:18:15.012775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T12:00:00+00:00 TriggerDagRunOperator 2023-05-05T13:11:17.694842+00:00 2023-05-05T13:11:18.145287+00:00 0:00:00.450445 373538 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T13:11:15.097160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T12:00:00+00:00 TriggerDagRunOperator 2023-05-05T13:11:17.517147+00:00 2023-05-05T13:11:17.868265+00:00 0:00:00.351118 373537 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T13:11:15.097112+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T12:00:00+00:00 EmrJobFlowSensor 2023-05-05T13:00:55.387104+00:00 2023-05-05T13:10:57.280564+00:00 0:10:01.893460 373530 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T13:00:53.221833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T13:00:35.571261+00:00 2023-05-05T13:00:36.384312+00:00 0:00:00.813051 373528 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T13:00:33.206578+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T12:00:00+00:00 PythonOperator 2023-05-05T13:00:13.911089+00:00 2023-05-05T13:00:14.837407+00:00 0:00:00.926318 373526 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T13:00:11.205543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T11:00:00+00:00 TriggerDagRunOperator 2023-05-05T12:28:51.797479+00:00 2023-05-05T12:28:52.252654+00:00 0:00:00.455175 373514 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T12:28:49.300841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T11:00:00+00:00 TriggerDagRunOperator 2023-05-05T12:28:51.749837+00:00 2023-05-05T12:28:52.099289+00:00 0:00:00.349452 373513 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T12:28:49.300811+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T11:00:00+00:00 EmrJobFlowSensor 2023-05-05T12:02:59.261651+00:00 2023-05-05T12:13:01.128651+00:00 0:10:01.867000 373506 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T12:02:57.086390+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T12:02:39.488930+00:00 2023-05-05T12:02:40.548859+00:00 0:00:01.059929 373504 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T12:02:37.002006+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T11:00:00+00:00 PythonOperator 2023-05-05T12:02:18.204283+00:00 2023-05-05T12:02:19.502431+00:00 0:00:01.298148 373502 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T12:02:14.982702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T10:00:00+00:00 TriggerDagRunOperator 2023-05-05T11:17:39.923466+00:00 2023-05-05T11:17:40.364504+00:00 0:00:00.441038 373491 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T11:17:36.860977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T10:00:00+00:00 TriggerDagRunOperator 2023-05-05T11:17:39.818964+00:00 2023-05-05T11:17:40.167184+00:00 0:00:00.348220 373490 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T11:17:36.860949+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T10:00:00+00:00 EmrJobFlowSensor 2023-05-05T11:07:27.094611+00:00 2023-05-05T11:17:29.006253+00:00 0:10:01.911642 373487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T11:07:24.819552+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T11:07:05.070422+00:00 2023-05-05T11:07:06.182213+00:00 0:00:01.111791 373484 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T11:07:02.771853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T10:00:00+00:00 PythonOperator 2023-05-05T11:06:45.432344+00:00 2023-05-05T11:06:46.388938+00:00 0:00:00.956594 373481 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T11:06:42.752382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T09:00:00+00:00 TriggerDagRunOperator 2023-05-05T10:11:02.123792+00:00 2023-05-05T10:11:02.601731+00:00 0:00:00.477939 373466 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T10:10:59.698662+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T09:00:00+00:00 TriggerDagRunOperator 2023-05-05T10:11:02.018427+00:00 2023-05-05T10:11:02.363577+00:00 0:00:00.345150 373465 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T10:10:59.698711+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T09:00:00+00:00 EmrJobFlowSensor 2023-05-05T10:00:55.965912+00:00 2023-05-05T10:10:58.058902+00:00 0:10:02.092990 373459 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T10:00:53.226622+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T10:00:33.890641+00:00 2023-05-05T10:00:34.690570+00:00 0:00:00.799929 373457 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T10:00:31.210238+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T09:00:00+00:00 PythonOperator 2023-05-05T10:00:12.344738+00:00 2023-05-05T10:00:13.327519+00:00 0:00:00.982781 373455 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T10:00:09.211277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T08:00:00+00:00 TriggerDagRunOperator 2023-05-05T09:18:28.043146+00:00 2023-05-05T09:18:28.391718+00:00 0:00:00.348572 373442 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T09:18:25.337822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T08:00:00+00:00 TriggerDagRunOperator 2023-05-05T09:18:28.014192+00:00 2023-05-05T09:18:28.491877+00:00 0:00:00.477685 373441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T09:18:25.337783+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T08:00:00+00:00 EmrJobFlowSensor 2023-05-05T09:01:01.908378+00:00 2023-05-05T09:11:03.908126+00:00 0:10:01.999748 373435 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T09:00:59.193760+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T09:00:39.818986+00:00 2023-05-05T09:00:40.753366+00:00 0:00:00.934380 373433 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T09:00:37.222471+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T08:00:00+00:00 PythonOperator 2023-05-05T09:00:19.311890+00:00 2023-05-05T09:00:20.306335+00:00 0:00:00.994445 373431 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T09:00:17.030899+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T07:00:00+00:00 TriggerDagRunOperator 2023-05-05T08:16:53.258568+00:00 2023-05-05T08:16:53.736773+00:00 0:00:00.478205 373418 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T08:16:50.186830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T07:00:00+00:00 TriggerDagRunOperator 2023-05-05T08:16:53.137294+00:00 2023-05-05T08:16:53.463881+00:00 0:00:00.326587 373417 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T08:16:50.186872+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T07:00:00+00:00 EmrJobFlowSensor 2023-05-05T08:04:33.852192+00:00 2023-05-05T08:14:35.634324+00:00 0:10:01.782132 373411 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T08:04:31.667685+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T08:04:12.027306+00:00 2023-05-05T08:04:12.903466+00:00 0:00:00.876160 373409 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T08:04:09.642098+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T07:00:00+00:00 PythonOperator 2023-05-05T08:03:51.794079+00:00 2023-05-05T08:03:52.721522+00:00 0:00:00.927443 373407 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T08:03:49.625525+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T06:00:00+00:00 TriggerDagRunOperator 2023-05-05T07:11:21.977414+00:00 2023-05-05T07:11:22.348727+00:00 0:00:00.371313 373393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T07:11:19.387932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T06:00:00+00:00 TriggerDagRunOperator 2023-05-05T07:11:21.917057+00:00 2023-05-05T07:11:22.371867+00:00 0:00:00.454810 373392 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T07:11:19.387900+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T06:00:00+00:00 EmrJobFlowSensor 2023-05-05T07:01:07.123410+00:00 2023-05-05T07:11:09.018945+00:00 0:10:01.895535 373386 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T07:01:04.919352+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T07:00:45.303427+00:00 2023-05-05T07:00:46.186102+00:00 0:00:00.882675 373384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T07:00:42.898532+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T06:00:00+00:00 PythonOperator 2023-05-05T07:00:25.101366+00:00 2023-05-05T07:00:25.998308+00:00 0:00:00.896942 373382 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T07:00:22.879086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T05:00:00+00:00 TriggerDagRunOperator 2023-05-05T06:12:17.956722+00:00 2023-05-05T06:12:18.588530+00:00 0:00:00.631808 373368 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T06:12:14.607099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T05:00:00+00:00 TriggerDagRunOperator 2023-05-05T06:12:17.057348+00:00 2023-05-05T06:12:17.395973+00:00 0:00:00.338625 373367 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T06:12:14.607071+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T05:00:00+00:00 EmrJobFlowSensor 2023-05-05T06:02:06.134569+00:00 2023-05-05T06:12:07.976371+00:00 0:10:01.841802 373360 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T06:02:03.953491+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T06:01:46.057513+00:00 2023-05-05T06:01:46.827946+00:00 0:00:00.770433 373359 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T06:01:43.935161+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T05:00:00+00:00 PythonOperator 2023-05-05T06:00:22.150067+00:00 2023-05-05T06:00:23.127980+00:00 0:00:00.977913 373355 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T06:00:19.718520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T04:00:00+00:00 TriggerDagRunOperator 2023-05-05T05:18:25.773570+00:00 2023-05-05T05:18:26.406384+00:00 0:00:00.632814 373341 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T05:18:22.805993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T04:00:00+00:00 TriggerDagRunOperator 2023-05-05T05:18:25.359429+00:00 2023-05-05T05:18:25.799072+00:00 0:00:00.439643 373340 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T05:18:22.805965+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T04:00:00+00:00 EmrJobFlowSensor 2023-05-05T05:00:51.552593+00:00 2023-05-05T05:10:53.303660+00:00 0:10:01.751067 373336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T05:00:49.223226+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T05:00:31.304821+00:00 2023-05-05T05:00:32.138211+00:00 0:00:00.833390 373334 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T05:00:29.137247+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T04:00:00+00:00 PythonOperator 2023-05-05T05:00:10.041850+00:00 2023-05-05T05:00:11.069599+00:00 0:00:01.027749 373332 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T05:00:07.190932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T03:00:00+00:00 TriggerDagRunOperator 2023-05-05T04:11:03.756752+00:00 2023-05-05T04:11:04.126710+00:00 0:00:00.369958 373319 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T04:11:01.480558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T03:00:00+00:00 TriggerDagRunOperator 2023-05-05T04:11:03.759912+00:00 2023-05-05T04:11:04.223389+00:00 0:00:00.463477 373318 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T04:11:01.480523+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T03:00:00+00:00 EmrJobFlowSensor 2023-05-05T04:00:50.850416+00:00 2023-05-05T04:10:52.744012+00:00 0:10:01.893596 373309 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T04:00:48.481942+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T04:00:30.853415+00:00 2023-05-05T04:00:32.428225+00:00 0:00:01.574810 373307 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T04:00:28.327638+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T03:00:00+00:00 PythonOperator 2023-05-05T04:00:08.949344+00:00 2023-05-05T04:00:09.915711+00:00 0:00:00.966367 373305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T04:00:06.311203+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T02:00:00+00:00 TriggerDagRunOperator 2023-05-05T03:11:03.625663+00:00 2023-05-05T03:11:04.115279+00:00 0:00:00.489616 373291 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T03:11:00.695822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T02:00:00+00:00 TriggerDagRunOperator 2023-05-05T03:11:03.617329+00:00 2023-05-05T03:11:04.008607+00:00 0:00:00.391278 373290 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T03:11:00.695865+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T02:00:00+00:00 EmrJobFlowSensor 2023-05-05T03:00:46.782903+00:00 2023-05-05T03:10:48.671647+00:00 0:10:01.888744 373282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T03:00:44.483959+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T03:00:26.699002+00:00 2023-05-05T03:00:27.601718+00:00 0:00:00.902716 373280 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T03:00:24.404023+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T02:00:00+00:00 PythonOperator 2023-05-05T03:00:04.782301+00:00 2023-05-05T03:00:05.766324+00:00 0:00:00.984023 373278 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T03:00:02.361167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T01:00:00+00:00 TriggerDagRunOperator 2023-05-05T02:11:00.258237+00:00 2023-05-05T02:11:00.741417+00:00 0:00:00.483180 373265 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T02:10:56.902512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T01:00:00+00:00 TriggerDagRunOperator 2023-05-05T02:11:00.173778+00:00 2023-05-05T02:11:00.609111+00:00 0:00:00.435333 373264 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T02:10:56.902541+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T01:00:00+00:00 EmrJobFlowSensor 2023-05-05T02:00:47.888864+00:00 2023-05-05T02:10:49.680376+00:00 0:10:01.791512 373256 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T02:00:45.714028+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T02:00:27.954782+00:00 2023-05-05T02:00:28.874035+00:00 0:00:00.919253 373254 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T02:00:25.695082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T01:00:00+00:00 PythonOperator 2023-05-05T02:00:06.620620+00:00 2023-05-05T02:00:07.534807+00:00 0:00:00.914187 373252 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T02:00:03.687852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T00:00:00+00:00 TriggerDagRunOperator 2023-05-05T01:12:11.820499+00:00 2023-05-05T01:12:12.260742+00:00 0:00:00.440243 373233 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T01:12:09.306080+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T00:00:00+00:00 TriggerDagRunOperator 2023-05-05T01:12:11.744696+00:00 2023-05-05T01:12:12.120672+00:00 0:00:00.375976 373232 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T01:12:09.306051+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T00:00:00+00:00 EmrJobFlowSensor 2023-05-05T01:00:56.067736+00:00 2023-05-05T01:11:57.967683+00:00 0:11:01.899947 373224 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T01:00:53.924103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T01:00:36.122010+00:00 2023-05-05T01:00:36.999744+00:00 0:00:00.877734 373222 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T01:00:33.881873+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T00:00:00+00:00 PythonOperator 2023-05-05T01:00:14.687425+00:00 2023-05-05T01:00:15.701993+00:00 0:00:01.014568 373220 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T01:00:12.010387+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T23:00:00+00:00 TriggerDagRunOperator 2023-05-05T00:11:01.259681+00:00 2023-05-05T00:11:01.718049+00:00 0:00:00.458368 373207 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T00:10:58.103700+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T23:00:00+00:00 TriggerDagRunOperator 2023-05-05T00:11:01.130146+00:00 2023-05-05T00:11:01.473000+00:00 0:00:00.342854 373206 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T00:10:58.103730+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T23:00:00+00:00 EmrJobFlowSensor 2023-05-05T00:01:41.749700+00:00 2023-05-05T00:10:43.619324+00:00 0:09:01.869624 373198 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T00:01:38.786417+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T00:00:28.422954+00:00 2023-05-05T00:00:29.224051+00:00 0:00:00.801097 373196 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T00:00:26.089818+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T23:00:00+00:00 PythonOperator 2023-05-05T00:00:08.828566+00:00 2023-05-05T00:00:09.806871+00:00 0:00:00.978305 373194 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T00:00:06.010447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T22:00:00+00:00 TriggerDagRunOperator 2023-05-04T23:10:19.909868+00:00 2023-05-04T23:10:20.357853+00:00 0:00:00.447985 373180 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T23:10:17.099771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T22:00:00+00:00 TriggerDagRunOperator 2023-05-04T23:10:19.802731+00:00 2023-05-04T23:10:20.145918+00:00 0:00:00.343187 373179 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T23:10:17.099731+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T22:00:00+00:00 EmrJobFlowSensor 2023-05-04T23:00:58.388268+00:00 2023-05-04T23:10:00.278183+00:00 0:09:01.889915 373170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T23:00:55.594292+00:00 2 default_pool