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 booking-processing-job_v002 check_cluster_status 2021-04-23T15:00:00+00:00 EmrJobFlowSensor 2021-04-23T16:12:10.921790+00:00 2021-04-23T16:21:14.298890+00:00 0:09:03.377100 20437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T16:12:08.612693+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T16:11:56.991425+00:00 2021-04-23T16:11:58.923250+00:00 0:00:01.931825 20436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T16:11:54.597601+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T16:11:49.659491+00:00 2021-04-23T16:11:51.463748+00:00 0:00:01.804257 20435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T16:11:46.593128+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T15:00:00+00:00 PythonOperator 2021-04-23T16:11:35.289850+00:00 2021-04-23T16:11:38.267018+00:00 0:00:02.977168 20434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T16:11:32.541161+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T15:00:00+00:00 PythonOperator 2021-04-23T16:11:26.843143+00:00 2021-04-23T16:11:30.255631+00:00 0:00:03.412488 20433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T16:11:24.643544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T15:00:00+00:00 TriggerDagRunOperator 2021-04-23T16:11:15.136087+00:00 2021-04-23T16:11:15.635972+00:00 0:00:00.499885 20432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T16:11:12.587641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T15:00:00+00:00 TriggerDagRunOperator 2021-04-23T16:11:14.892379+00:00 2021-04-23T16:11:15.314726+00:00 0:00:00.422347 20431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T16:11:12.587610+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T15:05:00+00:00 EmrJobFlowSensor 2021-04-23T16:06:08.311293+00:00 2021-04-23T16:14:10.781652+00:00 0:08:02.470359 20430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T16:06:05.914894+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T16:05:46.178988+00:00 2021-04-23T16:05:47.904282+00:00 0:00:01.725294 20429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T16:05:43.947280+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T15:05:00+00:00 PythonOperator 2021-04-23T16:05:23.983475+00:00 2021-04-23T16:05:27.199918+00:00 0:00:03.216443 20428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T16:05:21.875335+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T15:00:00+00:00 EmrJobFlowSensor 2021-04-23T16:01:05.786703+00:00 2021-04-23T16:11:08.746279+00:00 0:10:02.959576 20427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T16:01:03.558854+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T16:00:43.708616+00:00 2021-04-23T16:00:45.556649+00:00 0:00:01.848033 20426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T16:00:41.472485+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T15:00:00+00:00 PythonOperator 2021-04-23T16:00:21.837775+00:00 2021-04-23T16:00:24.820230+00:00 0:00:02.982455 20425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T16:00:19.404702+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T14:00:00+00:00 EmrJobFlowSensor 2021-04-23T15:12:05.651888+00:00 2021-04-23T15:25:09.217681+00:00 0:13:03.565793 20423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T15:12:03.226936+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T14:00:00+00:00 EmrJobFlowSensor 2021-04-23T15:11:59.767480+00:00 2021-04-23T15:21:02.543200+00:00 0:09:02.775720 20422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T15:11:57.244217+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T15:11:43.387054+00:00 2021-04-23T15:11:45.298259+00:00 0:00:01.911205 20421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T15:11:41.128359+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T15:11:37.587330+00:00 2021-04-23T15:11:39.321732+00:00 0:00:01.734402 20420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T15:11:35.179885+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T14:00:00+00:00 PythonOperator 2021-04-23T15:11:23.306303+00:00 2021-04-23T15:11:27.121591+00:00 0:00:03.815288 20419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T15:11:21.107369+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T14:00:00+00:00 PythonOperator 2021-04-23T15:11:17.778287+00:00 2021-04-23T15:11:21.035429+00:00 0:00:03.257142 20418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T15:11:15.104757+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T14:00:00+00:00 TriggerDagRunOperator 2021-04-23T15:11:08.162642+00:00 2021-04-23T15:11:08.792251+00:00 0:00:00.629609 20417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T15:11:05.155507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T14:00:00+00:00 TriggerDagRunOperator 2021-04-23T15:11:07.535595+00:00 2021-04-23T15:11:07.929365+00:00 0:00:00.393770 20416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T15:11:05.155539+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T14:05:00+00:00 EmrJobFlowSensor 2021-04-23T15:06:44.813777+00:00 2021-04-23T15:15:47.525397+00:00 0:09:02.711620 20415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T15:06:42.609868+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T15:06:22.916002+00:00 2021-04-23T15:06:24.608784+00:00 0:00:01.692782 20414 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T15:06:20.660195+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T14:05:00+00:00 PythonOperator 2021-04-23T15:05:04.853682+00:00 2021-04-23T15:05:08.054726+00:00 0:00:03.201044 20413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T15:05:02.556501+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T14:00:00+00:00 EmrJobFlowSensor 2021-04-23T15:00:48.181481+00:00 2021-04-23T15:10:51.053665+00:00 0:10:02.872184 20412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T15:00:46.012072+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T15:00:26.192913+00:00 2021-04-23T15:00:27.948511+00:00 0:00:01.755598 20411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T15:00:23.995476+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T14:00:00+00:00 PythonOperator 2021-04-23T15:00:06.311464+00:00 2021-04-23T15:00:09.351660+00:00 0:00:03.040196 20410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T15:00:03.913760+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T13:00:00+00:00 EmrJobFlowSensor 2021-04-23T14:11:23.315114+00:00 2021-04-23T14:20:26.045357+00:00 0:09:02.730243 20408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T14:11:20.966613+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T13:00:00+00:00 EmrJobFlowSensor 2021-04-23T14:11:21.047424+00:00 2021-04-23T14:20:23.693041+00:00 0:09:02.645617 20407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T14:11:18.872809+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T14:11:03.665926+00:00 2021-04-23T14:11:05.405521+00:00 0:00:01.739595 20406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T14:11:00.840771+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T14:11:01.498164+00:00 2021-04-23T14:11:03.480545+00:00 0:00:01.982381 20405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T14:10:58.841214+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T13:00:00+00:00 PythonOperator 2021-04-23T14:10:40.911771+00:00 2021-04-23T14:10:44.721565+00:00 0:00:03.809794 20404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T14:10:38.756211+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T13:00:00+00:00 PythonOperator 2021-04-23T14:10:39.465239+00:00 2021-04-23T14:10:42.405967+00:00 0:00:02.940728 20403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T14:10:36.761479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T13:00:00+00:00 TriggerDagRunOperator 2021-04-23T14:10:25.025386+00:00 2021-04-23T14:10:25.582977+00:00 0:00:00.557591 20402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T14:10:22.707095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T13:00:00+00:00 TriggerDagRunOperator 2021-04-23T14:10:24.998670+00:00 2021-04-23T14:10:25.478874+00:00 0:00:00.480204 20401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T14:10:22.707123+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T13:05:00+00:00 EmrJobFlowSensor 2021-04-23T14:06:04.778087+00:00 2021-04-23T14:15:07.412670+00:00 0:09:02.634583 20400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T14:06:02.455184+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T14:05:42.404204+00:00 2021-04-23T14:05:44.136422+00:00 0:00:01.732218 20399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T14:05:40.287930+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T13:05:00+00:00 PythonOperator 2021-04-23T14:05:14.631264+00:00 2021-04-23T14:05:17.736823+00:00 0:00:03.105559 20398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T14:05:12.276216+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T13:00:00+00:00 EmrJobFlowSensor 2021-04-23T14:01:02.324766+00:00 2021-04-23T14:10:05.164746+00:00 0:09:02.839980 20397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T14:00:59.953045+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T14:00:40.365052+00:00 2021-04-23T14:00:42.042412+00:00 0:00:01.677360 20396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T14:00:37.851846+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T13:00:00+00:00 PythonOperator 2021-04-23T14:00:18.566769+00:00 2021-04-23T14:00:21.567048+00:00 0:00:03.000279 20395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T14:00:15.779448+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T12:00:00+00:00 EmrJobFlowSensor 2021-04-23T13:11:22.026294+00:00 2021-04-23T13:21:24.754032+00:00 0:10:02.727738 20393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T13:11:19.887850+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T12:00:00+00:00 EmrJobFlowSensor 2021-04-23T13:11:12.857012+00:00 2021-04-23T13:21:15.672476+00:00 0:10:02.815464 20392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T13:11:09.846905+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T13:11:02.074478+00:00 2021-04-23T13:11:03.850522+00:00 0:00:01.776044 20391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T13:10:59.838183+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T13:10:52.084863+00:00 2021-04-23T13:10:53.867411+00:00 0:00:01.782548 20390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T13:10:49.827068+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T12:00:00+00:00 PythonOperator 2021-04-23T13:10:40.211965+00:00 2021-04-23T13:10:43.210239+00:00 0:00:02.998274 20389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T13:10:37.817498+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T12:00:00+00:00 PythonOperator 2021-04-23T13:10:30.291252+00:00 2021-04-23T13:10:33.471361+00:00 0:00:03.180109 20388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T13:10:27.817284+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T12:00:00+00:00 TriggerDagRunOperator 2021-04-23T13:10:20.127616+00:00 2021-04-23T13:10:20.657252+00:00 0:00:00.529636 20387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T13:10:17.794440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T12:00:00+00:00 TriggerDagRunOperator 2021-04-23T13:10:19.989383+00:00 2021-04-23T13:10:20.443836+00:00 0:00:00.454453 20386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T13:10:17.794474+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T12:05:00+00:00 EmrJobFlowSensor 2021-04-23T13:06:07.760219+00:00 2021-04-23T13:15:10.382151+00:00 0:09:02.621932 20385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T13:06:05.463167+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T13:05:47.598306+00:00 2021-04-23T13:05:49.254392+00:00 0:00:01.656086 20384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T13:05:45.447628+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T12:05:00+00:00 PythonOperator 2021-04-23T13:05:25.589932+00:00 2021-04-23T13:05:28.561196+00:00 0:00:02.971264 20383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T13:05:23.346608+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T12:00:00+00:00 EmrJobFlowSensor 2021-04-23T13:00:55.345471+00:00 2021-04-23T13:09:58.162656+00:00 0:09:02.817185 20382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T13:00:52.841839+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T13:00:35.199166+00:00 2021-04-23T13:00:37.016225+00:00 0:00:01.817059 20381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T13:00:32.826112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T12:00:00+00:00 PythonOperator 2021-04-23T13:00:13.026167+00:00 2021-04-23T13:00:16.280983+00:00 0:00:03.254816 20380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T13:00:10.715556+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T11:00:00+00:00 EmrJobFlowSensor 2021-04-23T12:13:06.283243+00:00 2021-04-23T12:23:09.117892+00:00 0:10:02.834649 20379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T12:13:04.085674+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T12:12:46.219464+00:00 2021-04-23T12:12:48.320747+00:00 0:00:02.101283 20378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T12:12:43.994113+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T11:00:00+00:00 EmrJobFlowSensor 2021-04-23T12:12:42.155709+00:00 2021-04-23T12:24:45.318118+00:00 0:12:03.162409 20377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T12:12:39.992352+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T11:05:00+00:00 EmrJobFlowSensor 2021-04-23T12:12:30.385001+00:00 2021-04-23T12:21:33.185266+00:00 0:09:02.800265 20376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T12:12:28.043613+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T11:00:00+00:00 PythonOperator 2021-04-23T12:12:24.144861+00:00 2021-04-23T12:12:27.068698+00:00 0:00:02.923837 20375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T12:12:21.930674+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T12:12:20.262444+00:00 2021-04-23T12:12:21.984904+00:00 0:00:01.722460 20374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T12:12:17.932375+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T12:12:10.035686+00:00 2021-04-23T12:12:11.681063+00:00 0:00:01.645377 20373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T12:12:07.867622+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T11:00:00+00:00 PythonOperator 2021-04-23T12:11:58.342744+00:00 2021-04-23T12:12:01.611064+00:00 0:00:03.268320 20372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T12:11:55.852003+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T11:05:00+00:00 PythonOperator 2021-04-23T12:11:35.983555+00:00 2021-04-23T12:11:38.910362+00:00 0:00:02.926807 20371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T12:11:33.835620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T11:00:00+00:00 TriggerDagRunOperator 2021-04-23T12:11:30.485742+00:00 2021-04-23T12:11:30.920352+00:00 0:00:00.434610 20370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T12:11:27.835379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T11:00:00+00:00 TriggerDagRunOperator 2021-04-23T12:11:30.407090+00:00 2021-04-23T12:11:30.949882+00:00 0:00:00.542792 20369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T12:11:27.835436+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T11:00:00+00:00 EmrJobFlowSensor 2021-04-23T12:00:48.308088+00:00 2021-04-23T12:09:50.951762+00:00 0:09:02.643674 20367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T12:00:46.016857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T12:00:28.561785+00:00 2021-04-23T12:00:30.385863+00:00 0:00:01.824078 20366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T12:00:25.998670+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T11:00:00+00:00 PythonOperator 2021-04-23T12:00:06.336018+00:00 2021-04-23T12:00:09.901869+00:00 0:00:03.565851 20365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T12:00:04.044643+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T10:00:00+00:00 EmrJobFlowSensor 2021-04-23T11:12:23.598503+00:00 2021-04-23T11:22:26.309675+00:00 0:10:02.711172 20364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T11:12:21.455878+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T10:00:00+00:00 EmrJobFlowSensor 2021-04-23T11:12:17.590176+00:00 2021-04-23T11:21:20.249983+00:00 0:09:02.659807 20363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T11:12:15.450935+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T11:12:02.143895+00:00 2021-04-23T11:12:03.905436+00:00 0:00:01.761541 20362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T11:11:59.548883+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T11:11:55.721048+00:00 2021-04-23T11:11:58.068746+00:00 0:00:02.347698 20361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T11:11:53.459207+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T10:00:00+00:00 PythonOperator 2021-04-23T11:11:40.019347+00:00 2021-04-23T11:11:43.429466+00:00 0:00:03.410119 20360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T11:11:37.472143+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T10:00:00+00:00 PythonOperator 2021-04-23T11:11:33.716047+00:00 2021-04-23T11:11:36.700812+00:00 0:00:02.984765 20359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T11:11:31.389586+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T10:00:00+00:00 TriggerDagRunOperator 2021-04-23T11:11:13.788287+00:00 2021-04-23T11:11:14.314131+00:00 0:00:00.525844 20358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T11:11:11.338734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T10:00:00+00:00 TriggerDagRunOperator 2021-04-23T11:11:13.570338+00:00 2021-04-23T11:11:14.006889+00:00 0:00:00.436551 20357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T11:11:11.338763+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T10:05:00+00:00 EmrJobFlowSensor 2021-04-23T11:05:49.647560+00:00 2021-04-23T11:13:52.151900+00:00 0:08:02.504340 20356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T11:05:47.055130+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T11:05:29.109229+00:00 2021-04-23T11:05:30.773816+00:00 0:00:01.664587 20355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T11:05:26.940513+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T10:05:00+00:00 PythonOperator 2021-04-23T11:05:07.369034+00:00 2021-04-23T11:05:10.337751+00:00 0:00:02.968717 20354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T11:05:04.929535+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T10:00:00+00:00 EmrJobFlowSensor 2021-04-23T11:01:05.718373+00:00 2021-04-23T11:11:08.564166+00:00 0:10:02.845793 20352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T11:01:03.385473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T11:00:43.558271+00:00 2021-04-23T11:00:45.266545+00:00 0:00:01.708274 20351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T11:00:41.363387+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T10:00:00+00:00 PythonOperator 2021-04-23T11:00:21.755666+00:00 2021-04-23T11:00:24.941018+00:00 0:00:03.185352 20350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T11:00:19.344373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T09:00:00+00:00 EmrJobFlowSensor 2021-04-23T10:15:59.205819+00:00 2021-04-23T10:25:01.893855+00:00 0:09:02.688036 20349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T10:15:56.784042+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T09:00:00+00:00 EmrJobFlowSensor 2021-04-23T10:15:59.027462+00:00 2021-04-23T10:26:01.863061+00:00 0:10:02.835599 20348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T10:15:56.784012+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T10:15:39.043020+00:00 2021-04-23T10:15:40.817536+00:00 0:00:01.774516 20347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T10:15:36.708733+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T10:15:37.160494+00:00 2021-04-23T10:15:38.853019+00:00 0:00:01.692525 20346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T10:15:34.759120+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T09:00:00+00:00 PythonOperator 2021-04-23T10:15:16.891331+00:00 2021-04-23T10:15:19.866397+00:00 0:00:02.975066 20345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T10:15:14.691180+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T09:00:00+00:00 PythonOperator 2021-04-23T10:15:14.968750+00:00 2021-04-23T10:15:18.356392+00:00 0:00:03.387642 20344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T10:15:12.703461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T09:00:00+00:00 TriggerDagRunOperator 2021-04-23T10:15:03.125380+00:00 2021-04-23T10:15:03.547718+00:00 0:00:00.422338 20343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T10:15:00.679637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T09:00:00+00:00 TriggerDagRunOperator 2021-04-23T10:15:02.911761+00:00 2021-04-23T10:15:03.463496+00:00 0:00:00.551735 20342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T10:15:00.679608+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T09:05:00+00:00 EmrJobFlowSensor 2021-04-23T10:05:54.399479+00:00 2021-04-23T10:14:57.073726+00:00 0:09:02.674247 20341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T10:05:51.982126+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T10:05:32.689156+00:00 2021-04-23T10:05:34.341322+00:00 0:00:01.652166 20340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T10:05:29.976412+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T09:05:00+00:00 PythonOperator 2021-04-23T10:05:10.275205+00:00 2021-04-23T10:05:13.199420+00:00 0:00:02.924215 20339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T10:05:07.890606+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T09:00:00+00:00 EmrJobFlowSensor 2021-04-23T10:03:48.139714+00:00 2021-04-23T10:14:51.093555+00:00 0:11:02.953841 20338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T10:03:45.773278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T10:03:25.881506+00:00 2021-04-23T10:03:27.564795+00:00 0:00:01.683289 20337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T10:03:23.703748+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T09:00:00+00:00 PythonOperator 2021-04-23T10:03:04.101849+00:00 2021-04-23T10:03:07.107579+00:00 0:00:03.005730 20336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T10:03:01.678697+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T08:00:00+00:00 EmrJobFlowSensor 2021-04-23T09:12:14.964686+00:00 2021-04-23T09:22:17.849262+00:00 0:10:02.884576 20334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T09:12:12.544722+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T08:00:00+00:00 EmrJobFlowSensor 2021-04-23T09:12:06.581722+00:00 2021-04-23T09:21:09.297966+00:00 0:09:02.716244 20333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T09:12:04.421109+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T09:11:55.000865+00:00 2021-04-23T09:11:56.942889+00:00 0:00:01.942024 20332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T09:11:52.405281+00:00 2 default_pool