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-19T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T03:02:55.173908+00:00 2023-05-19T03:02:56.247006+00:00 0:00:01.073098 381876 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T03:02:52.819057+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T02:00:00+00:00 PythonOperator 2023-05-19T03:02:34.408403+00:00 2023-05-19T03:02:35.358412+00:00 0:00:00.950009 381874 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T03:02:30.815503+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T01:00:00+00:00 TriggerDagRunOperator 2023-05-19T02:12:36.923799+00:00 2023-05-19T02:12:37.379988+00:00 0:00:00.456189 381863 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T02:12:34.101049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T01:00:00+00:00 TriggerDagRunOperator 2023-05-19T02:12:36.911621+00:00 2023-05-19T02:12:37.383933+00:00 0:00:00.472312 381862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T02:12:34.101005+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T01:00:00+00:00 EmrJobFlowSensor 2023-05-19T02:02:09.678563+00:00 2023-05-19T02:12:11.618678+00:00 0:10:01.940115 381855 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T02:02:07.361301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T02:01:49.929778+00:00 2023-05-19T02:01:51.263716+00:00 0:00:01.333938 381853 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T02:01:47.335276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T01:00:00+00:00 PythonOperator 2023-05-19T02:00:18.811416+00:00 2023-05-19T02:00:19.946007+00:00 0:00:01.134591 381851 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T02:00:16.442402+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-19T00:00:00+00:00 TriggerDagRunOperator 2023-05-19T01:10:53.570540+00:00 2023-05-19T01:10:54.218070+00:00 0:00:00.647530 381830 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T01:10:50.194232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-19T00:00:00+00:00 TriggerDagRunOperator 2023-05-19T01:10:53.278711+00:00 2023-05-19T01:10:53.768869+00:00 0:00:00.490158 381829 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T01:10:50.194271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-19T00:00:00+00:00 EmrJobFlowSensor 2023-05-19T01:01:39.683437+00:00 2023-05-19T01:10:41.449870+00:00 0:09:01.766433 381823 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T01:01:37.380577+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-19T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T01:00:32.462277+00:00 2023-05-19T01:00:33.508031+00:00 0:00:01.045754 381820 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T01:00:30.086638+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-19T00:00:00+00:00 PythonOperator 2023-05-19T01:00:10.597337+00:00 2023-05-19T01:00:11.709584+00:00 0:00:01.112247 381818 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T01:00:07.908036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T23:00:00+00:00 TriggerDagRunOperator 2023-05-19T00:11:10.459973+00:00 2023-05-19T00:11:10.949972+00:00 0:00:00.489999 381804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T00:11:07.647276+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T23:00:00+00:00 TriggerDagRunOperator 2023-05-19T00:11:10.402823+00:00 2023-05-19T00:11:10.858895+00:00 0:00:00.456072 381803 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-19T00:11:07.647247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T23:00:00+00:00 EmrJobFlowSensor 2023-05-19T00:01:44.187589+00:00 2023-05-19T00:10:46.032283+00:00 0:09:01.844694 381796 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-19T00:01:41.807003+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-19T00:00:33.459849+00:00 2023-05-19T00:00:34.440493+00:00 0:00:00.980644 381794 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-19T00:00:31.011437+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T23:00:00+00:00 PythonOperator 2023-05-19T00:00:11.622480+00:00 2023-05-19T00:00:12.610255+00:00 0:00:00.987775 381792 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-19T00:00:08.995586+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T22:00:00+00:00 TriggerDagRunOperator 2023-05-18T23:11:54.352126+00:00 2023-05-18T23:11:54.835308+00:00 0:00:00.483182 381776 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T23:11:51.873191+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T22:00:00+00:00 TriggerDagRunOperator 2023-05-18T23:11:54.237543+00:00 2023-05-18T23:11:54.744292+00:00 0:00:00.506749 381775 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T23:11:51.873219+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T22:00:00+00:00 EmrJobFlowSensor 2023-05-18T23:01:39.187919+00:00 2023-05-18T23:11:41.507849+00:00 0:10:02.319930 381768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T23:01:36.726003+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T23:01:18.932356+00:00 2023-05-18T23:01:19.915377+00:00 0:00:00.983021 381765 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T23:01:16.705965+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T22:00:00+00:00 PythonOperator 2023-05-18T23:00:14.469082+00:00 2023-05-18T23:00:15.581560+00:00 0:00:01.112478 381760 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T23:00:11.801983+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T21:00:00+00:00 TriggerDagRunOperator 2023-05-18T22:10:33.688539+00:00 2023-05-18T22:10:34.135766+00:00 0:00:00.447227 381747 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T22:10:30.611009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T21:00:00+00:00 TriggerDagRunOperator 2023-05-18T22:10:33.632123+00:00 2023-05-18T22:10:34.108594+00:00 0:00:00.476471 381746 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T22:10:30.610964+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T21:00:00+00:00 EmrJobFlowSensor 2023-05-18T22:01:10.569154+00:00 2023-05-18T22:10:12.380730+00:00 0:09:01.811576 381739 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T22:01:08.325446+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T22:00:30.340351+00:00 2023-05-18T22:00:31.206398+00:00 0:00:00.866047 381736 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T22:00:27.865841+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T21:00:00+00:00 PythonOperator 2023-05-18T22:00:10.569300+00:00 2023-05-18T22:00:11.697243+00:00 0:00:01.127943 381734 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T22:00:07.907992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T20:00:00+00:00 TriggerDagRunOperator 2023-05-18T21:13:30.820084+00:00 2023-05-18T21:13:31.297160+00:00 0:00:00.477076 381721 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T21:13:28.457773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T20:00:00+00:00 TriggerDagRunOperator 2023-05-18T21:13:30.740475+00:00 2023-05-18T21:13:31.257934+00:00 0:00:00.517459 381720 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T21:13:28.457718+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T20:00:00+00:00 EmrJobFlowSensor 2023-05-18T21:13:09.425535+00:00 2023-05-18T21:13:10.053348+00:00 0:00:00.627813 381718 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T21:13:06.503231+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T21:01:30.191694+00:00 2023-05-18T21:01:31.193863+00:00 0:00:01.002169 381710 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T21:01:27.504208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T20:00:00+00:00 PythonOperator 2023-05-18T21:00:16.440240+00:00 2023-05-18T21:00:17.459077+00:00 0:00:01.018837 381707 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T21:00:14.022293+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T19:00:00+00:00 TriggerDagRunOperator 2023-05-18T20:10:33.223219+00:00 2023-05-18T20:10:33.702986+00:00 0:00:00.479767 381693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T20:10:30.182643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T19:00:00+00:00 TriggerDagRunOperator 2023-05-18T20:10:33.098362+00:00 2023-05-18T20:10:33.635151+00:00 0:00:00.536789 381692 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T20:10:30.182684+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T19:00:00+00:00 EmrJobFlowSensor 2023-05-18T20:01:17.168158+00:00 2023-05-18T20:10:19.008836+00:00 0:09:01.840678 381686 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T20:01:14.118687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T20:00:25.939859+00:00 2023-05-18T20:00:26.824206+00:00 0:00:00.884347 381682 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T20:00:23.502859+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T19:00:00+00:00 PythonOperator 2023-05-18T20:00:03.969063+00:00 2023-05-18T20:00:04.895243+00:00 0:00:00.926180 381680 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T20:00:01.413046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T18:00:00+00:00 TriggerDagRunOperator 2023-05-18T19:11:33.250162+00:00 2023-05-18T19:11:33.631786+00:00 0:00:00.381624 381664 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T19:11:30.748005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T18:00:00+00:00 TriggerDagRunOperator 2023-05-18T19:11:32.991701+00:00 2023-05-18T19:11:33.455824+00:00 0:00:00.464123 381663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T19:11:30.748032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T18:00:00+00:00 EmrJobFlowSensor 2023-05-18T19:01:22.260265+00:00 2023-05-18T19:11:24.180008+00:00 0:10:01.919743 381656 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T19:01:19.917130+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T19:00:34.453883+00:00 2023-05-18T19:00:35.459381+00:00 0:00:01.005498 381654 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T19:00:31.981483+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T18:00:00+00:00 PythonOperator 2023-05-18T19:00:12.557418+00:00 2023-05-18T19:00:13.634545+00:00 0:00:01.077127 381652 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T19:00:09.893777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T17:00:00+00:00 TriggerDagRunOperator 2023-05-18T18:11:58.103324+00:00 2023-05-18T18:11:58.623383+00:00 0:00:00.520059 381637 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T18:11:55.783739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T17:00:00+00:00 TriggerDagRunOperator 2023-05-18T18:11:58.056136+00:00 2023-05-18T18:11:58.650368+00:00 0:00:00.594232 381636 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T18:11:55.783708+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T17:00:00+00:00 EmrJobFlowSensor 2023-05-18T18:01:39.496767+00:00 2023-05-18T18:11:41.619631+00:00 0:10:02.122864 381629 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T18:01:36.915672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T18:01:17.965384+00:00 2023-05-18T18:01:18.900326+00:00 0:00:00.934942 381628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T18:01:15.010207+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T17:00:00+00:00 PythonOperator 2023-05-18T18:00:19.150830+00:00 2023-05-18T18:00:20.244942+00:00 0:00:01.094112 381626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T18:00:16.686343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T16:00:00+00:00 TriggerDagRunOperator 2023-05-18T17:11:10.237438+00:00 2023-05-18T17:11:10.719571+00:00 0:00:00.482133 381612 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T17:11:07.791033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T16:00:00+00:00 TriggerDagRunOperator 2023-05-18T17:11:10.154623+00:00 2023-05-18T17:11:10.480685+00:00 0:00:00.326062 381611 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T17:11:07.791063+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T16:00:00+00:00 EmrJobFlowSensor 2023-05-18T17:00:59.978391+00:00 2023-05-18T17:11:02.222974+00:00 0:10:02.244583 381601 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T17:00:57.575721+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T17:00:39.863189+00:00 2023-05-18T17:00:40.791602+00:00 0:00:00.928413 381600 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T17:00:37.554855+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T16:00:00+00:00 PythonOperator 2023-05-18T17:00:17.986410+00:00 2023-05-18T17:00:19.105666+00:00 0:00:01.119256 381599 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T17:00:15.542755+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T15:00:00+00:00 TriggerDagRunOperator 2023-05-18T16:11:20.143939+00:00 2023-05-18T16:11:20.645071+00:00 0:00:00.501132 381586 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T16:11:17.604612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T15:00:00+00:00 TriggerDagRunOperator 2023-05-18T16:11:20.108582+00:00 2023-05-18T16:11:20.589607+00:00 0:00:00.481025 381585 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T16:11:17.604582+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T15:00:00+00:00 EmrJobFlowSensor 2023-05-18T16:00:53.402598+00:00 2023-05-18T16:10:55.415766+00:00 0:10:02.013168 381578 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T16:00:50.215405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T16:00:31.115232+00:00 2023-05-18T16:00:32.064155+00:00 0:00:00.948923 381576 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T16:00:28.116211+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T15:00:00+00:00 PythonOperator 2023-05-18T16:00:10.417091+00:00 2023-05-18T16:00:11.513143+00:00 0:00:01.096052 381574 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T16:00:08.040658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T14:00:00+00:00 TriggerDagRunOperator 2023-05-18T15:12:52.743453+00:00 2023-05-18T15:12:53.199236+00:00 0:00:00.455783 381562 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T15:12:49.999147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T14:00:00+00:00 TriggerDagRunOperator 2023-05-18T15:12:52.748290+00:00 2023-05-18T15:12:53.222048+00:00 0:00:00.473758 381561 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T15:12:49.999118+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T14:00:00+00:00 EmrJobFlowSensor 2023-05-18T15:00:49.140165+00:00 2023-05-18T15:10:51.110925+00:00 0:10:01.970760 381554 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T15:00:46.600484+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T15:00:29.083899+00:00 2023-05-18T15:00:30.163022+00:00 0:00:01.079123 381552 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T15:00:26.598342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T14:00:00+00:00 PythonOperator 2023-05-18T15:00:06.915434+00:00 2023-05-18T15:00:08.047400+00:00 0:00:01.131966 381550 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T15:00:04.532449+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T13:00:00+00:00 TriggerDagRunOperator 2023-05-18T14:11:10.936851+00:00 2023-05-18T14:11:11.376643+00:00 0:00:00.439792 381537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T14:11:08.483873+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T13:00:00+00:00 TriggerDagRunOperator 2023-05-18T14:11:10.795734+00:00 2023-05-18T14:11:11.294401+00:00 0:00:00.498667 381536 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T14:11:08.483838+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T13:00:00+00:00 EmrJobFlowSensor 2023-05-18T14:01:03.877902+00:00 2023-05-18T14:11:05.859284+00:00 0:10:01.981382 381529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T14:01:01.412420+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T14:00:41.667977+00:00 2023-05-18T14:00:42.605596+00:00 0:00:00.937619 381527 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T14:00:39.363284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T13:00:00+00:00 PythonOperator 2023-05-18T14:00:21.839395+00:00 2023-05-18T14:00:22.963248+00:00 0:00:01.123853 381525 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T14:00:19.348990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T12:00:00+00:00 TriggerDagRunOperator 2023-05-18T13:11:02.702413+00:00 2023-05-18T13:11:03.146624+00:00 0:00:00.444211 381510 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T13:11:00.133077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T12:00:00+00:00 TriggerDagRunOperator 2023-05-18T13:11:02.611714+00:00 2023-05-18T13:11:03.083262+00:00 0:00:00.471548 381509 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T13:11:00.133034+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T12:00:00+00:00 EmrJobFlowSensor 2023-05-18T13:00:56.083681+00:00 2023-05-18T13:10:58.071185+00:00 0:10:01.987504 381502 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T13:00:53.626962+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T13:00:35.841734+00:00 2023-05-18T13:00:36.721724+00:00 0:00:00.879990 381500 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T13:00:33.569376+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T12:00:00+00:00 PythonOperator 2023-05-18T13:00:14.168477+00:00 2023-05-18T13:00:16.485250+00:00 0:00:02.316773 381498 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T13:00:11.550274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T11:00:00+00:00 TriggerDagRunOperator 2023-05-18T12:12:05.370543+00:00 2023-05-18T12:12:05.851320+00:00 0:00:00.480777 381484 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T12:12:02.636515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T11:00:00+00:00 TriggerDagRunOperator 2023-05-18T12:12:05.111631+00:00 2023-05-18T12:12:05.567849+00:00 0:00:00.456218 381483 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T12:12:02.636486+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T11:00:00+00:00 EmrJobFlowSensor 2023-05-18T12:01:43.698101+00:00 2023-05-18T12:11:45.731055+00:00 0:10:02.032954 381476 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T12:01:41.183374+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T12:01:21.726451+00:00 2023-05-18T12:01:22.689401+00:00 0:00:00.962950 381474 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T12:01:19.201189+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T11:00:00+00:00 PythonOperator 2023-05-18T12:01:00.341392+00:00 2023-05-18T12:01:01.432082+00:00 0:00:01.090690 381472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T12:00:57.358385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T10:00:00+00:00 TriggerDagRunOperator 2023-05-18T11:11:17.428254+00:00 2023-05-18T11:11:17.898083+00:00 0:00:00.469829 381459 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T11:11:14.936893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T10:00:00+00:00 TriggerDagRunOperator 2023-05-18T11:11:17.306397+00:00 2023-05-18T11:11:17.641524+00:00 0:00:00.335127 381458 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T11:11:14.936921+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T10:00:00+00:00 EmrJobFlowSensor 2023-05-18T11:01:05.335453+00:00 2023-05-18T11:11:07.113146+00:00 0:10:01.777693 381451 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T11:01:03.080173+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T11:00:43.229561+00:00 2023-05-18T11:00:44.132790+00:00 0:00:00.903229 381449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T11:00:41.038259+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T10:00:00+00:00 PythonOperator 2023-05-18T11:00:23.477692+00:00 2023-05-18T11:00:24.669779+00:00 0:00:01.192087 381447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T11:00:21.096688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T09:00:00+00:00 TriggerDagRunOperator 2023-05-18T10:17:11.018063+00:00 2023-05-18T10:17:11.454785+00:00 0:00:00.436722 381435 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T10:17:08.313964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T09:00:00+00:00 TriggerDagRunOperator 2023-05-18T10:17:11.034059+00:00 2023-05-18T10:17:11.561038+00:00 0:00:00.526979 381434 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T10:17:08.313922+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T09:00:00+00:00 EmrJobFlowSensor 2023-05-18T10:06:48.186470+00:00 2023-05-18T10:16:50.406812+00:00 0:10:02.220342 381430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T10:06:45.884398+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T10:06:26.034995+00:00 2023-05-18T10:06:26.902782+00:00 0:00:00.867787 381427 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T10:06:23.861942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T09:00:00+00:00 PythonOperator 2023-05-18T10:06:06.310227+00:00 2023-05-18T10:06:07.454778+00:00 0:00:01.144551 381424 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T10:06:03.801790+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T08:00:00+00:00 TriggerDagRunOperator 2023-05-18T09:11:41.270091+00:00 2023-05-18T09:11:41.754598+00:00 0:00:00.484507 381411 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T09:11:38.030718+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T08:00:00+00:00 TriggerDagRunOperator 2023-05-18T09:11:41.018525+00:00 2023-05-18T09:11:41.356065+00:00 0:00:00.337540 381410 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T09:11:38.030750+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T08:00:00+00:00 EmrJobFlowSensor 2023-05-18T09:00:53.404592+00:00 2023-05-18T09:10:55.262812+00:00 0:10:01.858220 381400 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T09:00:51.118161+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T09:00:31.226548+00:00 2023-05-18T09:00:32.102718+00:00 0:00:00.876170 381399 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T09:00:29.071816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T08:00:00+00:00 PythonOperator 2023-05-18T09:00:11.623089+00:00 2023-05-18T09:00:12.755008+00:00 0:00:01.131919 381397 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T09:00:09.097830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T07:00:00+00:00 TriggerDagRunOperator 2023-05-18T08:11:24.450119+00:00 2023-05-18T08:11:24.921331+00:00 0:00:00.471212 381383 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T08:11:21.723296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T07:00:00+00:00 TriggerDagRunOperator 2023-05-18T08:11:24.383138+00:00 2023-05-18T08:11:24.747841+00:00 0:00:00.364703 381382 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T08:11:21.723339+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T07:00:00+00:00 EmrJobFlowSensor 2023-05-18T08:01:03.962614+00:00 2023-05-18T08:11:05.768476+00:00 0:10:01.805862 381375 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T08:01:01.415770+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-18T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-18T08:00:43.650149+00:00 2023-05-18T08:00:44.555352+00:00 0:00:00.905203 381373 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-18T08:00:41.351658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-18T07:00:00+00:00 PythonOperator 2023-05-18T08:00:21.596324+00:00 2023-05-18T08:00:22.770172+00:00 0:00:01.173848 381371 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-18T08:00:19.331779+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-18T06:00:00+00:00 TriggerDagRunOperator 2023-05-18T07:11:17.528878+00:00 2023-05-18T07:11:17.888402+00:00 0:00:00.359524 381357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T07:11:15.215162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-18T06:00:00+00:00 TriggerDagRunOperator 2023-05-18T07:11:17.515317+00:00 2023-05-18T07:11:17.982427+00:00 0:00:00.467110 381356 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-18T07:11:15.215134+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-18T06:00:00+00:00 EmrJobFlowSensor 2023-05-18T07:01:03.004086+00:00 2023-05-18T07:11:04.993280+00:00 0:10:01.989194 381349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-18T07:01:00.627844+00:00 2 default_pool