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-04T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T23:00:26.143483+00:00 2023-05-04T23:00:27.007825+00:00 0:00:00.864342 373167 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T23:00:23.807775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T22:00:00+00:00 PythonOperator 2023-05-04T23:00:04.388455+00:00 2023-05-04T23:00:05.351583+00:00 0:00:00.963128 373164 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T23:00:01.796159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T21:00:00+00:00 TriggerDagRunOperator 2023-05-04T22:11:44.920431+00:00 2023-05-04T22:11:45.500948+00:00 0:00:00.580517 373151 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T22:11:42.474847+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T21:00:00+00:00 TriggerDagRunOperator 2023-05-04T22:11:44.796695+00:00 2023-05-04T22:11:45.323521+00:00 0:00:00.526826 373150 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T22:11:42.474819+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T21:00:00+00:00 EmrJobFlowSensor 2023-05-04T22:01:29.042507+00:00 2023-05-04T22:11:30.993947+00:00 0:10:01.951440 373145 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T22:01:26.713390+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T22:01:07.057312+00:00 2023-05-04T22:01:08.197910+00:00 0:00:01.140598 373142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T22:01:04.692981+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T21:00:00+00:00 PythonOperator 2023-05-04T22:00:20.596921+00:00 2023-05-04T22:00:21.597785+00:00 0:00:01.000864 373139 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T22:00:18.095700+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T20:00:00+00:00 TriggerDagRunOperator 2023-05-04T21:11:31.119478+00:00 2023-05-04T21:11:31.522394+00:00 0:00:00.402916 373124 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T21:11:28.636558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T20:00:00+00:00 TriggerDagRunOperator 2023-05-04T21:11:31.043654+00:00 2023-05-04T21:11:31.584453+00:00 0:00:00.540799 373123 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T21:11:28.636529+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T20:00:00+00:00 EmrJobFlowSensor 2023-05-04T21:01:09.981090+00:00 2023-05-04T21:11:11.797737+00:00 0:10:01.816647 373117 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T21:01:07.780835+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T21:00:33.339399+00:00 2023-05-04T21:00:34.148535+00:00 0:00:00.809136 373114 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T21:00:30.995796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T20:00:00+00:00 PythonOperator 2023-05-04T21:00:13.075617+00:00 2023-05-04T21:00:14.096482+00:00 0:00:01.020865 373112 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T21:00:10.866404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T19:00:00+00:00 TriggerDagRunOperator 2023-05-04T20:11:48.771289+00:00 2023-05-04T20:11:49.213367+00:00 0:00:00.442078 373096 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T20:11:46.415211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T19:00:00+00:00 TriggerDagRunOperator 2023-05-04T20:11:48.714975+00:00 2023-05-04T20:11:49.086656+00:00 0:00:00.371681 373095 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T20:11:46.415240+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T19:00:00+00:00 EmrJobFlowSensor 2023-05-04T20:01:23.036145+00:00 2023-05-04T20:11:24.990859+00:00 0:10:01.954714 373088 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T20:01:20.785802+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T20:01:01.156392+00:00 2023-05-04T20:01:02.399909+00:00 0:00:01.243517 373086 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T20:00:58.734101+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T19:00:00+00:00 PythonOperator 2023-05-04T20:00:41.296871+00:00 2023-05-04T20:00:42.298333+00:00 0:00:01.001462 373084 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T20:00:38.712514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T18:00:00+00:00 TriggerDagRunOperator 2023-05-04T19:11:40.797355+00:00 2023-05-04T19:11:41.254801+00:00 0:00:00.457446 373068 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T19:11:38.203670+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T18:00:00+00:00 TriggerDagRunOperator 2023-05-04T19:11:40.724328+00:00 2023-05-04T19:11:41.104035+00:00 0:00:00.379707 373067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T19:11:38.203711+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T18:00:00+00:00 EmrJobFlowSensor 2023-05-04T19:01:32.818700+00:00 2023-05-04T19:11:34.803825+00:00 0:10:01.985125 373060 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T19:01:30.581445+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T19:01:10.833247+00:00 2023-05-04T19:01:11.710967+00:00 0:00:00.877720 373059 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T19:01:08.542593+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T18:00:00+00:00 PythonOperator 2023-05-04T19:00:50.934658+00:00 2023-05-04T19:00:51.840790+00:00 0:00:00.906132 373058 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T19:00:48.509870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T17:00:00+00:00 TriggerDagRunOperator 2023-05-04T18:11:42.799339+00:00 2023-05-04T18:11:43.242819+00:00 0:00:00.443480 373041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T18:11:40.391991+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T17:00:00+00:00 TriggerDagRunOperator 2023-05-04T18:11:42.755937+00:00 2023-05-04T18:11:43.101861+00:00 0:00:00.345924 373040 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T18:11:40.391943+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T17:00:00+00:00 EmrJobFlowSensor 2023-05-04T18:01:29.269016+00:00 2023-05-04T18:11:31.114631+00:00 0:10:01.845615 373033 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T18:01:27.128643+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T18:01:09.312194+00:00 2023-05-04T18:01:10.152126+00:00 0:00:00.839932 373032 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T18:01:07.106137+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T17:00:00+00:00 PythonOperator 2023-05-04T18:00:47.339267+00:00 2023-05-04T18:00:48.406805+00:00 0:00:01.067538 373031 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T18:00:45.129126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T16:00:00+00:00 TriggerDagRunOperator 2023-05-04T17:11:06.153152+00:00 2023-05-04T17:11:06.629984+00:00 0:00:00.476832 373016 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T17:11:03.680304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T16:00:00+00:00 TriggerDagRunOperator 2023-05-04T17:11:06.136428+00:00 2023-05-04T17:11:06.486012+00:00 0:00:00.349584 373015 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T17:11:03.680334+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T16:00:00+00:00 EmrJobFlowSensor 2023-05-04T17:00:54.601763+00:00 2023-05-04T17:10:56.508626+00:00 0:10:01.906863 373006 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T17:00:52.207126+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T17:00:34.477542+00:00 2023-05-04T17:00:35.253823+00:00 0:00:00.776281 373005 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T17:00:32.131697+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T16:00:00+00:00 PythonOperator 2023-05-04T17:00:12.286667+00:00 2023-05-04T17:00:13.239137+00:00 0:00:00.952470 373004 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T17:00:10.109238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T15:00:00+00:00 TriggerDagRunOperator 2023-05-04T16:17:34.030879+00:00 2023-05-04T16:17:34.368092+00:00 0:00:00.337213 372989 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T16:17:30.738142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T15:00:00+00:00 TriggerDagRunOperator 2023-05-04T16:17:33.001064+00:00 2023-05-04T16:17:33.431795+00:00 0:00:00.430731 372988 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T16:17:30.738169+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T15:00:00+00:00 EmrJobFlowSensor 2023-05-04T16:01:02.845492+00:00 2023-05-04T16:11:04.678594+00:00 0:10:01.833102 372984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T16:00:59.904705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T16:00:42.152238+00:00 2023-05-04T16:00:43.090072+00:00 0:00:00.937834 372982 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T16:00:39.812421+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T15:00:00+00:00 PythonOperator 2023-05-04T16:00:19.894927+00:00 2023-05-04T16:00:20.774224+00:00 0:00:00.879297 372980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T16:00:17.708933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T14:00:00+00:00 TriggerDagRunOperator 2023-05-04T15:22:28.743413+00:00 2023-05-04T15:22:29.126038+00:00 0:00:00.382625 372968 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T15:22:26.006582+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T14:00:00+00:00 TriggerDagRunOperator 2023-05-04T15:22:28.745970+00:00 2023-05-04T15:22:29.230927+00:00 0:00:00.484957 372967 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T15:22:26.006626+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T14:00:00+00:00 EmrJobFlowSensor 2023-05-04T15:01:09.923415+00:00 2023-05-04T15:12:11.951153+00:00 0:11:02.027738 372960 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T15:01:07.605937+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T15:00:47.727058+00:00 2023-05-04T15:00:48.602912+00:00 0:00:00.875854 372958 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T15:00:45.543251+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T14:00:00+00:00 PythonOperator 2023-05-04T15:00:23.806491+00:00 2023-05-04T15:00:24.758800+00:00 0:00:00.952309 372956 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T15:00:21.523398+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T13:00:00+00:00 TriggerDagRunOperator 2023-05-04T14:21:01.482059+00:00 2023-05-04T14:21:01.941906+00:00 0:00:00.459847 372944 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T14:20:58.655765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T13:00:00+00:00 TriggerDagRunOperator 2023-05-04T14:21:01.411250+00:00 2023-05-04T14:21:01.771507+00:00 0:00:00.360257 372943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T14:20:58.655737+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T13:00:00+00:00 EmrJobFlowSensor 2023-05-04T14:09:00.310038+00:00 2023-05-04T14:19:02.117416+00:00 0:10:01.807378 372939 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T14:08:57.962965+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T14:08:39.883399+00:00 2023-05-04T14:08:40.667957+00:00 0:00:00.784558 372936 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T14:08:35.966974+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T13:00:00+00:00 PythonOperator 2023-05-04T14:00:18.952499+00:00 2023-05-04T14:00:19.972445+00:00 0:00:01.019946 372932 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T14:00:16.150158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T12:00:00+00:00 TriggerDagRunOperator 2023-05-04T13:11:20.211858+00:00 2023-05-04T13:11:20.679539+00:00 0:00:00.467681 372920 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T13:11:17.429015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T12:00:00+00:00 TriggerDagRunOperator 2023-05-04T13:11:20.015671+00:00 2023-05-04T13:11:20.375265+00:00 0:00:00.359594 372919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T13:11:17.428974+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T12:00:00+00:00 EmrJobFlowSensor 2023-05-04T13:00:59.270623+00:00 2023-05-04T13:11:01.357585+00:00 0:10:02.086962 372912 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T13:00:56.989882+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T13:00:39.179276+00:00 2023-05-04T13:00:40.131923+00:00 0:00:00.952647 372910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T13:00:36.970459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T12:00:00+00:00 PythonOperator 2023-05-04T13:00:17.220294+00:00 2023-05-04T13:00:18.194705+00:00 0:00:00.974411 372908 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T13:00:14.985656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T11:00:00+00:00 TriggerDagRunOperator 2023-05-04T12:11:49.919380+00:00 2023-05-04T12:11:50.272952+00:00 0:00:00.353572 372895 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T12:11:46.814838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T11:00:00+00:00 TriggerDagRunOperator 2023-05-04T12:11:49.881619+00:00 2023-05-04T12:11:50.334998+00:00 0:00:00.453379 372894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T12:11:46.814876+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T11:00:00+00:00 EmrJobFlowSensor 2023-05-04T12:00:46.255192+00:00 2023-05-04T12:10:48.177762+00:00 0:10:01.922570 372886 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T12:00:44.027481+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T12:00:26.303038+00:00 2023-05-04T12:00:27.199807+00:00 0:00:00.896769 372884 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T12:00:24.000979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T11:00:00+00:00 PythonOperator 2023-05-04T12:00:05.184770+00:00 2023-05-04T12:00:06.447811+00:00 0:00:01.263041 372882 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T12:00:01.981135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T10:00:00+00:00 TriggerDagRunOperator 2023-05-04T11:11:34.970119+00:00 2023-05-04T11:11:35.320501+00:00 0:00:00.350382 372872 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T11:11:32.092641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T10:00:00+00:00 TriggerDagRunOperator 2023-05-04T11:11:34.987507+00:00 2023-05-04T11:11:35.430966+00:00 0:00:00.443459 372871 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T11:11:32.092674+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T10:00:00+00:00 EmrJobFlowSensor 2023-05-04T11:01:03.685850+00:00 2023-05-04T11:11:05.423555+00:00 0:10:01.737705 372863 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T11:01:01.530290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T11:00:44.086083+00:00 2023-05-04T11:00:45.006713+00:00 0:00:00.920630 372862 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T11:00:41.583936+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T10:00:00+00:00 PythonOperator 2023-05-04T11:00:22.362424+00:00 2023-05-04T11:00:23.385079+00:00 0:00:01.022655 372860 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T11:00:19.282451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T09:00:00+00:00 TriggerDagRunOperator 2023-05-04T10:14:55.291455+00:00 2023-05-04T10:14:55.721579+00:00 0:00:00.430124 372846 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T10:14:52.283628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T09:00:00+00:00 TriggerDagRunOperator 2023-05-04T10:14:55.204998+00:00 2023-05-04T10:14:55.561530+00:00 0:00:00.356532 372845 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T10:14:52.283657+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T09:00:00+00:00 EmrJobFlowSensor 2023-05-04T10:04:39.208316+00:00 2023-05-04T10:14:41.008914+00:00 0:10:01.800598 372838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T10:04:36.450443+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T10:04:18.692709+00:00 2023-05-04T10:04:19.565072+00:00 0:00:00.872363 372836 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T10:04:16.429773+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T09:00:00+00:00 PythonOperator 2023-05-04T10:03:57.170512+00:00 2023-05-04T10:03:58.109058+00:00 0:00:00.938546 372834 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T10:03:54.203958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T08:00:00+00:00 TriggerDagRunOperator 2023-05-04T09:21:39.428558+00:00 2023-05-04T09:21:39.778578+00:00 0:00:00.350020 372824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T09:21:36.382128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T08:00:00+00:00 TriggerDagRunOperator 2023-05-04T09:21:39.327161+00:00 2023-05-04T09:21:39.786030+00:00 0:00:00.458869 372823 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T09:21:36.382083+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T08:00:00+00:00 EmrJobFlowSensor 2023-05-04T09:10:29.925373+00:00 2023-05-04T09:21:32.058280+00:00 0:11:02.132907 372818 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T09:10:27.600468+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T09:10:07.848549+00:00 2023-05-04T09:10:08.784346+00:00 0:00:00.935797 372815 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T09:10:05.536325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T08:00:00+00:00 PythonOperator 2023-05-04T09:09:49.589747+00:00 2023-05-04T09:09:51.417855+00:00 0:00:01.828108 372812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T09:09:45.572926+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T07:00:00+00:00 TriggerDagRunOperator 2023-05-04T08:11:25.042434+00:00 2023-05-04T08:11:25.560607+00:00 0:00:00.518173 372799 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T08:11:22.558066+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T07:00:00+00:00 TriggerDagRunOperator 2023-05-04T08:11:24.722020+00:00 2023-05-04T08:11:25.067025+00:00 0:00:00.345005 372798 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T08:11:22.558098+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T07:00:00+00:00 EmrJobFlowSensor 2023-05-04T08:00:59.620373+00:00 2023-05-04T08:11:01.983687+00:00 0:10:02.363314 372789 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T08:00:57.080593+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T08:00:39.446288+00:00 2023-05-04T08:00:40.506308+00:00 0:00:01.060020 372788 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T08:00:36.998043+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T07:00:00+00:00 PythonOperator 2023-05-04T08:00:17.825865+00:00 2023-05-04T08:00:18.752592+00:00 0:00:00.926727 372787 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T08:00:14.992295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T06:00:00+00:00 TriggerDagRunOperator 2023-05-04T07:21:52.686167+00:00 2023-05-04T07:21:53.246568+00:00 0:00:00.560401 372774 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T07:21:49.709646+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T06:00:00+00:00 TriggerDagRunOperator 2023-05-04T07:21:52.332941+00:00 2023-05-04T07:21:52.792364+00:00 0:00:00.459423 372773 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T07:21:49.709606+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T06:00:00+00:00 EmrJobFlowSensor 2023-05-04T07:11:25.951766+00:00 2023-05-04T07:21:27.858496+00:00 0:10:01.906730 372769 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T07:11:23.610968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T07:11:05.882922+00:00 2023-05-04T07:11:06.775620+00:00 0:00:00.892698 372766 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T07:11:03.562931+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T06:00:00+00:00 PythonOperator 2023-05-04T07:10:44.612637+00:00 2023-05-04T07:10:45.641784+00:00 0:00:01.029147 372763 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T07:10:41.535987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T05:00:00+00:00 TriggerDagRunOperator 2023-05-04T06:30:08.704731+00:00 2023-05-04T06:30:09.184674+00:00 0:00:00.479943 372751 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T06:30:05.628816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T05:00:00+00:00 TriggerDagRunOperator 2023-05-04T06:30:08.499901+00:00 2023-05-04T06:30:08.998543+00:00 0:00:00.498642 372750 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T06:30:05.628850+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T05:00:00+00:00 EmrJobFlowSensor 2023-05-04T06:17:31.537351+00:00 2023-05-04T06:27:33.303322+00:00 0:10:01.765971 372747 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T06:17:29.351770+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T06:17:09.564651+00:00 2023-05-04T06:17:10.478684+00:00 0:00:00.914033 372744 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T06:17:07.338930+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T05:00:00+00:00 PythonOperator 2023-05-04T06:16:47.567182+00:00 2023-05-04T06:16:48.635805+00:00 0:00:01.068623 372741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T06:16:45.297474+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T04:00:00+00:00 TriggerDagRunOperator 2023-05-04T05:11:17.553264+00:00 2023-05-04T05:11:17.905081+00:00 0:00:00.351817 372727 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T05:11:15.028068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T04:00:00+00:00 TriggerDagRunOperator 2023-05-04T05:11:17.552332+00:00 2023-05-04T05:11:18.008430+00:00 0:00:00.456098 372726 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T05:11:15.028038+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T04:00:00+00:00 EmrJobFlowSensor 2023-05-04T05:01:04.099850+00:00 2023-05-04T05:11:06.008506+00:00 0:10:01.908656 372719 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T05:01:01.610410+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T05:00:41.988854+00:00 2023-05-04T05:00:42.914219+00:00 0:00:00.925365 372716 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T05:00:39.600890+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T04:00:00+00:00 PythonOperator 2023-05-04T05:00:22.176180+00:00 2023-05-04T05:00:23.165841+00:00 0:00:00.989661 372715 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T05:00:19.535620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T03:00:00+00:00 TriggerDagRunOperator 2023-05-04T04:12:54.392741+00:00 2023-05-04T04:12:54.861373+00:00 0:00:00.468632 372702 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T04:12:51.714063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T03:00:00+00:00 TriggerDagRunOperator 2023-05-04T04:12:54.325283+00:00 2023-05-04T04:12:54.695151+00:00 0:00:00.369868 372701 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T04:12:51.714034+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T03:00:00+00:00 EmrJobFlowSensor 2023-05-04T04:01:39.126250+00:00 2023-05-04T04:12:41.187021+00:00 0:11:02.060771 372694 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T04:01:36.708037+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-04T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-04T04:01:16.848747+00:00 2023-05-04T04:01:17.625538+00:00 0:00:00.776791 372692 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-04T04:01:14.649766+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-04T03:00:00+00:00 PythonOperator 2023-05-04T04:00:57.269802+00:00 2023-05-04T04:00:58.174679+00:00 0:00:00.904877 372690 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-04T04:00:54.684886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-04T02:00:00+00:00 TriggerDagRunOperator 2023-05-04T03:18:12.741580+00:00 2023-05-04T03:18:13.185936+00:00 0:00:00.444356 372679 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T03:18:09.814072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-04T02:00:00+00:00 TriggerDagRunOperator 2023-05-04T03:18:12.637282+00:00 2023-05-04T03:18:12.997627+00:00 0:00:00.360345 372678 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-04T03:18:09.814028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-04T02:00:00+00:00 EmrJobFlowSensor 2023-05-04T03:07:58.416234+00:00 2023-05-04T03:18:00.147898+00:00 0:10:01.731664 372674 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-04T03:07:56.223634+00:00 2 default_pool