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 trigger_dagrun_campaign-history-job_v002 2023-03-28T03:00:00+00:00 TriggerDagRunOperator 2023-03-28T04:24:46.077531+00:00 2023-03-28T04:24:46.564592+00:00 0:00:00.487061 360287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T04:24:43.695769+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T03:00:00+00:00 EmrJobFlowSensor 2023-03-28T04:14:33.168294+00:00 2023-03-28T04:24:34.915935+00:00 0:10:01.747641 360283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T04:14:30.928140+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T04:14:11.213711+00:00 2023-03-28T04:14:12.088609+00:00 0:00:00.874898 360280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T04:14:08.889640+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T03:00:00+00:00 PythonOperator 2023-03-28T04:13:51.163344+00:00 2023-03-28T04:13:55.237915+00:00 0:00:04.074571 360277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T04:13:48.875659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T02:00:00+00:00 TriggerDagRunOperator 2023-03-28T03:11:15.953101+00:00 2023-03-28T03:11:16.447549+00:00 0:00:00.494448 360268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T03:11:13.630506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T02:00:00+00:00 TriggerDagRunOperator 2023-03-28T03:11:15.942870+00:00 2023-03-28T03:11:16.412114+00:00 0:00:00.469244 360267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T03:11:13.630534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T02:00:00+00:00 EmrJobFlowSensor 2023-03-28T03:00:50.904468+00:00 2023-03-28T03:10:52.945752+00:00 0:10:02.041284 360259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T03:00:48.521227+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T03:00:28.676553+00:00 2023-03-28T03:00:29.492695+00:00 0:00:00.816142 360257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T03:00:26.499046+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T02:00:00+00:00 PythonOperator 2023-03-28T03:00:08.925190+00:00 2023-03-28T03:00:12.972033+00:00 0:00:04.046843 360255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T03:00:06.483701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T01:00:00+00:00 TriggerDagRunOperator 2023-03-28T02:22:02.337735+00:00 2023-03-28T02:22:02.852686+00:00 0:00:00.514951 360248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T02:21:59.289567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T01:00:00+00:00 TriggerDagRunOperator 2023-03-28T02:22:02.120496+00:00 2023-03-28T02:22:02.611954+00:00 0:00:00.491458 360247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T02:21:59.289602+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T01:00:00+00:00 EmrJobFlowSensor 2023-03-28T02:02:47.607618+00:00 2023-03-28T02:12:49.439202+00:00 0:10:01.831584 360241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T02:02:45.257938+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T02:02:28.397050+00:00 2023-03-28T02:02:29.295293+00:00 0:00:00.898243 360239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T02:02:25.299737+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T01:00:00+00:00 PythonOperator 2023-03-28T02:02:05.326887+00:00 2023-03-28T02:02:09.262622+00:00 0:00:03.935735 360237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T02:02:03.185315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T00:00:00+00:00 TriggerDagRunOperator 2023-03-28T01:14:22.090561+00:00 2023-03-28T01:14:22.627302+00:00 0:00:00.536741 360219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T01:14:18.953985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T00:00:00+00:00 TriggerDagRunOperator 2023-03-28T01:14:22.038933+00:00 2023-03-28T01:14:22.538555+00:00 0:00:00.499622 360218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T01:14:18.953945+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T00:00:00+00:00 EmrJobFlowSensor 2023-03-28T01:00:52.582136+00:00 2023-03-28T01:10:54.354029+00:00 0:10:01.771893 360214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T01:00:47.565569+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T01:00:27.764402+00:00 2023-03-28T01:00:28.658122+00:00 0:00:00.893720 360212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T01:00:25.562436+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T00:00:00+00:00 PythonOperator 2023-03-28T01:00:06.230502+00:00 2023-03-28T01:00:10.223962+00:00 0:00:03.993460 360210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T01:00:03.587401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T23:00:00+00:00 TriggerDagRunOperator 2023-03-28T00:12:20.866263+00:00 2023-03-28T00:12:21.421560+00:00 0:00:00.555297 360202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T00:12:17.710270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T23:00:00+00:00 TriggerDagRunOperator 2023-03-28T00:12:20.643618+00:00 2023-03-28T00:12:21.200681+00:00 0:00:00.557063 360201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T00:12:17.710239+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T23:00:00+00:00 EmrJobFlowSensor 2023-03-28T00:01:53.541998+00:00 2023-03-28T00:11:55.431440+00:00 0:10:01.889442 360195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T00:01:51.338622+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T00:01:31.499935+00:00 2023-03-28T00:01:32.333886+00:00 0:00:00.833951 360193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T00:01:29.295427+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T23:00:00+00:00 PythonOperator 2023-03-28T00:01:09.536857+00:00 2023-03-28T00:01:13.992421+00:00 0:00:04.455564 360191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T00:01:07.271944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T22:00:00+00:00 TriggerDagRunOperator 2023-03-27T23:11:35.597480+00:00 2023-03-27T23:11:36.144637+00:00 0:00:00.547157 360180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T23:11:32.704937+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T22:00:00+00:00 TriggerDagRunOperator 2023-03-27T23:11:35.442992+00:00 2023-03-27T23:11:35.908049+00:00 0:00:00.465057 360179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T23:11:32.704910+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T22:00:00+00:00 EmrJobFlowSensor 2023-03-27T23:01:00.832185+00:00 2023-03-27T23:11:03.061431+00:00 0:10:02.229246 360171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T23:00:58.362216+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T23:00:38.897061+00:00 2023-03-27T23:00:39.794841+00:00 0:00:00.897780 360168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T23:00:36.342213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T22:00:00+00:00 PythonOperator 2023-03-27T23:00:18.652794+00:00 2023-03-27T23:00:22.109916+00:00 0:00:03.457122 360165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T23:00:16.318370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T21:00:00+00:00 TriggerDagRunOperator 2023-03-27T22:10:56.580732+00:00 2023-03-27T22:10:57.128193+00:00 0:00:00.547461 360154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T22:10:54.129551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T21:00:00+00:00 TriggerDagRunOperator 2023-03-27T22:10:56.503502+00:00 2023-03-27T22:10:56.958695+00:00 0:00:00.455193 360153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T22:10:54.129524+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T21:00:00+00:00 EmrJobFlowSensor 2023-03-27T22:00:50.866680+00:00 2023-03-27T22:10:52.631777+00:00 0:10:01.765097 360146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T22:00:48.559661+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T22:00:28.911611+00:00 2023-03-27T22:00:29.743942+00:00 0:00:00.832331 360144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T22:00:26.537617+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T21:00:00+00:00 PythonOperator 2023-03-27T22:00:06.928862+00:00 2023-03-27T22:00:11.010534+00:00 0:00:04.081672 360142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T22:00:04.504279+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T20:00:00+00:00 TriggerDagRunOperator 2023-03-27T21:11:23.239842+00:00 2023-03-27T21:11:23.747504+00:00 0:00:00.507662 360131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T21:11:21.018217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T20:00:00+00:00 TriggerDagRunOperator 2023-03-27T21:11:23.213704+00:00 2023-03-27T21:11:23.679436+00:00 0:00:00.465732 360130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T21:11:21.018247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T20:00:00+00:00 EmrJobFlowSensor 2023-03-27T21:00:59.577161+00:00 2023-03-27T21:11:01.462556+00:00 0:10:01.885395 360124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T21:00:57.318693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T21:00:39.487652+00:00 2023-03-27T21:00:40.383396+00:00 0:00:00.895744 360122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T21:00:37.251829+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T20:00:00+00:00 PythonOperator 2023-03-27T21:00:17.523760+00:00 2023-03-27T21:00:20.987589+00:00 0:00:03.463829 360120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T21:00:15.233144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T19:00:00+00:00 TriggerDagRunOperator 2023-03-27T20:11:02.576375+00:00 2023-03-27T20:11:03.056348+00:00 0:00:00.479973 360107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T20:11:00.142862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T19:00:00+00:00 TriggerDagRunOperator 2023-03-27T20:11:02.344225+00:00 2023-03-27T20:11:02.833432+00:00 0:00:00.489207 360106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T20:11:00.142836+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T19:00:00+00:00 EmrJobFlowSensor 2023-03-27T20:00:52.954084+00:00 2023-03-27T20:10:54.609731+00:00 0:10:01.655647 360099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T20:00:50.680985+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T20:00:34.548786+00:00 2023-03-27T20:00:35.856927+00:00 0:00:01.308141 360098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T20:00:30.664635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T19:00:00+00:00 PythonOperator 2023-03-27T20:00:11.916494+00:00 2023-03-27T20:00:16.154889+00:00 0:00:04.238395 360096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T20:00:08.648902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T18:00:00+00:00 TriggerDagRunOperator 2023-03-27T19:11:32.500251+00:00 2023-03-27T19:11:32.985288+00:00 0:00:00.485037 360083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T19:11:30.152100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T18:00:00+00:00 TriggerDagRunOperator 2023-03-27T19:11:32.339097+00:00 2023-03-27T19:11:32.817279+00:00 0:00:00.478182 360082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T19:11:30.152127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T18:00:00+00:00 EmrJobFlowSensor 2023-03-27T19:01:06.036279+00:00 2023-03-27T19:11:07.718043+00:00 0:10:01.681764 360076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T19:01:03.835643+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T19:00:44.056994+00:00 2023-03-27T19:00:44.915012+00:00 0:00:00.858018 360074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T19:00:41.774798+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T18:00:00+00:00 PythonOperator 2023-03-27T19:00:23.988349+00:00 2023-03-27T19:00:29.530885+00:00 0:00:05.542536 360072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T19:00:21.754581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T17:00:00+00:00 TriggerDagRunOperator 2023-03-27T18:11:19.339013+00:00 2023-03-27T18:11:19.830822+00:00 0:00:00.491809 360061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T18:11:16.509443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T17:00:00+00:00 TriggerDagRunOperator 2023-03-27T18:11:19.307233+00:00 2023-03-27T18:11:19.789065+00:00 0:00:00.481832 360060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T18:11:16.509403+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T17:00:00+00:00 EmrJobFlowSensor 2023-03-27T18:01:00.439065+00:00 2023-03-27T18:11:02.700778+00:00 0:10:02.261713 360053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T18:00:58.066742+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T18:00:38.533484+00:00 2023-03-27T18:00:39.387755+00:00 0:00:00.854271 360051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T18:00:36.048360+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T17:00:00+00:00 PythonOperator 2023-03-27T18:00:18.917784+00:00 2023-03-27T18:00:22.522238+00:00 0:00:03.604454 360049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T18:00:16.104016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T16:00:00+00:00 TriggerDagRunOperator 2023-03-27T17:16:48.384709+00:00 2023-03-27T17:16:48.908901+00:00 0:00:00.524192 360040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T17:16:45.343514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T16:00:00+00:00 TriggerDagRunOperator 2023-03-27T17:16:48.163877+00:00 2023-03-27T17:16:48.626344+00:00 0:00:00.462467 360039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T17:16:45.343551+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T16:00:00+00:00 EmrJobFlowSensor 2023-03-27T17:00:52.535114+00:00 2023-03-27T17:10:54.387496+00:00 0:10:01.852382 360032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T17:00:50.188133+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T17:00:30.356606+00:00 2023-03-27T17:00:31.197912+00:00 0:00:00.841306 360030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T17:00:28.167739+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T16:00:00+00:00 PythonOperator 2023-03-27T17:00:10.408416+00:00 2023-03-27T17:00:14.591467+00:00 0:00:04.183051 360028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T17:00:08.148363+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T15:00:00+00:00 TriggerDagRunOperator 2023-03-27T16:11:44.461237+00:00 2023-03-27T16:11:44.964339+00:00 0:00:00.503102 360017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T16:11:41.652468+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T15:00:00+00:00 TriggerDagRunOperator 2023-03-27T16:11:44.241158+00:00 2023-03-27T16:11:44.706837+00:00 0:00:00.465679 360016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T16:11:41.652497+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T15:00:00+00:00 EmrJobFlowSensor 2023-03-27T16:00:48.937281+00:00 2023-03-27T16:10:50.737886+00:00 0:10:01.800605 360012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T16:00:46.718181+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T16:00:28.935674+00:00 2023-03-27T16:00:29.804857+00:00 0:00:00.869183 360010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T16:00:26.701202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T15:00:00+00:00 PythonOperator 2023-03-27T16:00:07.515247+00:00 2023-03-27T16:00:11.524194+00:00 0:00:04.008947 360008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T16:00:04.685207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T14:00:00+00:00 TriggerDagRunOperator 2023-03-27T15:25:43.573452+00:00 2023-03-27T15:25:44.047107+00:00 0:00:00.473655 360000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T15:25:41.134728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T14:00:00+00:00 TriggerDagRunOperator 2023-03-27T15:25:43.402429+00:00 2023-03-27T15:25:43.882606+00:00 0:00:00.480177 359999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T15:25:41.134699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T14:00:00+00:00 EmrJobFlowSensor 2023-03-27T15:15:28.991702+00:00 2023-03-27T15:25:31.130452+00:00 0:10:02.138750 359995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T15:15:26.204177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T15:15:06.502436+00:00 2023-03-27T15:15:07.351798+00:00 0:00:00.849362 359991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T15:15:04.174655+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T14:00:00+00:00 PythonOperator 2023-03-27T15:14:44.936848+00:00 2023-03-27T15:14:50.399621+00:00 0:00:05.462773 359989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T15:14:42.160714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T13:00:00+00:00 TriggerDagRunOperator 2023-03-27T14:17:13.410109+00:00 2023-03-27T14:17:13.941444+00:00 0:00:00.531335 359981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T14:17:10.736630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T13:00:00+00:00 TriggerDagRunOperator 2023-03-27T14:17:13.253072+00:00 2023-03-27T14:17:13.716006+00:00 0:00:00.462934 359980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T14:17:10.736659+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T13:00:00+00:00 EmrJobFlowSensor 2023-03-27T14:00:54.618050+00:00 2023-03-27T14:10:56.697381+00:00 0:10:02.079331 359972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T14:00:52.296022+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T14:00:34.466933+00:00 2023-03-27T14:00:35.301549+00:00 0:00:00.834616 359970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T14:00:32.201344+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T13:00:00+00:00 PythonOperator 2023-03-27T14:00:12.488527+00:00 2023-03-27T14:00:15.999215+00:00 0:00:03.510688 359968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T14:00:10.133295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T12:00:00+00:00 TriggerDagRunOperator 2023-03-27T13:11:11.314279+00:00 2023-03-27T13:11:11.775346+00:00 0:00:00.461067 359960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T13:11:08.841444+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T12:00:00+00:00 TriggerDagRunOperator 2023-03-27T13:11:11.237678+00:00 2023-03-27T13:11:11.745117+00:00 0:00:00.507439 359959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T13:11:08.841415+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T12:00:00+00:00 EmrJobFlowSensor 2023-03-27T13:01:00.213084+00:00 2023-03-27T13:11:02.026521+00:00 0:10:01.813437 359953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T13:00:57.110783+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T13:00:37.463214+00:00 2023-03-27T13:00:38.245361+00:00 0:00:00.782147 359951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T13:00:35.108299+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T12:00:00+00:00 PythonOperator 2023-03-27T13:00:15.240326+00:00 2023-03-27T13:00:18.443098+00:00 0:00:03.202772 359949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T13:00:12.941785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T11:00:00+00:00 TriggerDagRunOperator 2023-03-27T12:15:54.458341+00:00 2023-03-27T12:15:55.366939+00:00 0:00:00.908598 359938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T12:15:50.174545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T11:00:00+00:00 TriggerDagRunOperator 2023-03-27T12:15:52.537879+00:00 2023-03-27T12:15:52.970446+00:00 0:00:00.432567 359937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T12:15:50.174514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T11:00:00+00:00 EmrJobFlowSensor 2023-03-27T12:01:08.041691+00:00 2023-03-27T12:11:09.885169+00:00 0:10:01.843478 359933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T12:01:05.454457+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T12:00:45.697193+00:00 2023-03-27T12:00:46.598261+00:00 0:00:00.901068 359931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T12:00:43.432923+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T11:00:00+00:00 PythonOperator 2023-03-27T12:00:25.733565+00:00 2023-03-27T12:00:29.275096+00:00 0:00:03.541531 359929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T12:00:23.399862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T10:00:00+00:00 TriggerDagRunOperator 2023-03-27T11:22:56.179940+00:00 2023-03-27T11:22:56.645335+00:00 0:00:00.465395 359916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T11:22:53.222807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T10:00:00+00:00 TriggerDagRunOperator 2023-03-27T11:22:55.968429+00:00 2023-03-27T11:22:56.499027+00:00 0:00:00.530598 359915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T11:22:53.222835+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T10:00:00+00:00 EmrJobFlowSensor 2023-03-27T11:00:57.815238+00:00 2023-03-27T11:10:59.662290+00:00 0:10:01.847052 359913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T11:00:55.477036+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T11:00:37.552094+00:00 2023-03-27T11:00:38.552752+00:00 0:00:01.000658 359911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T11:00:35.430738+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T10:00:00+00:00 PythonOperator 2023-03-27T11:00:13.936613+00:00 2023-03-27T11:00:17.282557+00:00 0:00:03.345944 359909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T11:00:11.366914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T09:00:00+00:00 TriggerDagRunOperator 2023-03-27T10:12:41.340932+00:00 2023-03-27T10:12:42.033097+00:00 0:00:00.692165 359897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T10:12:38.017906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T09:00:00+00:00 TriggerDagRunOperator 2023-03-27T10:12:40.699434+00:00 2023-03-27T10:12:41.170493+00:00 0:00:00.471059 359896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T10:12:38.017938+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T09:00:00+00:00 EmrJobFlowSensor 2023-03-27T10:00:52.446260+00:00 2023-03-27T10:10:54.176439+00:00 0:10:01.730179 359892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T10:00:50.257641+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T10:00:30.530723+00:00 2023-03-27T10:00:31.454508+00:00 0:00:00.923785 359890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T10:00:28.232288+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T09:00:00+00:00 PythonOperator 2023-03-27T10:00:10.754092+00:00 2023-03-27T10:00:14.545925+00:00 0:00:03.791833 359888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T10:00:08.226598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T08:00:00+00:00 TriggerDagRunOperator 2023-03-27T09:58:46.663302+00:00 2023-03-27T09:58:47.161770+00:00 0:00:00.498468 359884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T09:58:44.026417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T08:00:00+00:00 TriggerDagRunOperator 2023-03-27T09:58:46.529833+00:00 2023-03-27T09:58:46.990827+00:00 0:00:00.460994 359883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T09:58:44.026445+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T08:00:00+00:00 EmrJobFlowSensor 2023-03-27T09:27:37.498774+00:00 2023-03-27T09:37:39.342776+00:00 0:10:01.844002 359878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T09:27:34.814238+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T09:27:19.108715+00:00 2023-03-27T09:27:19.999581+00:00 0:00:00.890866 359875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T09:27:14.813843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T07:00:00+00:00 TriggerDagRunOperator 2023-03-27T09:26:57.792939+00:00 2023-03-27T09:26:58.404318+00:00 0:00:00.611379 359871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T09:26:52.707052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T07:00:00+00:00 TriggerDagRunOperator 2023-03-27T09:26:57.768266+00:00 2023-03-27T09:26:58.345153+00:00 0:00:00.576887 359870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T09:26:52.707081+00:00 2 default_pool