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-03T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T07:13:32.055442+00:00 2023-05-03T07:13:32.910955+00:00 0:00:00.855513 372184 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T07:13:29.787081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T06:00:00+00:00 PythonOperator 2023-05-03T07:13:10.343945+00:00 2023-05-03T07:13:11.245480+00:00 0:00:00.901535 372181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T07:13:07.810419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T05:00:00+00:00 TriggerDagRunOperator 2023-05-03T06:17:18.948749+00:00 2023-05-03T06:17:19.312879+00:00 0:00:00.364130 372169 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T06:17:15.850614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T05:00:00+00:00 TriggerDagRunOperator 2023-05-03T06:17:18.679258+00:00 2023-05-03T06:17:19.116500+00:00 0:00:00.437242 372168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T06:17:15.850586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T05:00:00+00:00 EmrJobFlowSensor 2023-05-03T06:04:56.216362+00:00 2023-05-03T06:14:58.144415+00:00 0:10:01.928053 372162 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T06:04:53.921880+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T06:04:36.131724+00:00 2023-05-03T06:04:37.111948+00:00 0:00:00.980224 372160 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T06:04:33.902820+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T05:00:00+00:00 PythonOperator 2023-05-03T06:04:14.107207+00:00 2023-05-03T06:04:14.984123+00:00 0:00:00.876916 372158 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T06:04:11.895068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T04:00:00+00:00 TriggerDagRunOperator 2023-05-03T05:15:24.683901+00:00 2023-05-03T05:15:25.138798+00:00 0:00:00.454897 372144 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T05:15:21.662375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T04:00:00+00:00 TriggerDagRunOperator 2023-05-03T05:15:24.702495+00:00 2023-05-03T05:15:25.216348+00:00 0:00:00.513853 372143 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T05:15:21.662328+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T04:00:00+00:00 EmrJobFlowSensor 2023-05-03T05:01:15.833378+00:00 2023-05-03T05:11:17.609398+00:00 0:10:01.776020 372137 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T05:01:13.606442+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T05:00:33.124765+00:00 2023-05-03T05:00:33.985327+00:00 0:00:00.860562 372133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T05:00:31.029987+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T04:00:00+00:00 PythonOperator 2023-05-03T05:00:13.616708+00:00 2023-05-03T05:00:14.584112+00:00 0:00:00.967404 372132 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T05:00:10.997803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T03:00:00+00:00 TriggerDagRunOperator 2023-05-03T04:11:13.250588+00:00 2023-05-03T04:11:13.823428+00:00 0:00:00.572840 372117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T04:11:09.917157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T03:00:00+00:00 TriggerDagRunOperator 2023-05-03T04:11:12.843917+00:00 2023-05-03T04:11:13.191579+00:00 0:00:00.347662 372116 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T04:11:09.917129+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T03:00:00+00:00 EmrJobFlowSensor 2023-05-03T04:00:51.508010+00:00 2023-05-03T04:10:53.382868+00:00 0:10:01.874858 372112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T04:00:49.209897+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T04:00:31.400250+00:00 2023-05-03T04:00:32.320246+00:00 0:00:00.919996 372110 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T04:00:29.145062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T03:00:00+00:00 PythonOperator 2023-05-03T04:00:09.759001+00:00 2023-05-03T04:00:10.700649+00:00 0:00:00.941648 372108 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T04:00:07.125176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T02:00:00+00:00 TriggerDagRunOperator 2023-05-03T03:11:13.299623+00:00 2023-05-03T03:11:13.757965+00:00 0:00:00.458342 372094 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T03:11:10.813163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T02:00:00+00:00 TriggerDagRunOperator 2023-05-03T03:11:13.185011+00:00 2023-05-03T03:11:13.573345+00:00 0:00:00.388334 372093 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T03:11:10.813190+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T02:00:00+00:00 EmrJobFlowSensor 2023-05-03T03:01:00.282863+00:00 2023-05-03T03:11:02.167924+00:00 0:10:01.885061 372086 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T03:00:57.514412+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T03:00:37.703257+00:00 2023-05-03T03:00:38.499520+00:00 0:00:00.796263 372084 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T03:00:35.403251+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T02:00:00+00:00 PythonOperator 2023-05-03T03:00:17.781945+00:00 2023-05-03T03:00:18.753996+00:00 0:00:00.972051 372082 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T03:00:15.322357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T01:00:00+00:00 TriggerDagRunOperator 2023-05-03T02:11:20.843926+00:00 2023-05-03T02:11:21.279857+00:00 0:00:00.435931 372071 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T02:11:18.545146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T01:00:00+00:00 TriggerDagRunOperator 2023-05-03T02:11:20.797355+00:00 2023-05-03T02:11:21.146855+00:00 0:00:00.349500 372070 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T02:11:18.545176+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T01:00:00+00:00 EmrJobFlowSensor 2023-05-03T02:01:01.794230+00:00 2023-05-03T02:11:03.736968+00:00 0:10:01.942738 372064 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T02:00:59.468237+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T02:00:39.942726+00:00 2023-05-03T02:00:40.841254+00:00 0:00:00.898528 372062 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T02:00:37.482983+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T01:00:00+00:00 PythonOperator 2023-05-03T02:00:15.882813+00:00 2023-05-03T02:00:16.800042+00:00 0:00:00.917229 372060 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T02:00:13.413769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-03T00:00:00+00:00 TriggerDagRunOperator 2023-05-03T01:17:32.884210+00:00 2023-05-03T01:17:33.324889+00:00 0:00:00.440679 372040 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T01:17:29.908344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-03T00:00:00+00:00 TriggerDagRunOperator 2023-05-03T01:17:32.821163+00:00 2023-05-03T01:17:33.173395+00:00 0:00:00.352232 372039 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T01:17:29.908374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-03T00:00:00+00:00 EmrJobFlowSensor 2023-05-03T01:07:17.485528+00:00 2023-05-03T01:17:19.707065+00:00 0:10:02.221537 372035 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T01:07:15.309922+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-03T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T01:06:53.366538+00:00 2023-05-03T01:06:54.577005+00:00 0:00:01.210467 372032 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T01:06:51.224112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-03T00:00:00+00:00 PythonOperator 2023-05-03T01:06:33.377104+00:00 2023-05-03T01:06:35.267776+00:00 0:00:01.890672 372029 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T01:06:31.204740+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T23:00:00+00:00 TriggerDagRunOperator 2023-05-03T00:22:09.599017+00:00 2023-05-03T00:22:10.066915+00:00 0:00:00.467898 372017 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T00:22:07.038073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T23:00:00+00:00 TriggerDagRunOperator 2023-05-03T00:22:09.469415+00:00 2023-05-03T00:22:09.904621+00:00 0:00:00.435206 372016 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-03T00:22:07.038114+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T23:00:00+00:00 EmrJobFlowSensor 2023-05-03T00:12:00.185727+00:00 2023-05-03T00:22:02.194054+00:00 0:10:02.008327 372012 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-03T00:11:57.654365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-03T00:11:39.971886+00:00 2023-05-03T00:11:40.843706+00:00 0:00:00.871820 372009 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-03T00:11:37.635155+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T23:00:00+00:00 PythonOperator 2023-05-03T00:11:18.638447+00:00 2023-05-03T00:11:19.798173+00:00 0:00:01.159726 372006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-03T00:11:15.615379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T22:00:00+00:00 TriggerDagRunOperator 2023-05-02T23:16:40.807449+00:00 2023-05-02T23:16:41.227170+00:00 0:00:00.419721 371994 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T23:16:38.043988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T22:00:00+00:00 TriggerDagRunOperator 2023-05-02T23:16:40.697404+00:00 2023-05-02T23:16:41.090826+00:00 0:00:00.393422 371993 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T23:16:38.043960+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T22:00:00+00:00 EmrJobFlowSensor 2023-05-02T23:01:01.775858+00:00 2023-05-02T23:11:03.822155+00:00 0:10:02.046297 371986 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T23:00:59.475777+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T23:00:39.754029+00:00 2023-05-02T23:00:40.659788+00:00 0:00:00.905759 371983 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T23:00:37.437047+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T22:00:00+00:00 PythonOperator 2023-05-02T23:00:18.670316+00:00 2023-05-02T23:00:19.686925+00:00 0:00:01.016609 371980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T23:00:15.421273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T21:00:00+00:00 TriggerDagRunOperator 2023-05-02T22:11:16.513035+00:00 2023-05-02T22:11:16.879186+00:00 0:00:00.366151 371963 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T22:11:13.777917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T21:00:00+00:00 TriggerDagRunOperator 2023-05-02T22:11:16.271120+00:00 2023-05-02T22:11:16.754339+00:00 0:00:00.483219 371962 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T22:11:13.777882+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T21:00:00+00:00 EmrJobFlowSensor 2023-05-02T22:01:01.653181+00:00 2023-05-02T22:11:03.623724+00:00 0:10:01.970543 371958 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T22:00:59.530665+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T22:00:41.661234+00:00 2023-05-02T22:00:42.553130+00:00 0:00:00.891896 371956 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T22:00:39.454609+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T21:00:00+00:00 PythonOperator 2023-05-02T22:00:19.846921+00:00 2023-05-02T22:00:20.799745+00:00 0:00:00.952824 371954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T22:00:17.488501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T20:00:00+00:00 TriggerDagRunOperator 2023-05-02T21:11:10.417976+00:00 2023-05-02T21:11:10.858333+00:00 0:00:00.440357 371939 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T21:11:08.109463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T20:00:00+00:00 TriggerDagRunOperator 2023-05-02T21:11:10.295932+00:00 2023-05-02T21:11:10.667691+00:00 0:00:00.371759 371938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T21:11:08.109499+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T20:00:00+00:00 EmrJobFlowSensor 2023-05-02T21:00:51.903315+00:00 2023-05-02T21:10:53.726174+00:00 0:10:01.822859 371931 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T21:00:49.793167+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T21:00:32.116593+00:00 2023-05-02T21:00:32.864138+00:00 0:00:00.747545 371929 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T21:00:29.803714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T20:00:00+00:00 PythonOperator 2023-05-02T21:00:10.460583+00:00 2023-05-02T21:00:11.424508+00:00 0:00:00.963925 371927 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T21:00:07.785069+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T19:00:00+00:00 TriggerDagRunOperator 2023-05-02T20:11:13.070620+00:00 2023-05-02T20:11:13.520587+00:00 0:00:00.449967 371913 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T20:11:10.417781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T19:00:00+00:00 TriggerDagRunOperator 2023-05-02T20:11:12.930190+00:00 2023-05-02T20:11:13.269226+00:00 0:00:00.339036 371912 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T20:11:10.417825+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T19:00:00+00:00 EmrJobFlowSensor 2023-05-02T20:00:53.164802+00:00 2023-05-02T20:10:55.073337+00:00 0:10:01.908535 371906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T20:00:50.612536+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T20:00:33.385526+00:00 2023-05-02T20:00:34.570113+00:00 0:00:01.184587 371904 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T20:00:30.518169+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T19:00:00+00:00 PythonOperator 2023-05-02T20:00:11.329506+00:00 2023-05-02T20:00:12.233293+00:00 0:00:00.903787 371902 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T20:00:08.436638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T18:00:00+00:00 TriggerDagRunOperator 2023-05-02T19:11:15.696741+00:00 2023-05-02T19:11:16.126413+00:00 0:00:00.429672 371887 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T19:11:13.317194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T18:00:00+00:00 TriggerDagRunOperator 2023-05-02T19:11:15.563187+00:00 2023-05-02T19:11:15.887631+00:00 0:00:00.324444 371886 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T19:11:13.317142+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T18:00:00+00:00 EmrJobFlowSensor 2023-05-02T19:00:59.131066+00:00 2023-05-02T19:11:00.974953+00:00 0:10:01.843887 371879 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T19:00:56.874222+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T19:00:39.212995+00:00 2023-05-02T19:00:40.090514+00:00 0:00:00.877519 371878 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T19:00:36.855289+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T18:00:00+00:00 PythonOperator 2023-05-02T19:00:15.643017+00:00 2023-05-02T19:00:16.490375+00:00 0:00:00.847358 371877 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T19:00:12.887212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T17:00:00+00:00 TriggerDagRunOperator 2023-05-02T18:14:58.768293+00:00 2023-05-02T18:14:59.176249+00:00 0:00:00.407956 371860 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T18:14:55.858492+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T17:00:00+00:00 TriggerDagRunOperator 2023-05-02T18:14:58.736639+00:00 2023-05-02T18:14:59.217026+00:00 0:00:00.480387 371859 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T18:14:55.858536+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T17:00:00+00:00 EmrJobFlowSensor 2023-05-02T18:01:36.150830+00:00 2023-05-02T18:11:38.070741+00:00 0:10:01.919911 371853 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T18:01:33.837302+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T18:01:16.041214+00:00 2023-05-02T18:01:16.775415+00:00 0:00:00.734201 371852 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T18:01:13.821346+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T17:00:00+00:00 PythonOperator 2023-05-02T18:00:54.495283+00:00 2023-05-02T18:00:55.431612+00:00 0:00:00.936329 371850 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T18:00:51.785068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T16:00:00+00:00 TriggerDagRunOperator 2023-05-02T17:26:20.641513+00:00 2023-05-02T17:26:21.075385+00:00 0:00:00.433872 371840 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T17:26:17.409922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T16:00:00+00:00 TriggerDagRunOperator 2023-05-02T17:26:20.550069+00:00 2023-05-02T17:26:20.892585+00:00 0:00:00.342516 371839 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T17:26:17.409966+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T16:00:00+00:00 EmrJobFlowSensor 2023-05-02T17:15:54.452582+00:00 2023-05-02T17:25:56.247397+00:00 0:10:01.794815 371834 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T17:15:52.272321+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T17:15:34.370141+00:00 2023-05-02T17:15:35.160288+00:00 0:00:00.790147 371831 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T17:15:32.249616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T16:00:00+00:00 PythonOperator 2023-05-02T17:15:13.141778+00:00 2023-05-02T17:15:14.028190+00:00 0:00:00.886412 371828 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T17:15:10.206063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T15:00:00+00:00 TriggerDagRunOperator 2023-05-02T16:10:57.446246+00:00 2023-05-02T16:10:57.887238+00:00 0:00:00.440992 371815 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T16:10:55.146428+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T15:00:00+00:00 TriggerDagRunOperator 2023-05-02T16:10:57.305959+00:00 2023-05-02T16:10:57.645006+00:00 0:00:00.339047 371814 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T16:10:55.146382+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T15:00:00+00:00 EmrJobFlowSensor 2023-05-02T16:00:48.336373+00:00 2023-05-02T16:10:50.218918+00:00 0:10:01.882545 371807 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T16:00:45.846882+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T16:00:26.901681+00:00 2023-05-02T16:00:27.718494+00:00 0:00:00.816813 371805 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T16:00:23.890956+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T15:00:00+00:00 PythonOperator 2023-05-02T16:00:06.210571+00:00 2023-05-02T16:00:07.105582+00:00 0:00:00.895011 371803 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T16:00:03.807467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T14:00:00+00:00 TriggerDagRunOperator 2023-05-02T15:12:02.597022+00:00 2023-05-02T15:12:02.957336+00:00 0:00:00.360314 371790 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T15:12:00.303346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T14:00:00+00:00 TriggerDagRunOperator 2023-05-02T15:12:02.595901+00:00 2023-05-02T15:12:03.054497+00:00 0:00:00.458596 371789 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T15:12:00.303373+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T14:00:00+00:00 EmrJobFlowSensor 2023-05-02T15:00:55.432878+00:00 2023-05-02T15:11:57.335083+00:00 0:11:01.902205 371782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T15:00:53.307383+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T15:00:33.774141+00:00 2023-05-02T15:00:34.686309+00:00 0:00:00.912168 371780 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T15:00:31.303974+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T14:00:00+00:00 PythonOperator 2023-05-02T15:00:14.080305+00:00 2023-05-02T15:00:14.994377+00:00 0:00:00.914072 371778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T15:00:11.420111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T13:00:00+00:00 TriggerDagRunOperator 2023-05-02T14:33:57.518388+00:00 2023-05-02T14:33:57.950252+00:00 0:00:00.431864 371769 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T14:33:55.001114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T13:00:00+00:00 TriggerDagRunOperator 2023-05-02T14:33:57.430304+00:00 2023-05-02T14:33:57.773796+00:00 0:00:00.343492 371768 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T14:33:55.001068+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T13:00:00+00:00 EmrJobFlowSensor 2023-05-02T14:33:35.338677+00:00 2023-05-02T14:33:35.971978+00:00 0:00:00.633301 371767 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T14:33:33.002306+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T14:00:46.258290+00:00 2023-05-02T14:00:47.013667+00:00 0:00:00.755377 371757 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T14:00:44.070154+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T13:00:00+00:00 PythonOperator 2023-05-02T14:00:25.076695+00:00 2023-05-02T14:00:26.270548+00:00 0:00:01.193853 371755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T14:00:22.051102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T12:00:00+00:00 TriggerDagRunOperator 2023-05-02T13:12:11.842396+00:00 2023-05-02T13:12:12.309302+00:00 0:00:00.466906 371741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T13:12:08.921706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T12:00:00+00:00 TriggerDagRunOperator 2023-05-02T13:12:11.750338+00:00 2023-05-02T13:12:12.078702+00:00 0:00:00.328364 371740 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T13:12:08.921677+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T12:00:00+00:00 EmrJobFlowSensor 2023-05-02T13:01:03.077741+00:00 2023-05-02T13:11:04.996054+00:00 0:10:01.918313 371733 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T13:01:00.736607+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T13:00:41.228282+00:00 2023-05-02T13:00:42.350237+00:00 0:00:01.121955 371731 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T13:00:38.808630+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T12:00:00+00:00 PythonOperator 2023-05-02T13:00:20.823994+00:00 2023-05-02T13:00:21.732516+00:00 0:00:00.908522 371729 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T13:00:18.661278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T11:00:00+00:00 TriggerDagRunOperator 2023-05-02T12:14:28.064728+00:00 2023-05-02T12:14:28.496943+00:00 0:00:00.432215 371717 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T12:14:25.350534+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T11:00:00+00:00 TriggerDagRunOperator 2023-05-02T12:14:27.941475+00:00 2023-05-02T12:14:28.279820+00:00 0:00:00.338345 371716 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T12:14:25.350565+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T11:00:00+00:00 EmrJobFlowSensor 2023-05-02T12:01:45.389658+00:00 2023-05-02T12:11:47.242409+00:00 0:10:01.852751 371709 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T12:01:43.202954+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T12:01:23.329816+00:00 2023-05-02T12:01:24.149848+00:00 0:00:00.820032 371707 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T12:01:21.149712+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T11:00:00+00:00 PythonOperator 2023-05-02T12:01:04.479129+00:00 2023-05-02T12:01:05.682180+00:00 0:00:01.203051 371705 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T12:01:01.100352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T10:00:00+00:00 TriggerDagRunOperator 2023-05-02T11:17:23.752927+00:00 2023-05-02T11:17:24.192611+00:00 0:00:00.439684 371696 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T11:17:20.710567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T10:00:00+00:00 TriggerDagRunOperator 2023-05-02T11:17:23.619463+00:00 2023-05-02T11:17:24.020472+00:00 0:00:00.401009 371695 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T11:17:20.710533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T10:00:00+00:00 EmrJobFlowSensor 2023-05-02T11:00:56.825711+00:00 2023-05-02T11:10:58.597023+00:00 0:10:01.771312 371687 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T11:00:54.724821+00:00 2 default_pool