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-06-20T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T10:00:44.726550+00:00 2023-06-20T10:00:45.812090+00:00 0:00:01.085540 394951 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T10:00:42.740250+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T09:00:00+00:00 PythonOperator 2023-06-20T10:00:22.848003+00:00 2023-06-20T10:00:23.750897+00:00 0:00:00.902894 394949 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T10:00:20.698671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T08:00:00+00:00 EmrJobFlowSensor 2023-06-20T09:40:18.860524+00:00 2023-06-20T09:53:21.234505+00:00 0:13:02.373981 394945 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T09:40:16.707248+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T09:39:58.739432+00:00 2023-06-20T09:39:59.664513+00:00 0:00:00.925081 394944 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T09:39:56.686694+00:00 3 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T08:00:00+00:00 PythonOperator 2023-06-20T09:39:36.930341+00:00 2023-06-20T09:39:37.925386+00:00 0:00:00.995045 394943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T09:39:34.673549+00:00 3 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T08:00:00+00:00 TriggerDagRunOperator 2023-06-20T09:11:09.287501+00:00 2023-06-20T09:11:09.742085+00:00 0:00:00.454584 394936 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T09:11:06.654458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T08:00:00+00:00 TriggerDagRunOperator 2023-06-20T09:11:08.947126+00:00 2023-06-20T09:11:09.373127+00:00 0:00:00.426001 394935 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T09:11:06.654422+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T07:00:00+00:00 TriggerDagRunOperator 2023-06-20T08:11:32.553324+00:00 2023-06-20T08:11:33.024478+00:00 0:00:00.471154 394913 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T08:11:29.943832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T07:00:00+00:00 TriggerDagRunOperator 2023-06-20T08:11:32.306457+00:00 2023-06-20T08:11:32.715797+00:00 0:00:00.409340 394912 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T08:11:29.943883+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T07:00:00+00:00 EmrJobFlowSensor 2023-06-20T08:00:45.779964+00:00 2023-06-20T08:10:47.615178+00:00 0:10:01.835214 394904 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T08:00:43.756172+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T08:00:25.856990+00:00 2023-06-20T08:00:26.856727+00:00 0:00:00.999737 394902 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T08:00:23.738757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T07:00:00+00:00 PythonOperator 2023-06-20T08:00:04.167212+00:00 2023-06-20T08:00:05.128718+00:00 0:00:00.961506 394900 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T08:00:01.741111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T06:00:00+00:00 TriggerDagRunOperator 2023-06-20T07:11:01.207974+00:00 2023-06-20T07:11:01.673940+00:00 0:00:00.465966 394888 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T07:10:58.750076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T06:00:00+00:00 TriggerDagRunOperator 2023-06-20T07:11:01.209160+00:00 2023-06-20T07:11:01.680713+00:00 0:00:00.471553 394887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T07:10:58.750049+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T06:00:00+00:00 EmrJobFlowSensor 2023-06-20T07:00:51.534764+00:00 2023-06-20T07:10:53.343032+00:00 0:10:01.808268 394879 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T07:00:49.439611+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T07:00:29.766856+00:00 2023-06-20T07:00:30.821423+00:00 0:00:01.054567 394877 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T07:00:27.435489+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T06:00:00+00:00 PythonOperator 2023-06-20T07:00:09.760581+00:00 2023-06-20T07:00:10.756115+00:00 0:00:00.995534 394875 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T07:00:07.366721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T05:00:00+00:00 TriggerDagRunOperator 2023-06-20T06:11:26.242624+00:00 2023-06-20T06:11:26.687756+00:00 0:00:00.445132 394864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T06:11:23.405347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T05:00:00+00:00 TriggerDagRunOperator 2023-06-20T06:11:25.737146+00:00 2023-06-20T06:11:26.255267+00:00 0:00:00.518121 394863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T06:11:23.405387+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T05:00:00+00:00 EmrJobFlowSensor 2023-06-20T06:00:47.498432+00:00 2023-06-20T06:10:49.264243+00:00 0:10:01.765811 394855 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T06:00:45.437761+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T06:00:27.751305+00:00 2023-06-20T06:00:28.783588+00:00 0:00:01.032283 394853 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T06:00:25.429120+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T05:00:00+00:00 PythonOperator 2023-06-20T06:00:05.874465+00:00 2023-06-20T06:00:06.916543+00:00 0:00:01.042078 394851 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T06:00:03.354322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T04:00:00+00:00 TriggerDagRunOperator 2023-06-20T05:11:18.412650+00:00 2023-06-20T05:11:18.860247+00:00 0:00:00.447597 394840 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T05:11:16.071505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T04:00:00+00:00 TriggerDagRunOperator 2023-06-20T05:11:18.159258+00:00 2023-06-20T05:11:18.561428+00:00 0:00:00.402170 394839 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T05:11:16.071532+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T04:00:00+00:00 EmrJobFlowSensor 2023-06-20T05:01:00.403318+00:00 2023-06-20T05:11:02.212961+00:00 0:10:01.809643 394832 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T05:00:58.213691+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T05:00:38.237453+00:00 2023-06-20T05:00:39.154095+00:00 0:00:00.916642 394830 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T05:00:36.235213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T04:00:00+00:00 PythonOperator 2023-06-20T05:00:16.546643+00:00 2023-06-20T05:00:17.519073+00:00 0:00:00.972430 394828 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T05:00:14.225807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T03:00:00+00:00 TriggerDagRunOperator 2023-06-20T04:11:46.063586+00:00 2023-06-20T04:11:46.570212+00:00 0:00:00.506626 394816 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T04:11:43.568675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T03:00:00+00:00 TriggerDagRunOperator 2023-06-20T04:11:45.682702+00:00 2023-06-20T04:11:46.116482+00:00 0:00:00.433780 394815 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T04:11:43.568649+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T03:00:00+00:00 EmrJobFlowSensor 2023-06-20T04:01:04.610777+00:00 2023-06-20T04:11:06.664197+00:00 0:10:02.053420 394808 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T04:01:02.235963+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T04:00:42.672978+00:00 2023-06-20T04:00:43.650449+00:00 0:00:00.977471 394806 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T04:00:40.160459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T03:00:00+00:00 PythonOperator 2023-06-20T04:00:22.157612+00:00 2023-06-20T04:00:23.007734+00:00 0:00:00.850122 394804 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T04:00:20.145993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T02:00:00+00:00 TriggerDagRunOperator 2023-06-20T03:11:20.033580+00:00 2023-06-20T03:11:20.497322+00:00 0:00:00.463742 394793 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T03:11:17.524191+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T02:00:00+00:00 TriggerDagRunOperator 2023-06-20T03:11:19.712697+00:00 2023-06-20T03:11:20.136831+00:00 0:00:00.424134 394792 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T03:11:17.524165+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T02:00:00+00:00 EmrJobFlowSensor 2023-06-20T03:01:02.723184+00:00 2023-06-20T03:11:04.726796+00:00 0:10:02.003612 394784 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T03:01:00.574872+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T03:00:40.999734+00:00 2023-06-20T03:00:42.128601+00:00 0:00:01.128867 394782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T03:00:38.623864+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T02:00:00+00:00 PythonOperator 2023-06-20T03:00:18.876709+00:00 2023-06-20T03:00:19.777977+00:00 0:00:00.901268 394780 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T03:00:16.546630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T01:00:00+00:00 TriggerDagRunOperator 2023-06-20T02:11:16.638058+00:00 2023-06-20T02:11:17.120222+00:00 0:00:00.482164 394769 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T02:11:14.255963+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T01:00:00+00:00 TriggerDagRunOperator 2023-06-20T02:11:16.418863+00:00 2023-06-20T02:11:16.810323+00:00 0:00:00.391460 394768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T02:11:14.255990+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T01:00:00+00:00 EmrJobFlowSensor 2023-06-20T02:01:06.169107+00:00 2023-06-20T02:11:07.948227+00:00 0:10:01.779120 394761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T02:01:04.083158+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T02:00:46.376299+00:00 2023-06-20T02:00:47.330660+00:00 0:00:00.954361 394759 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T02:00:44.064924+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T01:00:00+00:00 PythonOperator 2023-06-20T02:00:24.321407+00:00 2023-06-20T02:00:25.171274+00:00 0:00:00.849867 394757 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T02:00:22.047252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-20T00:00:00+00:00 TriggerDagRunOperator 2023-06-20T01:11:18.542279+00:00 2023-06-20T01:11:19.029989+00:00 0:00:00.487710 394736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T01:11:16.383547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-20T00:00:00+00:00 TriggerDagRunOperator 2023-06-20T01:11:18.253395+00:00 2023-06-20T01:11:18.661631+00:00 0:00:00.408236 394735 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T01:11:16.383574+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-20T00:00:00+00:00 EmrJobFlowSensor 2023-06-20T01:01:03.859628+00:00 2023-06-20T01:11:05.878319+00:00 0:10:02.018691 394729 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T01:01:01.631345+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-20T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T01:00:43.538861+00:00 2023-06-20T01:00:44.411124+00:00 0:00:00.872263 394727 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T01:00:41.611584+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-20T00:00:00+00:00 PythonOperator 2023-06-20T01:00:21.949183+00:00 2023-06-20T01:00:22.800898+00:00 0:00:00.851715 394725 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T01:00:19.596019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T23:00:00+00:00 TriggerDagRunOperator 2023-06-20T00:11:01.898530+00:00 2023-06-20T00:11:02.352575+00:00 0:00:00.454045 394713 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T00:10:59.585148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T23:00:00+00:00 TriggerDagRunOperator 2023-06-20T00:11:01.442428+00:00 2023-06-20T00:11:01.838768+00:00 0:00:00.396340 394712 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-20T00:10:59.585201+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T23:00:00+00:00 EmrJobFlowSensor 2023-06-20T00:00:47.963018+00:00 2023-06-20T00:10:49.745591+00:00 0:10:01.782573 394705 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-20T00:00:46.057106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-20T00:00:25.980841+00:00 2023-06-20T00:00:26.877146+00:00 0:00:00.896305 394703 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-20T00:00:24.033394+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T23:00:00+00:00 PythonOperator 2023-06-20T00:00:04.756248+00:00 2023-06-20T00:00:05.822393+00:00 0:00:01.066145 394701 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-20T00:00:02.043188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T22:00:00+00:00 TriggerDagRunOperator 2023-06-19T23:11:12.115915+00:00 2023-06-19T23:11:12.693334+00:00 0:00:00.577419 394688 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T23:11:09.888852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T22:00:00+00:00 TriggerDagRunOperator 2023-06-19T23:11:11.724867+00:00 2023-06-19T23:11:12.137744+00:00 0:00:00.412877 394687 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T23:11:09.888819+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T22:00:00+00:00 EmrJobFlowSensor 2023-06-19T23:00:51.623797+00:00 2023-06-19T23:10:53.517591+00:00 0:10:01.893794 394680 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T23:00:49.334113+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T23:00:29.236287+00:00 2023-06-19T23:00:30.131016+00:00 0:00:00.894729 394676 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T23:00:27.314964+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T22:00:00+00:00 PythonOperator 2023-06-19T23:00:09.854750+00:00 2023-06-19T23:00:10.824804+00:00 0:00:00.970054 394674 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T23:00:07.295356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T21:00:00+00:00 TriggerDagRunOperator 2023-06-19T22:11:29.074087+00:00 2023-06-19T22:11:29.551535+00:00 0:00:00.477448 394660 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T22:11:26.749771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T21:00:00+00:00 TriggerDagRunOperator 2023-06-19T22:11:28.737259+00:00 2023-06-19T22:11:29.190897+00:00 0:00:00.453638 394659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T22:11:26.749741+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T21:00:00+00:00 EmrJobFlowSensor 2023-06-19T22:01:04.399875+00:00 2023-06-19T22:11:06.443223+00:00 0:10:02.043348 394653 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T22:01:02.070297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T22:00:44.270760+00:00 2023-06-19T22:00:45.258863+00:00 0:00:00.988103 394651 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T22:00:42.055654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T21:00:00+00:00 PythonOperator 2023-06-19T22:00:22.247244+00:00 2023-06-19T22:00:23.392374+00:00 0:00:01.145130 394649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T22:00:20.029257+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T20:00:00+00:00 TriggerDagRunOperator 2023-06-19T21:11:20.010224+00:00 2023-06-19T21:11:20.469733+00:00 0:00:00.459509 394637 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T21:11:17.749395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T20:00:00+00:00 TriggerDagRunOperator 2023-06-19T21:11:19.712207+00:00 2023-06-19T21:11:20.136390+00:00 0:00:00.424183 394636 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T21:11:17.749428+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T20:00:00+00:00 EmrJobFlowSensor 2023-06-19T21:00:58.770476+00:00 2023-06-19T21:11:00.617245+00:00 0:10:01.846769 394630 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T21:00:56.786358+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T21:00:36.940978+00:00 2023-06-19T21:00:37.846155+00:00 0:00:00.905177 394628 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T21:00:34.765463+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T20:00:00+00:00 PythonOperator 2023-06-19T21:00:16.672915+00:00 2023-06-19T21:00:17.561141+00:00 0:00:00.888226 394626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T21:00:14.749596+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T19:00:00+00:00 TriggerDagRunOperator 2023-06-19T20:11:00.096891+00:00 2023-06-19T20:11:00.562392+00:00 0:00:00.465501 394613 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T20:10:57.854390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T19:00:00+00:00 TriggerDagRunOperator 2023-06-19T20:10:59.743746+00:00 2023-06-19T20:11:00.221534+00:00 0:00:00.477788 394612 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T20:10:57.854361+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T19:00:00+00:00 EmrJobFlowSensor 2023-06-19T20:00:50.463645+00:00 2023-06-19T20:10:52.037457+00:00 0:10:01.573812 394605 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T20:00:48.558559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T20:00:30.741844+00:00 2023-06-19T20:00:31.784406+00:00 0:00:01.042562 394603 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T20:00:28.538899+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T19:00:00+00:00 PythonOperator 2023-06-19T20:00:08.780425+00:00 2023-06-19T20:00:09.637270+00:00 0:00:00.856845 394601 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T20:00:06.519704+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T18:00:00+00:00 TriggerDagRunOperator 2023-06-19T19:11:02.899318+00:00 2023-06-19T19:11:03.377149+00:00 0:00:00.477831 394587 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T19:11:00.723675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T18:00:00+00:00 TriggerDagRunOperator 2023-06-19T19:11:02.617590+00:00 2023-06-19T19:11:03.037184+00:00 0:00:00.419594 394586 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T19:11:00.723645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T18:00:00+00:00 EmrJobFlowSensor 2023-06-19T19:00:47.162612+00:00 2023-06-19T19:10:48.762184+00:00 0:10:01.599572 394579 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T19:00:45.240483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T19:00:25.490348+00:00 2023-06-19T19:00:26.469947+00:00 0:00:00.979599 394578 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T19:00:23.221514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T18:00:00+00:00 PythonOperator 2023-06-19T19:00:05.432169+00:00 2023-06-19T19:00:06.315315+00:00 0:00:00.883146 394576 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T19:00:03.203432+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T17:00:00+00:00 TriggerDagRunOperator 2023-06-19T18:11:11.324102+00:00 2023-06-19T18:11:11.767305+00:00 0:00:00.443203 394563 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T18:11:09.095584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T17:00:00+00:00 TriggerDagRunOperator 2023-06-19T18:11:11.137814+00:00 2023-06-19T18:11:11.544618+00:00 0:00:00.406804 394562 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T18:11:09.095555+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T17:00:00+00:00 EmrJobFlowSensor 2023-06-19T18:01:01.152601+00:00 2023-06-19T18:11:02.994598+00:00 0:10:01.841997 394555 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T18:00:59.249467+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T18:00:39.156342+00:00 2023-06-19T18:00:40.113582+00:00 0:00:00.957240 394554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T18:00:37.227545+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T17:00:00+00:00 PythonOperator 2023-06-19T18:00:19.173485+00:00 2023-06-19T18:00:20.021203+00:00 0:00:00.847718 394553 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T18:00:17.209401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T16:00:00+00:00 TriggerDagRunOperator 2023-06-19T17:11:22.324642+00:00 2023-06-19T17:11:22.803769+00:00 0:00:00.479127 394541 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T17:11:20.038319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T16:00:00+00:00 TriggerDagRunOperator 2023-06-19T17:11:22.067111+00:00 2023-06-19T17:11:22.467649+00:00 0:00:00.400538 394540 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T17:11:20.038349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T16:00:00+00:00 EmrJobFlowSensor 2023-06-19T17:01:02.181704+00:00 2023-06-19T17:11:03.936149+00:00 0:10:01.754445 394531 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T17:01:00.211977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T17:00:42.594359+00:00 2023-06-19T17:00:43.601177+00:00 0:00:01.006818 394530 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T17:00:40.193389+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T16:00:00+00:00 PythonOperator 2023-06-19T17:00:20.424280+00:00 2023-06-19T17:00:21.448180+00:00 0:00:01.023900 394529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T17:00:18.174693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T15:00:00+00:00 TriggerDagRunOperator 2023-06-19T16:11:13.805479+00:00 2023-06-19T16:11:14.272336+00:00 0:00:00.466857 394517 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T16:11:11.604234+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T15:00:00+00:00 TriggerDagRunOperator 2023-06-19T16:11:13.520324+00:00 2023-06-19T16:11:13.919981+00:00 0:00:00.399657 394516 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T16:11:11.604268+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T15:00:00+00:00 EmrJobFlowSensor 2023-06-19T16:00:48.551658+00:00 2023-06-19T16:10:50.318218+00:00 0:10:01.766560 394509 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T16:00:46.621538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T16:00:26.655289+00:00 2023-06-19T16:00:27.541994+00:00 0:00:00.886705 394507 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T16:00:24.643849+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T15:00:00+00:00 PythonOperator 2023-06-19T16:00:04.871023+00:00 2023-06-19T16:00:05.777169+00:00 0:00:00.906146 394505 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T16:00:02.630431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T14:00:00+00:00 TriggerDagRunOperator 2023-06-19T15:12:48.590134+00:00 2023-06-19T15:12:49.121599+00:00 0:00:00.531465 394496 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T15:12:45.950241+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T14:00:00+00:00 TriggerDagRunOperator 2023-06-19T15:12:48.309743+00:00 2023-06-19T15:12:48.706948+00:00 0:00:00.397205 394495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T15:12:45.950214+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T14:00:00+00:00 EmrJobFlowSensor 2023-06-19T15:01:37.559125+00:00 2023-06-19T15:12:39.927361+00:00 0:11:02.368236 394489 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T15:01:35.297148+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-19T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-19T15:01:15.689773+00:00 2023-06-19T15:01:16.718975+00:00 0:00:01.029202 394487 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-19T15:01:13.273882+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-19T14:00:00+00:00 PythonOperator 2023-06-19T15:00:55.186392+00:00 2023-06-19T15:00:56.072540+00:00 0:00:00.886148 394485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-19T15:00:53.259895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-19T13:00:00+00:00 TriggerDagRunOperator 2023-06-19T14:17:32.242598+00:00 2023-06-19T14:17:32.688740+00:00 0:00:00.446142 394475 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T14:17:29.815993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-19T13:00:00+00:00 TriggerDagRunOperator 2023-06-19T14:17:31.943365+00:00 2023-06-19T14:17:32.335219+00:00 0:00:00.391854 394474 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-19T14:17:29.815965+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-19T13:00:00+00:00 EmrJobFlowSensor 2023-06-19T14:00:53.785955+00:00 2023-06-19T14:10:55.568560+00:00 0:10:01.782605 394467 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-19T14:00:51.869613+00:00 2 default_pool