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 check_cluster_status 2023-02-15T13:00:00+00:00 EmrJobFlowSensor 2023-02-15T14:04:11.771703+00:00 2023-02-15T14:14:13.490649+00:00 0:10:01.718946 340241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T14:04:08.815938+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T14:03:50.462082+00:00 2023-02-15T14:03:51.697194+00:00 0:00:01.235112 340239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T14:03:46.800191+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T13:00:00+00:00 PythonOperator 2023-02-15T14:03:27.640970+00:00 2023-02-15T14:03:31.575755+00:00 0:00:03.934785 340236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T14:03:24.766423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T12:00:00+00:00 TriggerDagRunOperator 2023-02-15T13:27:10.947023+00:00 2023-02-15T13:27:11.550908+00:00 0:00:00.603885 340222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T13:27:06.030709+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T12:00:00+00:00 TriggerDagRunOperator 2023-02-15T13:27:08.596570+00:00 2023-02-15T13:27:09.041686+00:00 0:00:00.445116 340221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T13:27:06.030740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T12:00:00+00:00 EmrJobFlowSensor 2023-02-15T13:00:52.455734+00:00 2023-02-15T13:10:54.177475+00:00 0:10:01.721741 340217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T13:00:50.015847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T13:00:32.340691+00:00 2023-02-15T13:00:33.163832+00:00 0:00:00.823141 340215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T13:00:29.999648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T12:00:00+00:00 PythonOperator 2023-02-15T13:00:10.322033+00:00 2023-02-15T13:00:14.109018+00:00 0:00:03.786985 340213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T13:00:07.923188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T11:00:00+00:00 TriggerDagRunOperator 2023-02-15T12:22:14.736686+00:00 2023-02-15T12:22:15.365023+00:00 0:00:00.628337 340203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T12:22:11.908749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T11:00:00+00:00 TriggerDagRunOperator 2023-02-15T12:22:14.410249+00:00 2023-02-15T12:22:14.872605+00:00 0:00:00.462356 340202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T12:22:11.908778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T11:00:00+00:00 EmrJobFlowSensor 2023-02-15T12:00:53.498410+00:00 2023-02-15T12:10:55.453675+00:00 0:10:01.955265 340194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T12:00:51.276108+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T12:00:31.564890+00:00 2023-02-15T12:00:32.702633+00:00 0:00:01.137743 340192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T12:00:29.253972+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T11:00:00+00:00 PythonOperator 2023-02-15T12:00:09.687294+00:00 2023-02-15T12:00:14.940796+00:00 0:00:05.253502 340190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T12:00:07.234721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T10:00:00+00:00 TriggerDagRunOperator 2023-02-15T11:11:29.372997+00:00 2023-02-15T11:11:29.908521+00:00 0:00:00.535524 340178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T11:11:26.989949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T10:00:00+00:00 TriggerDagRunOperator 2023-02-15T11:11:29.309438+00:00 2023-02-15T11:11:29.800585+00:00 0:00:00.491147 340177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T11:11:26.989979+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T10:00:00+00:00 EmrJobFlowSensor 2023-02-15T11:01:03.997729+00:00 2023-02-15T11:11:05.955906+00:00 0:10:01.958177 340171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T11:01:01.545040+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T11:00:41.958758+00:00 2023-02-15T11:00:42.732431+00:00 0:00:00.773673 340169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T11:00:39.598423+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T10:00:00+00:00 PythonOperator 2023-02-15T11:00:21.654787+00:00 2023-02-15T11:00:25.419860+00:00 0:00:03.765073 340167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T11:00:19.460684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T09:00:00+00:00 TriggerDagRunOperator 2023-02-15T10:11:08.932663+00:00 2023-02-15T10:11:09.433734+00:00 0:00:00.501071 340152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T10:11:06.632322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T09:00:00+00:00 TriggerDagRunOperator 2023-02-15T10:11:08.833244+00:00 2023-02-15T10:11:09.320947+00:00 0:00:00.487703 340151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T10:11:06.632358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T09:00:00+00:00 EmrJobFlowSensor 2023-02-15T10:00:47.036008+00:00 2023-02-15T10:10:48.863823+00:00 0:10:01.827815 340144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T10:00:44.751186+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T10:00:27.149377+00:00 2023-02-15T10:00:27.966063+00:00 0:00:00.816686 340142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T10:00:24.736086+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T09:00:00+00:00 PythonOperator 2023-02-15T10:00:04.959767+00:00 2023-02-15T10:00:07.994019+00:00 0:00:03.034252 340140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T10:00:02.651344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T08:00:00+00:00 TriggerDagRunOperator 2023-02-15T09:11:28.181175+00:00 2023-02-15T09:11:28.779106+00:00 0:00:00.597931 340127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T09:11:25.380836+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T08:00:00+00:00 TriggerDagRunOperator 2023-02-15T09:11:27.918543+00:00 2023-02-15T09:11:28.584544+00:00 0:00:00.666001 340126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T09:11:25.380865+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T08:00:00+00:00 EmrJobFlowSensor 2023-02-15T09:01:19.305361+00:00 2023-02-15T09:11:21.369866+00:00 0:10:02.064505 340120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T09:01:16.714002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T09:00:56.959823+00:00 2023-02-15T09:00:57.805517+00:00 0:00:00.845694 340118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T09:00:54.648000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T08:00:00+00:00 PythonOperator 2023-02-15T09:00:34.830949+00:00 2023-02-15T09:00:38.689276+00:00 0:00:03.858327 340116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T09:00:32.638629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T07:00:00+00:00 TriggerDagRunOperator 2023-02-15T08:13:04.010000+00:00 2023-02-15T08:13:04.522634+00:00 0:00:00.512634 340102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T08:12:58.524528+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T07:00:00+00:00 TriggerDagRunOperator 2023-02-15T08:13:00.775240+00:00 2023-02-15T08:13:01.233383+00:00 0:00:00.458143 340101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T08:12:58.524577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T07:00:00+00:00 EmrJobFlowSensor 2023-02-15T08:00:55.400094+00:00 2023-02-15T08:10:57.186804+00:00 0:10:01.786710 340096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T08:00:52.821463+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T08:00:33.400086+00:00 2023-02-15T08:00:34.347919+00:00 0:00:00.947833 340094 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T08:00:30.821551+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T07:00:00+00:00 PythonOperator 2023-02-15T08:00:11.608677+00:00 2023-02-15T08:00:15.531831+00:00 0:00:03.923154 340092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T08:00:08.705743+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T06:00:00+00:00 TriggerDagRunOperator 2023-02-15T07:11:28.598128+00:00 2023-02-15T07:11:29.104049+00:00 0:00:00.505921 340080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T07:11:26.031796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T06:00:00+00:00 TriggerDagRunOperator 2023-02-15T07:11:28.577060+00:00 2023-02-15T07:11:29.115683+00:00 0:00:00.538623 340079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T07:11:26.031754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T06:00:00+00:00 EmrJobFlowSensor 2023-02-15T07:01:00.803272+00:00 2023-02-15T07:11:03.113015+00:00 0:10:02.309743 340072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T07:00:58.524326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T07:00:38.700341+00:00 2023-02-15T07:00:39.564176+00:00 0:00:00.863835 340070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T07:00:36.484271+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T06:00:00+00:00 PythonOperator 2023-02-15T07:00:19.560691+00:00 2023-02-15T07:00:22.679545+00:00 0:00:03.118854 340069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T07:00:16.466081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T05:00:00+00:00 TriggerDagRunOperator 2023-02-15T06:23:04.954495+00:00 2023-02-15T06:23:05.463421+00:00 0:00:00.508926 340058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T06:23:02.193455+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T05:00:00+00:00 TriggerDagRunOperator 2023-02-15T06:23:04.736427+00:00 2023-02-15T06:23:05.216754+00:00 0:00:00.480327 340057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T06:23:02.193424+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T05:00:00+00:00 EmrJobFlowSensor 2023-02-15T06:12:51.749320+00:00 2023-02-15T06:22:53.527058+00:00 0:10:01.777738 340052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T06:12:49.511275+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T06:12:30.571422+00:00 2023-02-15T06:12:31.473983+00:00 0:00:00.902561 340049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T06:12:27.474127+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T05:00:00+00:00 PythonOperator 2023-02-15T06:12:10.632054+00:00 2023-02-15T06:12:17.115177+00:00 0:00:06.483123 340046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T06:12:07.448152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T04:00:00+00:00 TriggerDagRunOperator 2023-02-15T05:16:09.197879+00:00 2023-02-15T05:16:09.643270+00:00 0:00:00.445391 340031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T05:16:06.216807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T04:00:00+00:00 TriggerDagRunOperator 2023-02-15T05:16:08.627283+00:00 2023-02-15T05:16:09.093603+00:00 0:00:00.466320 340030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T05:16:06.216849+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T04:00:00+00:00 EmrJobFlowSensor 2023-02-15T05:01:05.604762+00:00 2023-02-15T05:11:07.447079+00:00 0:10:01.842317 340026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T05:01:03.359360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T05:00:43.601478+00:00 2023-02-15T05:00:44.409566+00:00 0:00:00.808088 340024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T05:00:41.344321+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T04:00:00+00:00 PythonOperator 2023-02-15T05:00:21.560007+00:00 2023-02-15T05:00:24.490868+00:00 0:00:02.930861 340022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T05:00:19.306465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T03:00:00+00:00 TriggerDagRunOperator 2023-02-15T04:11:09.299014+00:00 2023-02-15T04:11:09.813885+00:00 0:00:00.514871 340008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T04:11:06.722283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T03:00:00+00:00 TriggerDagRunOperator 2023-02-15T04:11:09.169647+00:00 2023-02-15T04:11:09.618692+00:00 0:00:00.449045 340007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T04:11:06.722313+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T03:00:00+00:00 EmrJobFlowSensor 2023-02-15T04:01:00.298818+00:00 2023-02-15T04:11:02.106648+00:00 0:10:01.807830 340000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T04:00:57.891119+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T04:00:40.288501+00:00 2023-02-15T04:00:41.450208+00:00 0:00:01.161707 339998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T04:00:37.752100+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T03:00:00+00:00 PythonOperator 2023-02-15T04:00:16.050472+00:00 2023-02-15T04:00:18.956320+00:00 0:00:02.905848 339996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T04:00:13.797209+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T02:00:00+00:00 TriggerDagRunOperator 2023-02-15T03:11:04.886690+00:00 2023-02-15T03:11:05.423245+00:00 0:00:00.536555 339981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T03:11:01.887565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T02:00:00+00:00 TriggerDagRunOperator 2023-02-15T03:11:04.604376+00:00 2023-02-15T03:11:05.148613+00:00 0:00:00.544237 339980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T03:11:01.887613+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T02:00:00+00:00 EmrJobFlowSensor 2023-02-15T03:00:53.847958+00:00 2023-02-15T03:10:55.705962+00:00 0:10:01.858004 339973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T03:00:51.165900+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T03:00:31.935931+00:00 2023-02-15T03:00:32.785793+00:00 0:00:00.849862 339971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T03:00:29.153611+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T02:00:00+00:00 PythonOperator 2023-02-15T03:00:11.381280+00:00 2023-02-15T03:00:15.214095+00:00 0:00:03.832815 339969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T03:00:09.132584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T01:00:00+00:00 TriggerDagRunOperator 2023-02-15T02:11:19.017444+00:00 2023-02-15T02:11:19.773485+00:00 0:00:00.756041 339955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T02:11:16.599092+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T01:00:00+00:00 TriggerDagRunOperator 2023-02-15T02:11:18.964031+00:00 2023-02-15T02:11:19.683481+00:00 0:00:00.719450 339954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T02:11:16.599124+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T01:00:00+00:00 EmrJobFlowSensor 2023-02-15T02:00:54.272635+00:00 2023-02-15T02:10:56.227098+00:00 0:10:01.954463 339947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T02:00:51.971834+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T02:00:32.175518+00:00 2023-02-15T02:00:33.022347+00:00 0:00:00.846829 339945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T02:00:29.954103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T01:00:00+00:00 PythonOperator 2023-02-15T02:00:10.491252+00:00 2023-02-15T02:00:13.446520+00:00 0:00:02.955268 339943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T02:00:07.945514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T00:00:00+00:00 TriggerDagRunOperator 2023-02-15T01:11:13.330953+00:00 2023-02-15T01:11:13.859397+00:00 0:00:00.528444 339922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T01:11:10.977973+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T00:00:00+00:00 TriggerDagRunOperator 2023-02-15T01:11:13.280812+00:00 2023-02-15T01:11:13.723750+00:00 0:00:00.442938 339921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T01:11:10.978004+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T00:00:00+00:00 EmrJobFlowSensor 2023-02-15T01:00:58.145879+00:00 2023-02-15T01:10:59.944140+00:00 0:10:01.798261 339915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T01:00:55.919120+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T01:00:38.400958+00:00 2023-02-15T01:00:39.247861+00:00 0:00:00.846903 339913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T01:00:35.886845+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T00:00:00+00:00 PythonOperator 2023-02-15T01:00:14.580520+00:00 2023-02-15T01:00:17.389737+00:00 0:00:02.809217 339911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T01:00:11.989608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T23:00:00+00:00 TriggerDagRunOperator 2023-02-15T00:11:31.288057+00:00 2023-02-15T00:11:31.814191+00:00 0:00:00.526134 339897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T00:11:28.645889+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T23:00:00+00:00 TriggerDagRunOperator 2023-02-15T00:11:31.088513+00:00 2023-02-15T00:11:31.610192+00:00 0:00:00.521679 339896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T00:11:28.645918+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T23:00:00+00:00 EmrJobFlowSensor 2023-02-15T00:01:07.156734+00:00 2023-02-15T00:11:08.821620+00:00 0:10:01.664886 339890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T00:01:04.840684+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T00:00:47.657421+00:00 2023-02-15T00:00:48.655348+00:00 0:00:00.997927 339888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T00:00:42.813695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T23:00:00+00:00 PythonOperator 2023-02-15T00:00:22.931478+00:00 2023-02-15T00:00:26.730075+00:00 0:00:03.798597 339886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T00:00:20.729505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T22:00:00+00:00 TriggerDagRunOperator 2023-02-14T23:11:16.812709+00:00 2023-02-14T23:11:17.322682+00:00 0:00:00.509973 339871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T23:11:14.299757+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T22:00:00+00:00 TriggerDagRunOperator 2023-02-14T23:11:16.780165+00:00 2023-02-14T23:11:17.361330+00:00 0:00:00.581165 339870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T23:11:14.299703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T22:00:00+00:00 EmrJobFlowSensor 2023-02-14T23:01:03.249966+00:00 2023-02-14T23:11:05.066709+00:00 0:10:01.816743 339864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T23:01:00.720773+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T23:00:41.137678+00:00 2023-02-14T23:00:41.977156+00:00 0:00:00.839478 339861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T23:00:38.700174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T22:00:00+00:00 PythonOperator 2023-02-14T23:00:20.913904+00:00 2023-02-14T23:00:23.931246+00:00 0:00:03.017342 339858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T23:00:18.607130+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T21:00:00+00:00 TriggerDagRunOperator 2023-02-14T22:11:51.653975+00:00 2023-02-14T22:11:52.165998+00:00 0:00:00.512023 339843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T22:11:49.202416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T21:00:00+00:00 TriggerDagRunOperator 2023-02-14T22:11:51.547350+00:00 2023-02-14T22:11:52.025060+00:00 0:00:00.477710 339842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T22:11:49.202445+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T21:00:00+00:00 EmrJobFlowSensor 2023-02-14T22:01:25.424400+00:00 2023-02-14T22:11:27.614347+00:00 0:10:02.189947 339835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T22:01:22.749370+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T22:01:03.088747+00:00 2023-02-14T22:01:04.140937+00:00 0:00:01.052190 339833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T22:01:00.724861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T21:00:00+00:00 PythonOperator 2023-02-14T22:00:19.120980+00:00 2023-02-14T22:00:23.158222+00:00 0:00:04.037242 339831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T22:00:16.709188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T20:00:00+00:00 TriggerDagRunOperator 2023-02-14T21:12:06.938560+00:00 2023-02-14T21:12:07.425259+00:00 0:00:00.486699 339817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T21:12:04.430761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T20:00:00+00:00 TriggerDagRunOperator 2023-02-14T21:12:06.816155+00:00 2023-02-14T21:12:07.295515+00:00 0:00:00.479360 339816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T21:12:04.430789+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T20:00:00+00:00 EmrJobFlowSensor 2023-02-14T21:01:45.422592+00:00 2023-02-14T21:11:47.226821+00:00 0:10:01.804229 339811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T21:01:42.841374+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T21:01:22.947736+00:00 2023-02-14T21:01:23.787902+00:00 0:00:00.840166 339809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T21:01:20.814035+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T20:00:00+00:00 PythonOperator 2023-02-14T21:00:19.644426+00:00 2023-02-14T21:00:22.609912+00:00 0:00:02.965486 339805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T21:00:17.203429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T19:00:00+00:00 TriggerDagRunOperator 2023-02-14T20:11:56.455752+00:00 2023-02-14T20:11:56.951148+00:00 0:00:00.495396 339791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T20:11:53.729909+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T19:00:00+00:00 TriggerDagRunOperator 2023-02-14T20:11:56.317660+00:00 2023-02-14T20:11:56.777022+00:00 0:00:00.459362 339790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T20:11:53.729865+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T19:00:00+00:00 EmrJobFlowSensor 2023-02-14T20:01:33.867414+00:00 2023-02-14T20:11:35.795665+00:00 0:10:01.928251 339785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T20:01:30.807146+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T20:01:12.980229+00:00 2023-02-14T20:01:13.878744+00:00 0:00:00.898515 339783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T20:01:10.780775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T19:00:00+00:00 PythonOperator 2023-02-14T20:00:13.047538+00:00 2023-02-14T20:00:17.747028+00:00 0:00:04.699490 339779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T20:00:10.838132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T18:00:00+00:00 TriggerDagRunOperator 2023-02-14T19:16:13.746822+00:00 2023-02-14T19:16:14.233321+00:00 0:00:00.486499 339766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T19:16:10.000663+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T18:00:00+00:00 TriggerDagRunOperator 2023-02-14T19:16:12.906753+00:00 2023-02-14T19:16:13.360480+00:00 0:00:00.453727 339765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T19:16:10.000691+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T18:00:00+00:00 EmrJobFlowSensor 2023-02-14T19:00:59.894044+00:00 2023-02-14T19:11:01.930414+00:00 0:10:02.036370 339758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T19:00:57.652419+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T19:00:40.190588+00:00 2023-02-14T19:00:41.037427+00:00 0:00:00.846839 339756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T19:00:35.644101+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T18:00:00+00:00 PythonOperator 2023-02-14T19:00:18.211437+00:00 2023-02-14T19:00:21.261050+00:00 0:00:03.049613 339754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T19:00:15.556960+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T17:00:00+00:00 TriggerDagRunOperator 2023-02-14T18:11:13.796990+00:00 2023-02-14T18:11:14.319377+00:00 0:00:00.522387 339740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T18:11:11.001153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T17:00:00+00:00 TriggerDagRunOperator 2023-02-14T18:11:13.514969+00:00 2023-02-14T18:11:13.975691+00:00 0:00:00.460722 339739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T18:11:11.001125+00:00 2 default_pool