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-01T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T15:00:27.772858+00:00 2023-05-01T15:00:28.647927+00:00 0:00:00.875069 371189 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T15:00:25.411425+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T14:00:00+00:00 PythonOperator 2023-05-01T15:00:06.094498+00:00 2023-05-01T15:00:06.996700+00:00 0:00:00.902202 371187 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T15:00:03.389956+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T13:00:00+00:00 TriggerDagRunOperator 2023-05-01T14:19:07.546445+00:00 2023-05-01T14:19:07.908421+00:00 0:00:00.361976 371176 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T14:19:04.871743+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T13:00:00+00:00 TriggerDagRunOperator 2023-05-01T14:19:07.566458+00:00 2023-05-01T14:19:08.012431+00:00 0:00:00.445973 371175 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T14:19:04.871782+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T13:00:00+00:00 EmrJobFlowSensor 2023-05-01T14:05:47.493097+00:00 2023-05-01T14:15:49.340794+00:00 0:10:01.847697 371170 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T14:05:45.218720+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T14:05:27.309263+00:00 2023-05-01T14:05:28.158188+00:00 0:00:00.848925 371168 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T14:05:25.158576+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T13:00:00+00:00 PythonOperator 2023-05-01T14:05:05.767001+00:00 2023-05-01T14:05:06.650356+00:00 0:00:00.883355 371165 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T14:05:03.138949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T12:00:00+00:00 TriggerDagRunOperator 2023-05-01T13:10:56.605900+00:00 2023-05-01T13:10:57.050151+00:00 0:00:00.444251 371154 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T13:10:54.346596+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T12:00:00+00:00 TriggerDagRunOperator 2023-05-01T13:10:56.581438+00:00 2023-05-01T13:10:56.930333+00:00 0:00:00.348895 371153 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T13:10:54.346554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T12:00:00+00:00 EmrJobFlowSensor 2023-05-01T13:00:50.572483+00:00 2023-05-01T13:10:52.390278+00:00 0:10:01.817795 371146 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T13:00:47.782966+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T13:00:28.009237+00:00 2023-05-01T13:00:28.785473+00:00 0:00:00.776236 371144 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T13:00:25.689903+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T12:00:00+00:00 PythonOperator 2023-05-01T13:00:06.265924+00:00 2023-05-01T13:00:07.201139+00:00 0:00:00.935215 371142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T13:00:03.612785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T11:00:00+00:00 TriggerDagRunOperator 2023-05-01T12:11:22.917971+00:00 2023-05-01T12:11:23.362322+00:00 0:00:00.444351 371129 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T12:11:20.245722+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T11:00:00+00:00 TriggerDagRunOperator 2023-05-01T12:11:22.822670+00:00 2023-05-01T12:11:23.193482+00:00 0:00:00.370812 371128 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T12:11:20.245673+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T11:00:00+00:00 EmrJobFlowSensor 2023-05-01T12:01:02.056617+00:00 2023-05-01T12:11:03.913824+00:00 0:10:01.857207 371121 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T12:00:59.919215+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T12:00:40.194259+00:00 2023-05-01T12:00:41.029684+00:00 0:00:00.835425 371119 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T12:00:37.891260+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T11:00:00+00:00 PythonOperator 2023-05-01T12:00:18.022208+00:00 2023-05-01T12:00:19.030837+00:00 0:00:01.008629 371117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T12:00:15.814807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T10:00:00+00:00 TriggerDagRunOperator 2023-05-01T11:12:01.033132+00:00 2023-05-01T11:12:01.405179+00:00 0:00:00.372047 371104 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T11:11:58.258639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T10:00:00+00:00 TriggerDagRunOperator 2023-05-01T11:12:00.940312+00:00 2023-05-01T11:12:01.437505+00:00 0:00:00.497193 371103 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T11:11:58.258684+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T10:00:00+00:00 EmrJobFlowSensor 2023-05-01T11:01:48.425310+00:00 2023-05-01T11:11:50.456468+00:00 0:10:02.031158 371096 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T11:01:46.304211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T11:01:28.418547+00:00 2023-05-01T11:01:29.218046+00:00 0:00:00.799499 371094 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T11:01:26.250518+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T10:00:00+00:00 PythonOperator 2023-05-01T11:01:07.184889+00:00 2023-05-01T11:01:08.091193+00:00 0:00:00.906304 371092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T11:01:04.391417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T09:00:00+00:00 TriggerDagRunOperator 2023-05-01T10:12:27.995800+00:00 2023-05-01T10:12:28.347558+00:00 0:00:00.351758 371080 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T10:12:25.602806+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T09:00:00+00:00 TriggerDagRunOperator 2023-05-01T10:12:27.982249+00:00 2023-05-01T10:12:28.436164+00:00 0:00:00.453915 371079 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T10:12:25.602778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T09:00:00+00:00 EmrJobFlowSensor 2023-05-01T10:01:02.418197+00:00 2023-05-01T10:11:04.242380+00:00 0:10:01.824183 371072 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T10:00:59.885032+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T10:00:40.145470+00:00 2023-05-01T10:00:41.050240+00:00 0:00:00.904770 371069 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T10:00:37.783580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T09:00:00+00:00 PythonOperator 2023-05-01T10:00:18.259683+00:00 2023-05-01T10:00:20.074641+00:00 0:00:01.814958 371067 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T10:00:15.704240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T08:00:00+00:00 TriggerDagRunOperator 2023-05-01T09:15:34.595185+00:00 2023-05-01T09:15:35.050118+00:00 0:00:00.454933 371055 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T09:15:31.708715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T08:00:00+00:00 TriggerDagRunOperator 2023-05-01T09:15:34.565402+00:00 2023-05-01T09:15:34.928691+00:00 0:00:00.363289 371054 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T09:15:31.708681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T08:00:00+00:00 EmrJobFlowSensor 2023-05-01T09:01:58.185849+00:00 2023-05-01T09:12:00.090845+00:00 0:10:01.904996 371047 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T09:01:55.984012+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T09:01:40.067662+00:00 2023-05-01T09:01:40.913460+00:00 0:00:00.845798 371046 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T09:01:35.960520+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T08:00:00+00:00 PythonOperator 2023-05-01T09:00:20.720245+00:00 2023-05-01T09:00:21.632747+00:00 0:00:00.912502 371043 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T09:00:18.484468+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T07:00:00+00:00 TriggerDagRunOperator 2023-05-01T08:18:53.923148+00:00 2023-05-01T08:18:54.358034+00:00 0:00:00.434886 371031 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T08:18:51.019574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T07:00:00+00:00 TriggerDagRunOperator 2023-05-01T08:18:53.845635+00:00 2023-05-01T08:18:54.202757+00:00 0:00:00.357122 371030 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T08:18:51.019544+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T07:00:00+00:00 EmrJobFlowSensor 2023-05-01T08:00:51.330320+00:00 2023-05-01T08:10:53.134376+00:00 0:10:01.804056 371023 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T08:00:49.149635+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T08:00:31.311821+00:00 2023-05-01T08:00:32.133188+00:00 0:00:00.821367 371021 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T08:00:29.128446+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T07:00:00+00:00 PythonOperator 2023-05-01T08:00:09.412397+00:00 2023-05-01T08:00:10.346380+00:00 0:00:00.933983 371019 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T08:00:07.107715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T06:00:00+00:00 TriggerDagRunOperator 2023-05-01T07:12:25.735829+00:00 2023-05-01T07:12:26.097950+00:00 0:00:00.362121 371006 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T07:12:22.667571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T06:00:00+00:00 TriggerDagRunOperator 2023-05-01T07:12:24.876283+00:00 2023-05-01T07:12:25.322964+00:00 0:00:00.446681 371005 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T07:12:22.667604+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T06:00:00+00:00 EmrJobFlowSensor 2023-05-01T07:01:00.828706+00:00 2023-05-01T07:12:02.879752+00:00 0:11:02.051046 370998 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T07:00:58.556630+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T07:00:38.770416+00:00 2023-05-01T07:00:39.700136+00:00 0:00:00.929720 370996 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T07:00:36.453146+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T06:00:00+00:00 PythonOperator 2023-05-01T07:00:18.872128+00:00 2023-05-01T07:00:19.796640+00:00 0:00:00.924512 370994 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T07:00:16.435584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T05:00:00+00:00 TriggerDagRunOperator 2023-05-01T06:12:41.197773+00:00 2023-05-01T06:12:41.551912+00:00 0:00:00.354139 370981 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T06:12:38.284059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T05:00:00+00:00 TriggerDagRunOperator 2023-05-01T06:12:41.214272+00:00 2023-05-01T06:12:41.686553+00:00 0:00:00.472281 370980 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T06:12:38.284102+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T05:00:00+00:00 EmrJobFlowSensor 2023-05-01T06:02:20.026210+00:00 2023-05-01T06:12:22.008495+00:00 0:10:01.982285 370974 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T06:02:17.835557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T06:01:57.970175+00:00 2023-05-01T06:01:58.832708+00:00 0:00:00.862533 370972 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T06:01:55.815379+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T05:00:00+00:00 PythonOperator 2023-05-01T06:01:38.096328+00:00 2023-05-01T06:01:39.015631+00:00 0:00:00.919303 370970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T06:01:35.795970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T04:00:00+00:00 TriggerDagRunOperator 2023-05-01T05:48:36.324475+00:00 2023-05-01T05:48:36.761832+00:00 0:00:00.437357 370961 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T05:48:33.823176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T04:00:00+00:00 TriggerDagRunOperator 2023-05-01T05:48:36.250530+00:00 2023-05-01T05:48:36.603525+00:00 0:00:00.352995 370960 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T05:48:33.823205+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T04:00:00+00:00 EmrJobFlowSensor 2023-05-01T05:29:15.426756+00:00 2023-05-01T05:39:17.288051+00:00 0:10:01.861295 370956 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T05:29:13.137062+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T05:28:53.052786+00:00 2023-05-01T05:28:53.860478+00:00 0:00:00.807692 370953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T05:28:50.935484+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T04:00:00+00:00 PythonOperator 2023-05-01T05:28:33.072709+00:00 2023-05-01T05:28:33.970160+00:00 0:00:00.897451 370950 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T05:28:30.917450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T03:00:00+00:00 TriggerDagRunOperator 2023-05-01T04:11:19.134910+00:00 2023-05-01T04:11:19.597572+00:00 0:00:00.462662 370937 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T04:11:16.410274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T03:00:00+00:00 TriggerDagRunOperator 2023-05-01T04:11:19.069853+00:00 2023-05-01T04:11:19.464277+00:00 0:00:00.394424 370936 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T04:11:16.410315+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T03:00:00+00:00 EmrJobFlowSensor 2023-05-01T04:01:02.482702+00:00 2023-05-01T04:11:04.369411+00:00 0:10:01.886709 370930 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T04:00:59.714080+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T04:00:39.928550+00:00 2023-05-01T04:00:40.807975+00:00 0:00:00.879425 370927 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T04:00:37.634337+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T03:00:00+00:00 PythonOperator 2023-05-01T04:00:20.590487+00:00 2023-05-01T04:00:21.459580+00:00 0:00:00.869093 370926 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T04:00:17.618428+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T02:00:00+00:00 TriggerDagRunOperator 2023-05-01T03:15:55.233719+00:00 2023-05-01T03:15:55.594898+00:00 0:00:00.361179 370914 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T03:15:52.481359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T02:00:00+00:00 TriggerDagRunOperator 2023-05-01T03:15:55.242801+00:00 2023-05-01T03:15:55.684491+00:00 0:00:00.441690 370913 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T03:15:52.481331+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T02:00:00+00:00 EmrJobFlowSensor 2023-05-01T03:05:38.709207+00:00 2023-05-01T03:15:40.573638+00:00 0:10:01.864431 370909 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T03:05:36.007994+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T03:05:18.255938+00:00 2023-05-01T03:05:19.070484+00:00 0:00:00.814546 370906 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T03:05:15.960086+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T02:00:00+00:00 PythonOperator 2023-05-01T03:04:56.776869+00:00 2023-05-01T03:04:57.748492+00:00 0:00:00.971623 370903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T03:04:53.970973+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T01:00:00+00:00 TriggerDagRunOperator 2023-05-01T02:13:53.049939+00:00 2023-05-01T02:13:53.567208+00:00 0:00:00.517269 370889 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T02:13:50.117765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T01:00:00+00:00 TriggerDagRunOperator 2023-05-01T02:13:52.648372+00:00 2023-05-01T02:13:53.094444+00:00 0:00:00.446072 370888 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T02:13:50.117794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T01:00:00+00:00 EmrJobFlowSensor 2023-05-01T02:03:37.233680+00:00 2023-05-01T02:13:39.087143+00:00 0:10:01.853463 370882 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T02:03:35.005856+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T02:03:15.180984+00:00 2023-05-01T02:03:16.128901+00:00 0:00:00.947917 370879 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T02:03:12.939173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T01:00:00+00:00 PythonOperator 2023-05-01T02:02:56.166006+00:00 2023-05-01T02:02:57.115510+00:00 0:00:00.949504 370878 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T02:02:52.923868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T00:00:00+00:00 TriggerDagRunOperator 2023-05-01T01:16:07.393874+00:00 2023-05-01T01:16:07.752784+00:00 0:00:00.358910 370859 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T01:16:04.595413+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T00:00:00+00:00 TriggerDagRunOperator 2023-05-01T01:16:07.403030+00:00 2023-05-01T01:16:07.892366+00:00 0:00:00.489336 370858 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T01:16:04.595442+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T00:00:00+00:00 EmrJobFlowSensor 2023-05-01T01:05:59.840035+00:00 2023-05-01T01:16:01.996983+00:00 0:10:02.156948 370855 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T01:05:57.491555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T01:05:37.641875+00:00 2023-05-01T01:05:38.490367+00:00 0:00:00.848492 370852 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T01:05:35.429781+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T00:00:00+00:00 PythonOperator 2023-05-01T01:05:17.992316+00:00 2023-05-01T01:05:18.889881+00:00 0:00:00.897565 370849 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T01:05:15.409578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T23:00:00+00:00 TriggerDagRunOperator 2023-05-01T00:16:31.569450+00:00 2023-05-01T00:16:31.917643+00:00 0:00:00.348193 370834 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T00:16:28.576732+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T23:00:00+00:00 TriggerDagRunOperator 2023-05-01T00:16:31.565108+00:00 2023-05-01T00:16:32.032702+00:00 0:00:00.467594 370833 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T00:16:28.576764+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T23:00:00+00:00 EmrJobFlowSensor 2023-05-01T00:00:59.617393+00:00 2023-05-01T00:11:01.581179+00:00 0:10:01.963786 370825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T00:00:57.122754+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T00:00:37.349089+00:00 2023-05-01T00:00:38.139790+00:00 0:00:00.790701 370823 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T00:00:35.103635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T23:00:00+00:00 PythonOperator 2023-05-01T00:00:18.183267+00:00 2023-05-01T00:00:20.292624+00:00 0:00:02.109357 370821 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T00:00:13.083984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T22:00:00+00:00 TriggerDagRunOperator 2023-04-30T23:11:26.613273+00:00 2023-04-30T23:11:27.059541+00:00 0:00:00.446268 370810 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T23:11:24.132159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T22:00:00+00:00 TriggerDagRunOperator 2023-04-30T23:11:26.439428+00:00 2023-04-30T23:11:26.803083+00:00 0:00:00.363655 370809 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T23:11:24.132130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T22:00:00+00:00 EmrJobFlowSensor 2023-04-30T23:01:08.887001+00:00 2023-04-30T23:11:10.757035+00:00 0:10:01.870034 370801 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T23:01:06.480433+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T23:00:46.655913+00:00 2023-04-30T23:00:47.433209+00:00 0:00:00.777296 370798 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T23:00:44.404830+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T22:00:00+00:00 PythonOperator 2023-04-30T23:00:24.709086+00:00 2023-04-30T23:00:25.647626+00:00 0:00:00.938540 370795 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T23:00:22.365229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T21:00:00+00:00 TriggerDagRunOperator 2023-04-30T22:11:06.653237+00:00 2023-04-30T22:11:06.999478+00:00 0:00:00.346241 370781 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T22:11:04.202976+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T21:00:00+00:00 TriggerDagRunOperator 2023-04-30T22:11:06.663709+00:00 2023-04-30T22:11:07.117306+00:00 0:00:00.453597 370780 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T22:11:04.203024+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T21:00:00+00:00 EmrJobFlowSensor 2023-04-30T22:00:58.125652+00:00 2023-04-30T22:10:59.904947+00:00 0:10:01.779295 370774 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T22:00:55.106573+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T22:00:36.485745+00:00 2023-04-30T22:00:37.281187+00:00 0:00:00.795442 370772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T22:00:33.084648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T21:00:00+00:00 PythonOperator 2023-04-30T22:00:15.302450+00:00 2023-04-30T22:00:16.273680+00:00 0:00:00.971230 370770 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T22:00:13.016538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T20:00:00+00:00 TriggerDagRunOperator 2023-04-30T21:12:44.830335+00:00 2023-04-30T21:12:45.313797+00:00 0:00:00.483462 370756 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T21:12:41.707081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T20:00:00+00:00 TriggerDagRunOperator 2023-04-30T21:12:44.774755+00:00 2023-04-30T21:12:45.368821+00:00 0:00:00.594066 370755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T21:12:41.707042+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T20:00:00+00:00 EmrJobFlowSensor 2023-04-30T21:00:53.573141+00:00 2023-04-30T21:10:55.460454+00:00 0:10:01.887313 370747 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T21:00:51.191221+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T21:00:33.488798+00:00 2023-04-30T21:00:34.408548+00:00 0:00:00.919750 370745 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T21:00:31.107687+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T20:00:00+00:00 PythonOperator 2023-04-30T21:00:11.659312+00:00 2023-04-30T21:00:12.614228+00:00 0:00:00.954916 370743 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T21:00:09.098093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T19:00:00+00:00 TriggerDagRunOperator 2023-04-30T20:12:54.756038+00:00 2023-04-30T20:12:55.276762+00:00 0:00:00.520724 370731 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T20:12:51.819044+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T19:00:00+00:00 TriggerDagRunOperator 2023-04-30T20:12:54.698843+00:00 2023-04-30T20:12:55.081915+00:00 0:00:00.383072 370730 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T20:12:51.819008+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T19:00:00+00:00 EmrJobFlowSensor 2023-04-30T20:01:15.466090+00:00 2023-04-30T20:11:17.233330+00:00 0:10:01.767240 370723 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T20:01:13.245686+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-30T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-30T20:00:53.417366+00:00 2023-04-30T20:00:54.195613+00:00 0:00:00.778247 370721 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-30T20:00:51.218893+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-30T19:00:00+00:00 PythonOperator 2023-04-30T20:00:33.901488+00:00 2023-04-30T20:00:34.870641+00:00 0:00:00.969153 370719 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-30T20:00:31.259713+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-30T18:00:00+00:00 TriggerDagRunOperator 2023-04-30T19:11:17.667195+00:00 2023-04-30T19:11:18.115357+00:00 0:00:00.448162 370706 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T19:11:15.308954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-30T18:00:00+00:00 TriggerDagRunOperator 2023-04-30T19:11:17.610776+00:00 2023-04-30T19:11:17.980830+00:00 0:00:00.370054 370705 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-30T19:11:15.308987+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-30T18:00:00+00:00 EmrJobFlowSensor 2023-04-30T19:01:02.140376+00:00 2023-04-30T19:11:03.986053+00:00 0:10:01.845677 370699 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-30T19:00:59.840600+00:00 2 default_pool