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-history-job_v002 create_emr_steps 2021-03-24T17:00:00+00:00 PythonOperator 2021-03-24T18:11:31.781977+00:00 2021-03-24T18:11:34.519889+00:00 0:00:02.737912 11330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T18:11:29.627614+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T17:00:00+00:00 PythonOperator 2021-03-24T18:11:16.097475+00:00 2021-03-24T18:11:19.293534+00:00 0:00:03.196059 11329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T18:11:13.580591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T17:00:00+00:00 TriggerDagRunOperator 2021-03-24T18:11:06.000156+00:00 2021-03-24T18:11:06.518875+00:00 0:00:00.518719 11328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T18:11:03.528237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T17:00:00+00:00 TriggerDagRunOperator 2021-03-24T18:11:05.821976+00:00 2021-03-24T18:11:06.210691+00:00 0:00:00.388715 11327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T18:11:03.528209+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T17:05:00+00:00 EmrJobFlowSensor 2021-03-24T18:05:59.109685+00:00 2021-03-24T18:15:01.607067+00:00 0:09:02.497382 11326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T18:05:56.974616+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T18:05:39.102189+00:00 2021-03-24T18:05:40.724933+00:00 0:00:01.622744 11325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T18:05:36.957358+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T17:05:00+00:00 PythonOperator 2021-03-24T18:05:17.066858+00:00 2021-03-24T18:05:19.768981+00:00 0:00:02.702123 11324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T18:05:14.936770+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T17:00:00+00:00 EmrJobFlowSensor 2021-03-24T18:00:50.863173+00:00 2021-03-24T18:10:53.788682+00:00 0:10:02.925509 11323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T18:00:48.600170+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T18:00:28.810761+00:00 2021-03-24T18:00:30.496453+00:00 0:00:01.685692 11322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T18:00:26.527013+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T17:00:00+00:00 PythonOperator 2021-03-24T18:00:08.805669+00:00 2021-03-24T18:00:11.547376+00:00 0:00:02.741707 11321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T18:00:06.510463+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T16:00:00+00:00 EmrJobFlowSensor 2021-03-24T17:12:18.934114+00:00 2021-03-24T17:21:21.588710+00:00 0:09:02.654596 11319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:12:16.624481+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T16:00:00+00:00 EmrJobFlowSensor 2021-03-24T17:12:10.790646+00:00 2021-03-24T17:20:13.333589+00:00 0:08:02.542943 11318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:12:08.618841+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T17:11:56.953739+00:00 2021-03-24T17:11:58.758024+00:00 0:00:01.804285 11317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T17:11:54.606703+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T17:11:49.124144+00:00 2021-03-24T17:11:50.911229+00:00 0:00:01.787085 11316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T17:11:46.643867+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T16:00:00+00:00 PythonOperator 2021-03-24T17:11:34.908301+00:00 2021-03-24T17:11:37.939842+00:00 0:00:03.031541 11315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T17:11:32.591565+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T16:00:00+00:00 PythonOperator 2021-03-24T17:11:27.001187+00:00 2021-03-24T17:11:29.798031+00:00 0:00:02.796844 11314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T17:11:24.581593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T16:00:00+00:00 TriggerDagRunOperator 2021-03-24T17:11:10.940174+00:00 2021-03-24T17:11:11.378462+00:00 0:00:00.438288 11313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:11:08.580504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T16:00:00+00:00 TriggerDagRunOperator 2021-03-24T17:11:10.911656+00:00 2021-03-24T17:11:11.443231+00:00 0:00:00.531575 11312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:11:08.580473+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T16:05:00+00:00 EmrJobFlowSensor 2021-03-24T17:06:04.573159+00:00 2021-03-24T17:14:07.085627+00:00 0:08:02.512468 11311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T17:06:02.060295+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T16:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T17:05:42.170078+00:00 2021-03-24T17:05:43.947636+00:00 0:00:01.777558 11310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T17:05:39.957166+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T16:05:00+00:00 PythonOperator 2021-03-24T17:05:21.974722+00:00 2021-03-24T17:05:24.655360+00:00 0:00:02.680638 11309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T17:05:19.815990+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T16:00:00+00:00 EmrJobFlowSensor 2021-03-24T17:00:47.573022+00:00 2021-03-24T17:10:50.374864+00:00 0:10:02.801842 11308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T17:00:45.259094+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T17:00:25.475040+00:00 2021-03-24T17:00:27.220188+00:00 0:00:01.745148 11307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T17:00:23.219490+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T16:00:00+00:00 PythonOperator 2021-03-24T17:00:05.616683+00:00 2021-03-24T17:00:08.429712+00:00 0:00:02.813029 11306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T17:00:03.210720+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T15:00:00+00:00 EmrJobFlowSensor 2021-03-24T16:14:24.765151+00:00 2021-03-24T16:23:27.490272+00:00 0:09:02.725121 11305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:14:22.495852+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T15:00:00+00:00 EmrJobFlowSensor 2021-03-24T16:14:16.882041+00:00 2021-03-24T16:22:19.431965+00:00 0:08:02.549924 11304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:14:14.556700+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T16:14:02.646171+00:00 2021-03-24T16:14:04.438098+00:00 0:00:01.791927 11303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T16:14:00.438688+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T16:13:48.884365+00:00 2021-03-24T16:13:50.574044+00:00 0:00:01.689679 11302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T16:13:46.421997+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T15:00:00+00:00 PythonOperator 2021-03-24T16:13:38.626034+00:00 2021-03-24T16:13:41.531400+00:00 0:00:02.905366 11301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T16:13:36.413861+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T15:00:00+00:00 PythonOperator 2021-03-24T16:13:22.572363+00:00 2021-03-24T16:13:25.272596+00:00 0:00:02.700233 11300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T16:13:20.399021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T15:00:00+00:00 TriggerDagRunOperator 2021-03-24T16:13:17.390701+00:00 2021-03-24T16:13:18.032940+00:00 0:00:00.642239 11299 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:13:14.335755+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T15:00:00+00:00 TriggerDagRunOperator 2021-03-24T16:13:17.172870+00:00 2021-03-24T16:13:17.695867+00:00 0:00:00.522997 11298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:13:14.335783+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T15:05:00+00:00 EmrJobFlowSensor 2021-03-24T16:06:01.757610+00:00 2021-03-24T16:14:04.355858+00:00 0:08:02.598248 11296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T16:05:59.359528+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T16:05:39.283581+00:00 2021-03-24T16:05:40.915675+00:00 0:00:01.632094 11295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T16:05:37.188573+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T15:05:00+00:00 PythonOperator 2021-03-24T16:05:17.276273+00:00 2021-03-24T16:05:20.086839+00:00 0:00:02.810566 11294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T16:05:15.107486+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T15:00:00+00:00 EmrJobFlowSensor 2021-03-24T16:01:04.820949+00:00 2021-03-24T16:11:07.639424+00:00 0:10:02.818475 11293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T16:01:02.686326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T16:00:40.915054+00:00 2021-03-24T16:00:42.724208+00:00 0:00:01.809154 11292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T16:00:38.640782+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T15:00:00+00:00 PythonOperator 2021-03-24T16:00:18.914652+00:00 2021-03-24T16:00:21.784033+00:00 0:00:02.869381 11291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T16:00:16.597424+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T14:00:00+00:00 EmrJobFlowSensor 2021-03-24T15:12:24.389688+00:00 2021-03-24T15:21:26.975899+00:00 0:09:02.586211 11290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:12:22.051259+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T14:00:00+00:00 EmrJobFlowSensor 2021-03-24T15:12:12.195544+00:00 2021-03-24T15:22:15.076807+00:00 0:10:02.881263 11289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:12:09.986465+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:12:04.388294+00:00 2021-03-24T15:12:06.092610+00:00 0:00:01.704316 11288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T15:12:01.954539+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:11:52.376683+00:00 2021-03-24T15:11:54.076488+00:00 0:00:01.699805 11287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T15:11:49.944473+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T14:00:00+00:00 PythonOperator 2021-03-24T15:11:42.583080+00:00 2021-03-24T15:11:45.291271+00:00 0:00:02.708191 11286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:11:39.897991+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T14:00:00+00:00 PythonOperator 2021-03-24T15:11:30.685696+00:00 2021-03-24T15:11:33.610945+00:00 0:00:02.925249 11285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:11:27.940943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T14:00:00+00:00 TriggerDagRunOperator 2021-03-24T15:11:18.149832+00:00 2021-03-24T15:11:18.694944+00:00 0:00:00.545112 11284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:11:15.721460+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T14:00:00+00:00 TriggerDagRunOperator 2021-03-24T15:11:17.893149+00:00 2021-03-24T15:11:18.293593+00:00 0:00:00.400444 11283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:11:15.721425+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T14:05:00+00:00 EmrJobFlowSensor 2021-03-24T15:07:33.667053+00:00 2021-03-24T15:17:36.517259+00:00 0:10:02.850206 11282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T15:07:31.473221+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:07:11.581866+00:00 2021-03-24T15:07:13.239813+00:00 0:00:01.657947 11281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T15:07:09.390993+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T14:05:00+00:00 PythonOperator 2021-03-24T15:06:49.656817+00:00 2021-03-24T15:06:52.353779+00:00 0:00:02.696962 11280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:06:47.372773+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T14:00:00+00:00 EmrJobFlowSensor 2021-03-24T15:01:05.653113+00:00 2021-03-24T15:11:08.620373+00:00 0:10:02.967260 11278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:01:03.111201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:00:41.446303+00:00 2021-03-24T15:00:43.138804+00:00 0:00:01.692501 11277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T15:00:39.161948+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T14:00:00+00:00 PythonOperator 2021-03-24T15:00:21.186396+00:00 2021-03-24T15:00:24.078532+00:00 0:00:02.892136 11276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T15:00:18.995450+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T13:00:00+00:00 EmrJobFlowSensor 2021-03-24T14:14:18.070661+00:00 2021-03-24T14:24:20.788119+00:00 0:10:02.717458 11275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:14:15.894137+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T13:00:00+00:00 EmrJobFlowSensor 2021-03-24T14:14:12.004829+00:00 2021-03-24T14:24:14.932020+00:00 0:10:02.927191 11274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:14:09.824650+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:13:56.180096+00:00 2021-03-24T14:13:57.851919+00:00 0:00:01.671823 11273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T14:13:53.818940+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:13:52.119867+00:00 2021-03-24T14:13:53.807428+00:00 0:00:01.687561 11272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T14:13:49.811613+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T13:00:00+00:00 PythonOperator 2021-03-24T14:13:34.192426+00:00 2021-03-24T14:13:37.087285+00:00 0:00:02.894859 11271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:13:31.864016+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T13:00:00+00:00 PythonOperator 2021-03-24T14:13:30.373064+00:00 2021-03-24T14:13:33.356546+00:00 0:00:02.983482 11270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:13:27.756008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T13:00:00+00:00 TriggerDagRunOperator 2021-03-24T14:13:14.186840+00:00 2021-03-24T14:13:14.620112+00:00 0:00:00.433272 11269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:13:11.674663+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T13:00:00+00:00 TriggerDagRunOperator 2021-03-24T14:13:14.073065+00:00 2021-03-24T14:13:14.623526+00:00 0:00:00.550461 11268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:13:11.674616+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T13:05:00+00:00 EmrJobFlowSensor 2021-03-24T14:06:05.441534+00:00 2021-03-24T14:15:07.996828+00:00 0:09:02.555294 11267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:06:03.143673+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:05:43.357958+00:00 2021-03-24T14:05:45.171047+00:00 0:00:01.813089 11266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T14:05:41.075448+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T13:05:00+00:00 PythonOperator 2021-03-24T14:05:21.229379+00:00 2021-03-24T14:05:23.965271+00:00 0:00:02.735892 11265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:05:19.052088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T13:00:00+00:00 EmrJobFlowSensor 2021-03-24T14:02:55.139191+00:00 2021-03-24T14:12:57.852186+00:00 0:10:02.712995 11264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:02:52.773358+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:02:35.148490+00:00 2021-03-24T14:02:36.942857+00:00 0:00:01.794367 11263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T14:02:32.753492+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T13:00:00+00:00 PythonOperator 2021-03-24T14:02:11.084808+00:00 2021-03-24T14:02:13.859422+00:00 0:00:02.774614 11262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T14:02:08.659497+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T12:00:00+00:00 EmrJobFlowSensor 2021-03-24T13:12:04.401852+00:00 2021-03-24T13:21:07.058935+00:00 0:09:02.657083 11260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:12:01.969860+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T12:00:00+00:00 EmrJobFlowSensor 2021-03-24T13:11:54.261825+00:00 2021-03-24T13:21:56.998403+00:00 0:10:02.736578 11259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:11:51.952225+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:11:42.306153+00:00 2021-03-24T13:11:44.112470+00:00 0:00:01.806317 11258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T13:11:39.961458+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:11:34.198320+00:00 2021-03-24T13:11:35.995252+00:00 0:00:01.796932 11257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T13:11:31.873705+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T12:00:00+00:00 PythonOperator 2021-03-24T13:11:22.068644+00:00 2021-03-24T13:11:24.990626+00:00 0:00:02.921982 11256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:11:19.818159+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T12:00:00+00:00 PythonOperator 2021-03-24T13:11:12.091629+00:00 2021-03-24T13:11:14.817176+00:00 0:00:02.725547 11255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:11:09.815352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T12:00:00+00:00 TriggerDagRunOperator 2021-03-24T13:11:06.603807+00:00 2021-03-24T13:11:06.974099+00:00 0:00:00.370292 11254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:11:03.811126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T12:00:00+00:00 TriggerDagRunOperator 2021-03-24T13:11:06.073075+00:00 2021-03-24T13:11:06.600240+00:00 0:00:00.527165 11253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:11:03.811168+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T12:05:00+00:00 EmrJobFlowSensor 2021-03-24T13:06:05.490067+00:00 2021-03-24T13:15:08.047583+00:00 0:09:02.557516 11252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:06:03.339832+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:05:43.636473+00:00 2021-03-24T13:05:45.371161+00:00 0:00:01.734688 11251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T13:05:41.324413+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T12:05:00+00:00 PythonOperator 2021-03-24T13:05:23.775686+00:00 2021-03-24T13:05:26.697836+00:00 0:00:02.922150 11250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:05:21.304714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T12:00:00+00:00 EmrJobFlowSensor 2021-03-24T13:00:51.133828+00:00 2021-03-24T13:10:53.986946+00:00 0:10:02.853118 11249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:00:48.901964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:00:29.254487+00:00 2021-03-24T13:00:30.954782+00:00 0:00:01.700295 11248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T13:00:26.947298+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T12:00:00+00:00 PythonOperator 2021-03-24T13:00:09.623925+00:00 2021-03-24T13:00:12.534306+00:00 0:00:02.910381 11247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T13:00:06.863989+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T11:00:00+00:00 EmrJobFlowSensor 2021-03-24T12:12:15.305703+00:00 2021-03-24T12:22:18.120521+00:00 0:10:02.814818 11245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:12:12.955812+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T11:00:00+00:00 EmrJobFlowSensor 2021-03-24T12:12:13.099611+00:00 2021-03-24T12:21:15.650914+00:00 0:09:02.551303 11244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:12:10.885778+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:11:55.145590+00:00 2021-03-24T12:11:56.841529+00:00 0:00:01.695939 11243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T12:11:52.871421+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:11:51.123347+00:00 2021-03-24T12:11:52.919090+00:00 0:00:01.795743 11242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T12:11:48.858549+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T11:00:00+00:00 PythonOperator 2021-03-24T12:11:33.069140+00:00 2021-03-24T12:11:36.036109+00:00 0:00:02.966969 11241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:11:30.843389+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T11:00:00+00:00 PythonOperator 2021-03-24T12:11:31.224640+00:00 2021-03-24T12:11:34.043316+00:00 0:00:02.818676 11240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:11:28.858262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T11:00:00+00:00 TriggerDagRunOperator 2021-03-24T12:11:07.375328+00:00 2021-03-24T12:11:07.928870+00:00 0:00:00.553542 11239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:11:04.780312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T11:00:00+00:00 TriggerDagRunOperator 2021-03-24T12:11:07.095540+00:00 2021-03-24T12:11:07.510273+00:00 0:00:00.414733 11238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:11:04.780358+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T11:05:00+00:00 EmrJobFlowSensor 2021-03-24T12:06:00.705208+00:00 2021-03-24T12:14:03.117350+00:00 0:08:02.412142 11237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:05:58.264704+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:05:38.314145+00:00 2021-03-24T12:05:40.078476+00:00 0:00:01.764331 11236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T12:05:36.128095+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T11:05:00+00:00 PythonOperator 2021-03-24T12:05:16.249926+00:00 2021-03-24T12:05:18.998543+00:00 0:00:02.748617 11235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:05:14.119393+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T11:00:00+00:00 EmrJobFlowSensor 2021-03-24T12:00:50.070356+00:00 2021-03-24T12:10:52.822037+00:00 0:10:02.751681 11234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:00:47.808438+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:00:28.088527+00:00 2021-03-24T12:00:29.772355+00:00 0:00:01.683828 11233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T12:00:25.790234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T11:00:00+00:00 PythonOperator 2021-03-24T12:00:08.083656+00:00 2021-03-24T12:00:10.814935+00:00 0:00:02.731279 11232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T12:00:05.738111+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:11:39.103995+00:00 2021-03-24T11:21:41.781652+00:00 0:10:02.677657 11230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:11:36.773501+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:11:35.033510+00:00 2021-03-24T11:21:37.922879+00:00 0:10:02.889369 11229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:11:32.711366+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:11:16.988437+00:00 2021-03-24T11:11:18.907678+00:00 0:00:01.919241 11228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T11:11:14.743393+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:11:12.954924+00:00 2021-03-24T11:11:14.691451+00:00 0:00:01.736527 11227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T11:11:10.689095+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:10:45.214490+00:00 2021-03-24T11:10:47.942717+00:00 0:00:02.728227 11226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:10:42.595224+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:10:40.825614+00:00 2021-03-24T11:10:43.937767+00:00 0:00:03.112153 11225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:10:38.596065+00:00 2 default_pool