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 vc-asset-import_v002 create_emr_steps 2021-04-29T11:05:00+00:00 PythonOperator 2021-04-29T12:05:16.067326+00:00 2021-04-29T12:05:19.048718+00:00 0:00:02.981392 22549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T12:05:13.920130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T11:00:00+00:00 EmrJobFlowSensor 2021-04-29T12:01:05.739217+00:00 2021-04-29T12:10:08.452419+00:00 0:09:02.713202 22548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T12:01:03.517655+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T12:00:37.713895+00:00 2021-04-29T12:00:39.408247+00:00 0:00:01.694352 22547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T12:00:35.490267+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T11:00:00+00:00 PythonOperator 2021-04-29T12:00:15.889771+00:00 2021-04-29T12:00:18.925839+00:00 0:00:03.036068 22546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T12:00:13.422501+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T10:00:00+00:00 EmrJobFlowSensor 2021-04-29T11:12:10.215973+00:00 2021-04-29T11:21:12.988014+00:00 0:09:02.772041 22544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T11:12:07.914870+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T10:00:00+00:00 EmrJobFlowSensor 2021-04-29T11:12:06.082972+00:00 2021-04-29T11:22:08.940587+00:00 0:10:02.857615 22543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T11:12:03.913614+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T11:11:44.303959+00:00 2021-04-29T11:11:46.020149+00:00 0:00:01.716190 22542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T11:11:41.960724+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T11:11:42.302739+00:00 2021-04-29T11:11:44.134512+00:00 0:00:01.831773 22541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T11:11:39.957841+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T10:00:00+00:00 PythonOperator 2021-04-29T11:11:22.826834+00:00 2021-04-29T11:11:25.785775+00:00 0:00:02.958941 22540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T11:11:19.844986+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T10:00:00+00:00 PythonOperator 2021-04-29T11:11:20.335058+00:00 2021-04-29T11:11:24.185683+00:00 0:00:03.850625 22539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T11:11:17.845778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T10:00:00+00:00 TriggerDagRunOperator 2021-04-29T11:11:00.340513+00:00 2021-04-29T11:11:00.890097+00:00 0:00:00.549584 22538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T11:10:57.847171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T10:00:00+00:00 TriggerDagRunOperator 2021-04-29T11:11:00.103099+00:00 2021-04-29T11:11:00.499239+00:00 0:00:00.396140 22537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T11:10:57.847139+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T10:05:00+00:00 EmrJobFlowSensor 2021-04-29T11:06:03.562429+00:00 2021-04-29T11:16:06.369387+00:00 0:10:02.806958 22536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T11:06:01.399708+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T11:05:41.604919+00:00 2021-04-29T11:05:43.336793+00:00 0:00:01.731874 22535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T11:05:39.382978+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T10:05:00+00:00 PythonOperator 2021-04-29T11:05:19.475320+00:00 2021-04-29T11:05:22.401418+00:00 0:00:02.926098 22534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T11:05:17.297423+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T10:00:00+00:00 EmrJobFlowSensor 2021-04-29T11:00:51.030580+00:00 2021-04-29T11:10:53.988259+00:00 0:10:02.957679 22533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T11:00:48.821499+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T11:00:29.118050+00:00 2021-04-29T11:00:30.927845+00:00 0:00:01.809795 22532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T11:00:26.804257+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T10:00:00+00:00 PythonOperator 2021-04-29T11:00:07.272959+00:00 2021-04-29T11:00:10.384721+00:00 0:00:03.111762 22531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T11:00:04.787899+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T09:00:00+00:00 EmrJobFlowSensor 2021-04-29T10:26:19.706123+00:00 2021-04-29T10:35:22.441973+00:00 0:09:02.735850 22529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T10:26:17.060122+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T09:00:00+00:00 EmrJobFlowSensor 2021-04-29T10:26:17.397314+00:00 2021-04-29T10:49:21.996909+00:00 0:23:04.599595 22528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T10:26:15.055277+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T10:25:59.214352+00:00 2021-04-29T10:26:00.933731+00:00 0:00:01.719379 22527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T10:25:56.963594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T10:25:55.161745+00:00 2021-04-29T10:25:56.966674+00:00 0:00:01.804929 22526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T10:25:52.889426+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T09:00:00+00:00 PythonOperator 2021-04-29T10:25:37.505483+00:00 2021-04-29T10:25:40.758236+00:00 0:00:03.252753 22525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T10:25:34.839643+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T09:00:00+00:00 PythonOperator 2021-04-29T10:25:35.317903+00:00 2021-04-29T10:25:39.098402+00:00 0:00:03.780499 22524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T10:25:32.879021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T09:00:00+00:00 TriggerDagRunOperator 2021-04-29T10:25:21.019356+00:00 2021-04-29T10:25:21.446219+00:00 0:00:00.426863 22523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T10:25:18.822007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T09:00:00+00:00 TriggerDagRunOperator 2021-04-29T10:25:21.002174+00:00 2021-04-29T10:25:21.541810+00:00 0:00:00.539636 22522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T10:25:18.822038+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T09:05:00+00:00 EmrJobFlowSensor 2021-04-29T10:06:01.205099+00:00 2021-04-29T10:15:03.931070+00:00 0:09:02.725971 22521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T10:05:58.960887+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T10:05:39.217415+00:00 2021-04-29T10:05:40.904585+00:00 0:00:01.687170 22520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T10:05:36.905516+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T09:05:00+00:00 PythonOperator 2021-04-29T10:05:17.044737+00:00 2021-04-29T10:05:20.036960+00:00 0:00:02.992223 22519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T10:05:14.886374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T09:00:00+00:00 EmrJobFlowSensor 2021-04-29T10:01:06.548992+00:00 2021-04-29T10:25:11.323403+00:00 0:24:04.774411 22518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T10:01:04.317332+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T10:00:44.983334+00:00 2021-04-29T10:00:46.896288+00:00 0:00:01.912954 22517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T10:00:42.370752+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T09:00:00+00:00 PythonOperator 2021-04-29T10:00:24.946250+00:00 2021-04-29T10:00:27.992016+00:00 0:00:03.045766 22516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T10:00:22.284467+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T08:00:00+00:00 EmrJobFlowSensor 2021-04-29T09:10:09.209536+00:00 2021-04-29T09:19:11.800100+00:00 0:09:02.590564 22514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T09:10:06.890078+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T08:00:00+00:00 EmrJobFlowSensor 2021-04-29T09:09:59.033933+00:00 2021-04-29T09:18:01.656689+00:00 0:08:02.622756 22513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T09:09:56.819131+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T09:09:49.253825+00:00 2021-04-29T09:09:51.073387+00:00 0:00:01.819562 22512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T09:09:46.809089+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T09:09:36.967544+00:00 2021-04-29T09:09:38.668873+00:00 0:00:01.701329 22511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T09:09:34.800082+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T08:00:00+00:00 PythonOperator 2021-04-29T09:09:27.281982+00:00 2021-04-29T09:09:30.565124+00:00 0:00:03.283142 22510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T09:09:24.855727+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T08:00:00+00:00 PythonOperator 2021-04-29T09:09:15.417146+00:00 2021-04-29T09:09:18.497241+00:00 0:00:03.080095 22509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T09:09:12.784359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T08:00:00+00:00 TriggerDagRunOperator 2021-04-29T09:09:11.313681+00:00 2021-04-29T09:09:11.886612+00:00 0:00:00.572931 22508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T09:09:08.845158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T08:00:00+00:00 TriggerDagRunOperator 2021-04-29T09:09:11.289936+00:00 2021-04-29T09:09:11.943072+00:00 0:00:00.653136 22507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T09:09:08.845117+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T08:05:00+00:00 EmrJobFlowSensor 2021-04-29T09:05:48.696441+00:00 2021-04-29T09:14:51.241621+00:00 0:09:02.545180 22506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T09:05:46.469353+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T09:05:28.765697+00:00 2021-04-29T09:05:30.418558+00:00 0:00:01.652861 22505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T09:05:26.425622+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T08:05:00+00:00 PythonOperator 2021-04-29T09:05:06.797119+00:00 2021-04-29T09:05:09.762988+00:00 0:00:02.965869 22504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T09:05:04.413341+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T08:00:00+00:00 EmrJobFlowSensor 2021-04-29T09:01:04.255538+00:00 2021-04-29T09:09:07.042556+00:00 0:08:02.787018 22503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T09:01:02.040680+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T09:00:42.305921+00:00 2021-04-29T09:00:44.038852+00:00 0:00:01.732931 22502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T09:00:40.023272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T08:00:00+00:00 PythonOperator 2021-04-29T09:00:20.394963+00:00 2021-04-29T09:00:23.487465+00:00 0:00:03.092502 22501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T09:00:18.013569+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T07:00:00+00:00 EmrJobFlowSensor 2021-04-29T08:11:57.825782+00:00 2021-04-29T08:21:00.450203+00:00 0:09:02.624421 22499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T08:11:55.454005+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T07:00:00+00:00 EmrJobFlowSensor 2021-04-29T08:11:56.039990+00:00 2021-04-29T08:21:58.903689+00:00 0:10:02.863699 22498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T08:11:53.466355+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T08:11:35.819519+00:00 2021-04-29T08:11:37.499704+00:00 0:00:01.680185 22497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T08:11:33.446315+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T08:11:33.846539+00:00 2021-04-29T08:11:35.663986+00:00 0:00:01.817447 22496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T08:11:31.455183+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T07:00:00+00:00 PythonOperator 2021-04-29T08:11:16.132062+00:00 2021-04-29T08:11:19.406331+00:00 0:00:03.274269 22495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T08:11:13.304612+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T07:00:00+00:00 PythonOperator 2021-04-29T08:11:11.515342+00:00 2021-04-29T08:11:15.419014+00:00 0:00:03.903672 22494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T08:11:09.293931+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T07:00:00+00:00 TriggerDagRunOperator 2021-04-29T08:10:59.726793+00:00 2021-04-29T08:11:00.192989+00:00 0:00:00.466196 22493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T08:10:57.284610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T07:00:00+00:00 TriggerDagRunOperator 2021-04-29T08:10:59.598893+00:00 2021-04-29T08:11:00.179219+00:00 0:00:00.580326 22492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T08:10:57.284576+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T07:05:00+00:00 EmrJobFlowSensor 2021-04-29T08:05:55.010235+00:00 2021-04-29T08:13:57.446213+00:00 0:08:02.435978 22491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T08:05:52.558553+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T08:05:32.893591+00:00 2021-04-29T08:05:34.661261+00:00 0:00:01.767670 22490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T08:05:30.489131+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T07:05:00+00:00 PythonOperator 2021-04-29T08:05:10.707462+00:00 2021-04-29T08:05:13.687061+00:00 0:00:02.979599 22489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T08:05:08.452179+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T07:00:00+00:00 EmrJobFlowSensor 2021-04-29T08:00:50.389254+00:00 2021-04-29T08:10:53.271285+00:00 0:10:02.882031 22488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T08:00:48.002145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T08:00:30.523168+00:00 2021-04-29T08:00:32.230059+00:00 0:00:01.706891 22487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T08:00:27.960054+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T07:00:00+00:00 PythonOperator 2021-04-29T08:00:08.208449+00:00 2021-04-29T08:00:11.315172+00:00 0:00:03.106723 22486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T08:00:05.819010+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T06:00:00+00:00 EmrJobFlowSensor 2021-04-29T07:11:12.041462+00:00 2021-04-29T07:20:14.715013+00:00 0:09:02.673551 22484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T07:11:09.663045+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T06:00:00+00:00 EmrJobFlowSensor 2021-04-29T07:11:12.054396+00:00 2021-04-29T07:20:14.815309+00:00 0:09:02.760913 22483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T07:11:09.663080+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T07:10:51.996287+00:00 2021-04-29T07:10:53.828783+00:00 0:00:01.832496 22482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T07:10:49.529367+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T07:10:51.892837+00:00 2021-04-29T07:10:53.650654+00:00 0:00:01.757817 22481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T07:10:49.529332+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T06:00:00+00:00 PythonOperator 2021-04-29T07:10:30.348687+00:00 2021-04-29T07:10:33.639765+00:00 0:00:03.291078 22480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T07:10:27.644656+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T06:00:00+00:00 PythonOperator 2021-04-29T07:10:30.285251+00:00 2021-04-29T07:10:33.331491+00:00 0:00:03.046240 22479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T07:10:27.644702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T06:00:00+00:00 TriggerDagRunOperator 2021-04-29T07:10:09.842278+00:00 2021-04-29T07:10:10.346102+00:00 0:00:00.503824 22478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T07:10:07.450013+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T06:00:00+00:00 TriggerDagRunOperator 2021-04-29T07:10:09.713543+00:00 2021-04-29T07:10:10.145783+00:00 0:00:00.432240 22477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T07:10:07.449966+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T06:05:00+00:00 EmrJobFlowSensor 2021-04-29T07:06:03.468796+00:00 2021-04-29T07:15:06.082540+00:00 0:09:02.613744 22476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T07:06:01.055834+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T07:05:41.262094+00:00 2021-04-29T07:05:42.995458+00:00 0:00:01.733364 22475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T07:05:38.943539+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T06:05:00+00:00 PythonOperator 2021-04-29T07:05:20.981798+00:00 2021-04-29T07:05:24.097468+00:00 0:00:03.115670 22474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T07:05:18.800091+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T06:00:00+00:00 EmrJobFlowSensor 2021-04-29T07:00:54.664120+00:00 2021-04-29T07:09:57.277350+00:00 0:09:02.613230 22473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T07:00:52.307109+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T07:00:34.524251+00:00 2021-04-29T07:00:36.242996+00:00 0:00:01.718745 22472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T07:00:32.284110+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T06:00:00+00:00 PythonOperator 2021-04-29T07:00:10.660398+00:00 2021-04-29T07:00:13.716611+00:00 0:00:03.056213 22471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T07:00:08.211717+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T05:00:00+00:00 EmrJobFlowSensor 2021-04-29T06:12:32.102295+00:00 2021-04-29T06:21:34.653626+00:00 0:09:02.551331 22469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:12:29.653512+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T05:00:00+00:00 EmrJobFlowSensor 2021-04-29T06:12:18.482846+00:00 2021-04-29T06:22:21.236327+00:00 0:10:02.753481 22468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:12:15.495196+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:12:09.808455+00:00 2021-04-29T06:12:11.515675+00:00 0:00:01.707220 22467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T06:12:07.493711+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:11:57.697635+00:00 2021-04-29T06:11:59.474142+00:00 0:00:01.776507 22466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T06:11:55.423535+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T05:00:00+00:00 PythonOperator 2021-04-29T06:11:48.129259+00:00 2021-04-29T06:11:51.172834+00:00 0:00:03.043575 22465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:11:45.466805+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T05:00:00+00:00 PythonOperator 2021-04-29T06:11:35.958975+00:00 2021-04-29T06:11:39.273016+00:00 0:00:03.314041 22464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:11:33.403299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T05:00:00+00:00 TriggerDagRunOperator 2021-04-29T06:11:30.231899+00:00 2021-04-29T06:11:30.758564+00:00 0:00:00.526665 22463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:11:27.456389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T05:00:00+00:00 TriggerDagRunOperator 2021-04-29T06:11:30.019030+00:00 2021-04-29T06:11:30.461869+00:00 0:00:00.442839 22462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:11:27.456343+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T05:05:00+00:00 EmrJobFlowSensor 2021-04-29T06:06:05.300604+00:00 2021-04-29T06:15:07.951336+00:00 0:09:02.650732 22461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:06:02.946883+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:05:43.196431+00:00 2021-04-29T06:05:44.915006+00:00 0:00:01.718575 22460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T06:05:40.863893+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T05:05:00+00:00 PythonOperator 2021-04-29T06:05:21.176898+00:00 2021-04-29T06:05:24.175706+00:00 0:00:02.998808 22459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:05:18.843408+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T05:00:00+00:00 EmrJobFlowSensor 2021-04-29T06:01:04.886341+00:00 2021-04-29T06:11:07.881551+00:00 0:10:02.995210 22458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:01:02.393014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:00:42.537348+00:00 2021-04-29T06:00:44.243857+00:00 0:00:01.706509 22457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T06:00:40.329412+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T05:00:00+00:00 PythonOperator 2021-04-29T06:00:20.738197+00:00 2021-04-29T06:00:23.776179+00:00 0:00:03.037982 22456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T06:00:18.313674+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T04:00:00+00:00 EmrJobFlowSensor 2021-04-29T05:11:31.827018+00:00 2021-04-29T05:20:34.454772+00:00 0:09:02.627754 22454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:11:29.262040+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T04:00:00+00:00 EmrJobFlowSensor 2021-04-29T05:11:27.398259+00:00 2021-04-29T05:21:30.207435+00:00 0:10:02.809176 22453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:11:25.105631+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T05:11:11.341825+00:00 2021-04-29T05:11:13.181511+00:00 0:00:01.839686 22452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T05:11:09.090129+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T05:11:05.369661+00:00 2021-04-29T05:11:07.064445+00:00 0:00:01.694784 22451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T05:11:03.099841+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T04:00:00+00:00 PythonOperator 2021-04-29T05:10:49.372423+00:00 2021-04-29T05:10:52.437513+00:00 0:00:03.065090 22450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:10:47.070459+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T04:00:00+00:00 PythonOperator 2021-04-29T05:10:43.458909+00:00 2021-04-29T05:10:46.732414+00:00 0:00:03.273505 22449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:10:41.066511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T04:00:00+00:00 TriggerDagRunOperator 2021-04-29T05:10:19.407075+00:00 2021-04-29T05:10:19.933549+00:00 0:00:00.526474 22448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:10:17.045343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T04:00:00+00:00 TriggerDagRunOperator 2021-04-29T05:10:19.333445+00:00 2021-04-29T05:10:19.750651+00:00 0:00:00.417206 22447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:10:17.045310+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T04:05:00+00:00 EmrJobFlowSensor 2021-04-29T05:06:11.039894+00:00 2021-04-29T05:14:13.576095+00:00 0:08:02.536201 22446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:06:08.742466+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T05:05:42.811505+00:00 2021-04-29T05:05:44.509466+00:00 0:00:01.697961 22445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T05:05:40.594468+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T04:05:00+00:00 PythonOperator 2021-04-29T05:05:20.783640+00:00 2021-04-29T05:05:23.763060+00:00 0:00:02.979420 22444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:05:18.521683+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T04:00:00+00:00 EmrJobFlowSensor 2021-04-29T05:00:54.443086+00:00 2021-04-29T05:09:57.095026+00:00 0:09:02.651940 22443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:00:52.040656+00:00 2 default_pool