Task Instances

  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_booking-processing-job_v002 2021-03-24T09:00:00+00:00 TriggerDagRunOperator 2021-03-24T10:10:13.965165+00:00 2021-03-24T10:10:14.498750+00:00 0:00:00.533585 11209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:10:11.631480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T09:00:00+00:00 TriggerDagRunOperator 2021-03-24T10:10:13.959410+00:00 2021-03-24T10:10:14.414180+00:00 0:00:00.454770 11208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:10:11.631451+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T09:05:00+00:00 EmrJobFlowSensor 2021-03-24T10:06:07.500840+00:00 2021-03-24T10:14:10.039183+00:00 0:08:02.538343 11207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:06:05.143267+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:05:45.329093+00:00 2021-03-24T10:05:46.944756+00:00 0:00:01.615663 11206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T10:05:43.044242+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T09:05:00+00:00 PythonOperator 2021-03-24T10:05:25.117086+00:00 2021-03-24T10:05:27.809820+00:00 0:00:02.692734 11205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:05:22.955947+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T09:00:00+00:00 EmrJobFlowSensor 2021-03-24T10:00:50.606476+00:00 2021-03-24T10:09:53.176774+00:00 0:09:02.570298 11204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:00:48.441017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:00:30.917730+00:00 2021-03-24T10:00:32.615047+00:00 0:00:01.697317 11203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T10:00:28.482179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T09:00:00+00:00 PythonOperator 2021-03-24T10:00:08.795350+00:00 2021-03-24T10:00:11.623989+00:00 0:00:02.828639 11202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T10:00:06.389438+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:12:28.931855+00:00 2021-03-24T09:21:31.476258+00:00 0:09:02.544403 11200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:12:26.459025+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:12:12.744204+00:00 2021-03-24T09:21:15.489538+00:00 0:09:02.745334 11199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:12:10.397079+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:12:08.910010+00:00 2021-03-24T09:12:10.713706+00:00 0:00:01.803696 11198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:12:06.460112+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:11:50.490115+00:00 2021-03-24T09:11:52.187103+00:00 0:00:01.696988 11197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:11:48.332604+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:11:36.769487+00:00 2021-03-24T09:11:39.457397+00:00 0:00:02.687910 11196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:11:34.322864+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:11:24.611038+00:00 2021-03-24T09:11:27.570498+00:00 0:00:02.959460 11195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:11:22.324192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T08:00:00+00:00 TriggerDagRunOperator 2021-03-24T09:11:18.598499+00:00 2021-03-24T09:11:19.018245+00:00 0:00:00.419746 11194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:11:16.302638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T08:00:00+00:00 TriggerDagRunOperator 2021-03-24T09:11:18.531044+00:00 2021-03-24T09:11:19.041488+00:00 0:00:00.510444 11193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:11:16.302586+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T08:05:00+00:00 EmrJobFlowSensor 2021-03-24T09:06:05.962774+00:00 2021-03-24T09:16:08.701095+00:00 0:10:02.738321 11192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:06:03.635645+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:05:45.690581+00:00 2021-03-24T09:05:47.405186+00:00 0:00:01.714605 11191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:05:43.522062+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T08:05:00+00:00 PythonOperator 2021-03-24T09:05:23.855570+00:00 2021-03-24T09:05:26.689208+00:00 0:00:02.833638 11190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:05:21.504040+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:00:55.130767+00:00 2021-03-24T09:10:57.783478+00:00 0:10:02.652711 11189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:00:52.902688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:00:33.310815+00:00 2021-03-24T09:00:35.106140+00:00 0:00:01.795325 11188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T09:00:30.950081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:00:11.624755+00:00 2021-03-24T09:00:14.405301+00:00 0:00:02.780546 11187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T09:00:08.789147+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:11:10.014225+00:00 2021-03-24T08:20:12.712158+00:00 0:09:02.697933 11185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:11:07.723284+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:11:03.877483+00:00 2021-03-24T08:19:06.342394+00:00 0:08:02.464911 11184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:11:01.726420+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:10:46.196589+00:00 2021-03-24T08:10:47.982700+00:00 0:00:01.786111 11183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:10:43.707879+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:10:42.191941+00:00 2021-03-24T08:10:44.068483+00:00 0:00:01.876542 11182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:10:39.766215+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:10:26.232697+00:00 2021-03-24T08:10:29.128485+00:00 0:00:02.895788 11181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:10:23.759194+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:10:21.824484+00:00 2021-03-24T08:10:24.642776+00:00 0:00:02.818292 11180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:10:19.684107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T07:00:00+00:00 TriggerDagRunOperator 2021-03-24T08:10:08.155217+00:00 2021-03-24T08:10:08.594584+00:00 0:00:00.439367 11179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:10:05.623073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T07:00:00+00:00 TriggerDagRunOperator 2021-03-24T08:10:07.904770+00:00 2021-03-24T08:10:08.461302+00:00 0:00:00.556532 11178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:10:05.623045+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T07:05:00+00:00 EmrJobFlowSensor 2021-03-24T08:05:51.308153+00:00 2021-03-24T08:13:53.713162+00:00 0:08:02.405009 11177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:05:49.160618+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:05:31.637411+00:00 2021-03-24T08:05:33.289917+00:00 0:00:01.652506 11176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:05:29.160580+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T07:05:00+00:00 PythonOperator 2021-03-24T08:05:09.552301+00:00 2021-03-24T08:05:12.262043+00:00 0:00:02.709742 11175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:05:07.087851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:00:59.019118+00:00 2021-03-24T08:10:01.650128+00:00 0:09:02.631010 11174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:00:56.424252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:00:36.957400+00:00 2021-03-24T08:00:38.772637+00:00 0:00:01.815237 11173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T08:00:34.474957+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:00:15.159478+00:00 2021-03-24T08:00:18.032593+00:00 0:00:02.873115 11172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T08:00:12.388039+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T06:00:00+00:00 EmrJobFlowSensor 2021-03-24T07:11:23.859214+00:00 2021-03-24T07:20:26.630766+00:00 0:09:02.771552 11170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:11:20.966912+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T06:00:00+00:00 EmrJobFlowSensor 2021-03-24T07:11:21.653821+00:00 2021-03-24T07:21:24.857819+00:00 0:10:03.203998 11169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:11:19.069585+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:11:01.663919+00:00 2021-03-24T07:11:03.445492+00:00 0:00:01.781573 11168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T07:10:58.852991+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:10:59.258057+00:00 2021-03-24T07:11:01.235454+00:00 0:00:01.977397 11167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T07:10:56.778142+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T06:00:00+00:00 PythonOperator 2021-03-24T07:10:39.143966+00:00 2021-03-24T07:10:42.146330+00:00 0:00:03.002364 11166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:10:36.691676+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T06:00:00+00:00 PythonOperator 2021-03-24T07:10:39.044136+00:00 2021-03-24T07:10:41.857911+00:00 0:00:02.813775 11165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:10:36.691645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T06:00:00+00:00 TriggerDagRunOperator 2021-03-24T07:10:31.297190+00:00 2021-03-24T07:10:31.720742+00:00 0:00:00.423552 11164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:10:28.576717+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T06:00:00+00:00 TriggerDagRunOperator 2021-03-24T07:10:31.296917+00:00 2021-03-24T07:10:31.833196+00:00 0:00:00.536279 11163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:10:28.576673+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T06:05:00+00:00 EmrJobFlowSensor 2021-03-24T07:05:50.069478+00:00 2021-03-24T07:13:52.349931+00:00 0:08:02.280453 11162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T07:05:47.927733+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T06:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:05:30.278341+00:00 2021-03-24T07:05:32.083649+00:00 0:00:01.805308 11161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T07:05:27.910501+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T06:05:00+00:00 PythonOperator 2021-03-24T07:05:08.202477+00:00 2021-03-24T07:05:10.867097+00:00 0:00:02.664620 11160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:05:05.889484+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T06:00:00+00:00 EmrJobFlowSensor 2021-03-24T07:01:03.750242+00:00 2021-03-24T07:10:06.620989+00:00 0:09:02.870747 11159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T07:01:01.459384+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T07:00:41.607449+00:00 2021-03-24T07:00:43.337219+00:00 0:00:01.729770 11158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T07:00:39.418209+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T06:00:00+00:00 PythonOperator 2021-03-24T07:00:20.001439+00:00 2021-03-24T07:00:22.745514+00:00 0:00:02.744075 11157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T07:00:17.476587+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T05:00:00+00:00 EmrJobFlowSensor 2021-03-24T06:12:41.583824+00:00 2021-03-24T06:21:44.218820+00:00 0:09:02.634996 11155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:12:39.253802+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T05:00:00+00:00 EmrJobFlowSensor 2021-03-24T06:12:35.609906+00:00 2021-03-24T06:21:38.179265+00:00 0:09:02.569359 11154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:12:33.187948+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:12:19.467917+00:00 2021-03-24T06:12:21.165069+00:00 0:00:01.697152 11153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T06:12:17.151285+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:12:15.633149+00:00 2021-03-24T06:12:17.362792+00:00 0:00:01.729643 11152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T06:12:13.172516+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T05:00:00+00:00 PythonOperator 2021-03-24T06:11:59.312839+00:00 2021-03-24T06:12:02.336921+00:00 0:00:03.024082 11151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:11:57.073784+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T05:00:00+00:00 PythonOperator 2021-03-24T06:11:53.337811+00:00 2021-03-24T06:11:56.071503+00:00 0:00:02.733692 11150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:11:51.064602+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T05:00:00+00:00 TriggerDagRunOperator 2021-03-24T06:11:37.366338+00:00 2021-03-24T06:11:37.811644+00:00 0:00:00.445306 11149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:11:35.051217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T05:00:00+00:00 TriggerDagRunOperator 2021-03-24T06:11:37.382164+00:00 2021-03-24T06:11:37.947620+00:00 0:00:00.565456 11148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:11:35.051254+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T05:05:00+00:00 EmrJobFlowSensor 2021-03-24T06:05:56.601970+00:00 2021-03-24T06:14:59.085441+00:00 0:09:02.483471 11147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T06:05:54.436072+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T05:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:05:34.903848+00:00 2021-03-24T06:05:36.530750+00:00 0:00:01.626902 11146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T06:05:32.411375+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T05:05:00+00:00 PythonOperator 2021-03-24T06:05:12.674974+00:00 2021-03-24T06:05:15.478461+00:00 0:00:02.803487 11145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:05:10.395567+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T05:00:00+00:00 EmrJobFlowSensor 2021-03-24T06:01:16.273405+00:00 2021-03-24T06:11:19.031568+00:00 0:10:02.758163 11144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T06:01:14.023723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T06:00:52.283741+00:00 2021-03-24T06:00:54.080246+00:00 0:00:01.796505 11143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T06:00:49.998199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T05:00:00+00:00 PythonOperator 2021-03-24T06:00:18.407846+00:00 2021-03-24T06:00:21.146727+00:00 0:00:02.738881 11142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T06:00:15.972374+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T04:00:00+00:00 EmrJobFlowSensor 2021-03-24T05:11:37.820708+00:00 2021-03-24T05:20:40.590569+00:00 0:09:02.769861 11140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:11:35.599224+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T04:00:00+00:00 EmrJobFlowSensor 2021-03-24T05:11:35.980916+00:00 2021-03-24T05:21:38.669002+00:00 0:10:02.688086 11139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:11:33.667567+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:11:18.511135+00:00 2021-03-24T05:11:20.256701+00:00 0:00:01.745566 11138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T05:11:15.584118+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:11:16.216612+00:00 2021-03-24T05:11:18.357447+00:00 0:00:02.140835 11137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T05:11:13.663757+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T04:00:00+00:00 PythonOperator 2021-03-24T05:10:55.870489+00:00 2021-03-24T05:10:58.702529+00:00 0:00:02.832040 11136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:10:53.538858+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T04:00:00+00:00 PythonOperator 2021-03-24T05:10:53.703497+00:00 2021-03-24T05:10:56.716143+00:00 0:00:03.012646 11135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:10:51.535382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T04:00:00+00:00 TriggerDagRunOperator 2021-03-24T05:10:35.839586+00:00 2021-03-24T05:10:36.332406+00:00 0:00:00.492820 11134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:10:33.521738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T04:00:00+00:00 TriggerDagRunOperator 2021-03-24T05:10:35.675779+00:00 2021-03-24T05:10:36.086939+00:00 0:00:00.411160 11133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:10:33.521769+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T04:05:00+00:00 EmrJobFlowSensor 2021-03-24T05:05:51.153146+00:00 2021-03-24T05:14:53.819702+00:00 0:09:02.666556 11132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T05:05:48.911120+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T04:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:05:29.252730+00:00 2021-03-24T05:05:30.967539+00:00 0:00:01.714809 11131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T05:05:26.889666+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T04:05:00+00:00 PythonOperator 2021-03-24T05:05:08.990463+00:00 2021-03-24T05:05:11.692142+00:00 0:00:02.701679 11130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:05:06.837771+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T04:00:00+00:00 EmrJobFlowSensor 2021-03-24T05:01:08.860539+00:00 2021-03-24T05:10:11.658983+00:00 0:09:02.798444 11129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T05:01:06.537297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T05:00:46.962428+00:00 2021-03-24T05:00:48.769401+00:00 0:00:01.806973 11128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T05:00:44.573913+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T04:00:00+00:00 PythonOperator 2021-03-24T05:00:25.164357+00:00 2021-03-24T05:00:27.916003+00:00 0:00:02.751646 11127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T05:00:22.572978+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T03:00:00+00:00 EmrJobFlowSensor 2021-03-24T04:11:34.220101+00:00 2021-03-24T04:21:37.022668+00:00 0:10:02.802567 11125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T04:11:31.839735+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T03:00:00+00:00 EmrJobFlowSensor 2021-03-24T04:11:18.096890+00:00 2021-03-24T04:20:20.820415+00:00 0:09:02.723525 11124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T04:11:15.820121+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T04:11:00.183394+00:00 2021-03-24T04:11:01.990471+00:00 0:00:01.807077 11123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T04:10:57.813357+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T04:10:54.281146+00:00 2021-03-24T04:10:55.949259+00:00 0:00:01.668113 11122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T04:10:51.806192+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T03:00:00+00:00 PythonOperator 2021-03-24T04:10:37.978964+00:00 2021-03-24T04:10:40.906665+00:00 0:00:02.927701 11121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T04:10:35.792980+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T03:00:00+00:00 PythonOperator 2021-03-24T04:10:32.505028+00:00 2021-03-24T04:10:35.283467+00:00 0:00:02.778439 11120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T04:10:29.940854+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T03:00:00+00:00 TriggerDagRunOperator 2021-03-24T04:10:16.194752+00:00 2021-03-24T04:10:16.699301+00:00 0:00:00.504549 11119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T04:10:13.769279+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T03:00:00+00:00 TriggerDagRunOperator 2021-03-24T04:10:15.943209+00:00 2021-03-24T04:10:16.330033+00:00 0:00:00.386824 11118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T04:10:13.769314+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T03:05:00+00:00 EmrJobFlowSensor 2021-03-24T04:05:47.611745+00:00 2021-03-24T04:14:50.219772+00:00 0:09:02.608027 11117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T04:05:45.384909+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T03:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T04:05:25.787549+00:00 2021-03-24T04:05:27.536893+00:00 0:00:01.749344 11116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T04:05:23.343843+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T03:05:00+00:00 PythonOperator 2021-03-24T04:05:03.685860+00:00 2021-03-24T04:05:06.496932+00:00 0:00:02.811072 11115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T04:05:01.359992+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T03:00:00+00:00 EmrJobFlowSensor 2021-03-24T04:00:55.309296+00:00 2021-03-24T04:09:57.923619+00:00 0:09:02.614323 11114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T04:00:53.004781+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T04:00:33.203541+00:00 2021-03-24T04:00:34.996944+00:00 0:00:01.793403 11113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T04:00:30.995498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T03:00:00+00:00 PythonOperator 2021-03-24T04:00:11.226348+00:00 2021-03-24T04:00:14.061978+00:00 0:00:02.835630 11112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T04:00:08.919865+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T02:00:00+00:00 EmrJobFlowSensor 2021-03-24T03:11:13.305993+00:00 2021-03-24T03:20:15.970415+00:00 0:09:02.664422 11110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T03:11:11.088186+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T02:00:00+00:00 EmrJobFlowSensor 2021-03-24T03:11:13.328064+00:00 2021-03-24T03:20:16.135631+00:00 0:09:02.807567 11109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T03:11:11.088215+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T03:10:53.665566+00:00 2021-03-24T03:10:55.369297+00:00 0:00:01.703731 11108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T03:10:50.928236+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T03:10:51.249032+00:00 2021-03-24T03:10:53.274454+00:00 0:00:02.025422 11107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T03:10:48.986505+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T02:00:00+00:00 PythonOperator 2021-03-24T03:10:31.693247+00:00 2021-03-24T03:10:34.506863+00:00 0:00:02.813616 11106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T03:10:28.914593+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T02:00:00+00:00 PythonOperator 2021-03-24T03:10:31.596587+00:00 2021-03-24T03:10:34.605761+00:00 0:00:03.009174 11105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T03:10:28.914624+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T02:00:00+00:00 TriggerDagRunOperator 2021-03-24T03:10:19.514602+00:00 2021-03-24T03:10:20.029340+00:00 0:00:00.514738 11104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T03:10:16.941323+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T02:00:00+00:00 TriggerDagRunOperator 2021-03-24T03:10:19.368339+00:00 2021-03-24T03:10:19.868549+00:00 0:00:00.500210 11103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T03:10:16.941276+00:00 2 default_pool