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 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
success vc-asset-import_v002 check_cluster_status 2021-03-24T02:05:00+00:00 EmrJobFlowSensor 2021-03-24T03:06:08.625332+00:00 2021-03-24T03:15:11.348666+00:00 0:09:02.723334 11102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T03:06:06.324927+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T02:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T03:05:46.530191+00:00 2021-03-24T03:05:48.216043+00:00 0:00:01.685852 11101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T03:05:44.307828+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T02:05:00+00:00 PythonOperator 2021-03-24T03:05:24.707343+00:00 2021-03-24T03:05:27.493653+00:00 0:00:02.786310 11100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T03:05:22.389634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T02:00:00+00:00 EmrJobFlowSensor 2021-03-24T03:00:58.037626+00:00 2021-03-24T03:10:00.925710+00:00 0:09:02.888084 11099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T03:00:55.906143+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T03:00:36.237311+00:00 2021-03-24T03:00:38.021845+00:00 0:00:01.784534 11098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T03:00:33.892138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T02:00:00+00:00 PythonOperator 2021-03-24T03:00:14.332562+00:00 2021-03-24T03:00:17.076680+00:00 0:00:02.744118 11097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T03:00:11.821359+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T01:00:00+00:00 EmrJobFlowSensor 2021-03-24T02:12:35.917099+00:00 2021-03-24T02:22:38.825376+00:00 0:10:02.908277 11095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:12:33.598252+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T01:00:00+00:00 EmrJobFlowSensor 2021-03-24T02:12:22.095986+00:00 2021-03-24T02:21:24.931671+00:00 0:09:02.835685 11094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:12:19.651801+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:12:11.811370+00:00 2021-03-24T02:12:13.566838+00:00 0:00:01.755468 11093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T02:12:09.571893+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:11:51.756951+00:00 2021-03-24T02:11:53.512983+00:00 0:00:01.756032 11092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T02:11:49.553529+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T01:00:00+00:00 PythonOperator 2021-03-24T02:11:45.762928+00:00 2021-03-24T02:11:48.668677+00:00 0:00:02.905749 11091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:11:43.543114+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T01:00:00+00:00 PythonOperator 2021-03-24T02:11:25.785953+00:00 2021-03-24T02:11:28.554565+00:00 0:00:02.768612 11090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:11:23.618494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T01:00:00+00:00 TriggerDagRunOperator 2021-03-24T02:11:21.840804+00:00 2021-03-24T02:11:22.345207+00:00 0:00:00.504403 11089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:11:19.523262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T01:00:00+00:00 TriggerDagRunOperator 2021-03-24T02:11:21.701158+00:00 2021-03-24T02:11:22.111147+00:00 0:00:00.409989 11088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:11:19.523230+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T01:05:00+00:00 EmrJobFlowSensor 2021-03-24T02:06:05.496252+00:00 2021-03-24T02:15:08.142614+00:00 0:09:02.646362 11087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:06:03.088066+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T01:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:05:43.078935+00:00 2021-03-24T02:05:44.705356+00:00 0:00:01.626421 11086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T02:05:40.951667+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T01:05:00+00:00 PythonOperator 2021-03-24T02:05:23.184516+00:00 2021-03-24T02:05:26.052586+00:00 0:00:02.868070 11085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:05:20.901429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T01:00:00+00:00 EmrJobFlowSensor 2021-03-24T02:01:04.808534+00:00 2021-03-24T02:11:07.980947+00:00 0:10:03.172413 11084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:01:02.494566+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:00:42.618869+00:00 2021-03-24T02:00:44.388166+00:00 0:00:01.769297 11083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T02:00:40.420450+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T01:00:00+00:00 PythonOperator 2021-03-24T02:00:21.182913+00:00 2021-03-24T02:00:23.997661+00:00 0:00:02.814748 11082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T02:00:18.464334+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T00:00:00+00:00 EmrJobFlowSensor 2021-03-24T01:12:26.883726+00:00 2021-03-24T01:22:29.635366+00:00 0:10:02.751640 11080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:12:24.465733+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T00:00:00+00:00 EmrJobFlowSensor 2021-03-24T01:12:16.660233+00:00 2021-03-24T01:21:19.456718+00:00 0:09:02.796485 11079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:12:14.399968+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:12:06.808232+00:00 2021-03-24T01:12:08.538663+00:00 0:00:01.730431 11078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T01:12:04.392891+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:11:54.652670+00:00 2021-03-24T01:11:56.303590+00:00 0:00:01.650920 11077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T01:11:52.359377+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T00:00:00+00:00 PythonOperator 2021-03-24T01:11:44.626503+00:00 2021-03-24T01:11:47.739411+00:00 0:00:03.112908 11076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:11:42.347972+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T00:00:00+00:00 PythonOperator 2021-03-24T01:11:34.618565+00:00 2021-03-24T01:11:37.320146+00:00 0:00:02.701581 11075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:11:32.340452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T00:00:00+00:00 TriggerDagRunOperator 2021-03-24T01:11:18.997495+00:00 2021-03-24T01:11:19.509036+00:00 0:00:00.511541 11074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:11:16.377286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T00:00:00+00:00 TriggerDagRunOperator 2021-03-24T01:11:18.920258+00:00 2021-03-24T01:11:19.317770+00:00 0:00:00.397512 11073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:11:16.377340+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T00:05:00+00:00 EmrJobFlowSensor 2021-03-24T01:05:50.020164+00:00 2021-03-24T01:14:52.568480+00:00 0:09:02.548316 11072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:05:47.814849+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T00:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:05:28.123426+00:00 2021-03-24T01:05:29.800964+00:00 0:00:01.677538 11071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T01:05:25.867998+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T00:05:00+00:00 PythonOperator 2021-03-24T01:05:07.873312+00:00 2021-03-24T01:05:10.534043+00:00 0:00:02.660731 11070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:05:05.738847+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T00:00:00+00:00 EmrJobFlowSensor 2021-03-24T01:00:51.595112+00:00 2021-03-24T01:10:54.444882+00:00 0:10:02.849770 11069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:00:49.283644+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:00:29.446809+00:00 2021-03-24T01:00:31.158011+00:00 0:00:01.711202 11068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T01:00:27.264642+00:00 2 default_pool