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 create_cluster_and_add_emr_steps 2021-04-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T10:12:02.091100+00:00 2021-04-13T10:12:03.839532+00:00 0:00:01.748432 16695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T10:11:59.051583+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T09:00:00+00:00 PythonOperator 2021-04-13T10:11:41.136925+00:00 2021-04-13T10:11:44.198063+00:00 0:00:03.061138 16694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:11:38.877439+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T09:00:00+00:00 PythonOperator 2021-04-13T10:11:39.434787+00:00 2021-04-13T10:11:42.155701+00:00 0:00:02.720914 16693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:11:36.902446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T09:00:00+00:00 TriggerDagRunOperator 2021-04-13T10:11:19.499452+00:00 2021-04-13T10:11:20.031735+00:00 0:00:00.532283 16692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:11:16.875367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T09:00:00+00:00 TriggerDagRunOperator 2021-04-13T10:11:19.245682+00:00 2021-04-13T10:11:19.670873+00:00 0:00:00.425191 16691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:11:16.875397+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T09:05:00+00:00 EmrJobFlowSensor 2021-04-13T10:05:54.592679+00:00 2021-04-13T10:13:57.140942+00:00 0:08:02.548263 16690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:05:52.294667+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T10:05:34.595877+00:00 2021-04-13T10:05:36.367600+00:00 0:00:01.771723 16689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T10:05:32.280857+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T09:05:00+00:00 PythonOperator 2021-04-13T10:05:12.568458+00:00 2021-04-13T10:05:15.340103+00:00 0:00:02.771645 16688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:05:10.267720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T09:00:00+00:00 EmrJobFlowSensor 2021-04-13T10:01:00.286433+00:00 2021-04-13T10:11:03.117944+00:00 0:10:02.831511 16687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:00:57.958791+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T10:00:38.325824+00:00 2021-04-13T10:00:40.126164+00:00 0:00:01.800340 16686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T10:00:35.974548+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T09:00:00+00:00 PythonOperator 2021-04-13T10:00:18.508416+00:00 2021-04-13T10:00:21.312834+00:00 0:00:02.804418 16685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T10:00:15.964316+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-13T09:54:00.917790+00:00 PythonOperator 2021-04-13T09:54:45.768402+00:00 2021-04-13T09:54:48.898563+00:00 0:00:03.130161 16684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T09:54:43.389519+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-13T09:54:00.917790+00:00 PythonOperator 2021-04-13T09:54:23.847695+00:00 2021-04-13T09:54:24.169955+00:00 0:00:00.322260 16683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T09:54:21.381049+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T08:00:00+00:00 EmrJobFlowSensor 2021-04-13T09:12:26.933333+00:00 2021-04-13T09:22:29.721124+00:00 0:10:02.787791 16681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T09:12:24.492717+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T08:00:00+00:00 EmrJobFlowSensor 2021-04-13T09:12:26.859387+00:00 2021-04-13T09:22:29.569929+00:00 0:10:02.710542 16680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T09:12:24.492750+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T09:12:05.072604+00:00 2021-04-13T09:12:06.924448+00:00 0:00:01.851844 16679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T09:12:02.417656+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T09:12:04.728306+00:00 2021-04-13T09:12:06.734479+00:00 0:00:02.006173 16678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T09:12:02.417693+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T08:00:00+00:00 PythonOperator 2021-04-13T09:11:42.729019+00:00 2021-04-13T09:11:45.472214+00:00 0:00:02.743195 16677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T09:11:40.389186+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T08:00:00+00:00 PythonOperator 2021-04-13T09:11:42.651433+00:00 2021-04-13T09:11:45.742783+00:00 0:00:03.091350 16676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T09:11:40.389224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T08:00:00+00:00 TriggerDagRunOperator 2021-04-13T09:11:20.426757+00:00 2021-04-13T09:11:21.355834+00:00 0:00:00.929077 16675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T09:11:17.331667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T08:00:00+00:00 TriggerDagRunOperator 2021-04-13T09:11:20.141052+00:00 2021-04-13T09:11:21.109754+00:00 0:00:00.968702 16674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T09:11:17.331640+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T08:05:00+00:00 EmrJobFlowSensor 2021-04-13T09:06:10.664452+00:00 2021-04-13T09:15:13.290720+00:00 0:09:02.626268 16673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T09:06:08.525766+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T09:05:44.813538+00:00 2021-04-13T09:05:46.560425+00:00 0:00:01.746887 16672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T09:05:42.498617+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T08:05:00+00:00 PythonOperator 2021-04-13T09:05:22.646469+00:00 2021-04-13T09:05:25.314814+00:00 0:00:02.668345 16671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T09:05:20.461991+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T08:00:00+00:00 EmrJobFlowSensor 2021-04-13T09:01:08.951171+00:00 2021-04-13T09:11:11.865483+00:00 0:10:02.914312 16670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T09:01:06.188516+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T09:00:46.424083+00:00 2021-04-13T09:00:48.238826+00:00 0:00:01.814743 16669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T09:00:44.146704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T08:00:00+00:00 PythonOperator 2021-04-13T09:00:24.712251+00:00 2021-04-13T09:00:27.535839+00:00 0:00:02.823588 16668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T09:00:22.125742+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T07:00:00+00:00 EmrJobFlowSensor 2021-04-13T08:11:37.798476+00:00 2021-04-13T08:20:40.494655+00:00 0:09:02.696179 16666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T08:11:35.551148+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T07:00:00+00:00 EmrJobFlowSensor 2021-04-13T08:11:25.719485+00:00 2021-04-13T08:20:28.365440+00:00 0:09:02.645955 16665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T08:11:23.520630+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T08:11:09.828851+00:00 2021-04-13T08:11:11.620277+00:00 0:00:01.791426 16664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T08:11:07.435662+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T08:11:01.620979+00:00 2021-04-13T08:11:03.332548+00:00 0:00:01.711569 16663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T08:10:59.423402+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T07:00:00+00:00 PythonOperator 2021-04-13T08:10:44.073841+00:00 2021-04-13T08:10:46.906947+00:00 0:00:02.833106 16662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T08:10:41.408895+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T07:00:00+00:00 PythonOperator 2021-04-13T08:10:39.889539+00:00 2021-04-13T08:10:43.256129+00:00 0:00:03.366590 16661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T08:10:37.456781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T07:00:00+00:00 TriggerDagRunOperator 2021-04-13T08:10:25.834016+00:00 2021-04-13T08:10:26.343602+00:00 0:00:00.509586 16660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T08:10:23.394108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T07:00:00+00:00 TriggerDagRunOperator 2021-04-13T08:10:25.727553+00:00 2021-04-13T08:10:26.139091+00:00 0:00:00.411538 16659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T08:10:23.394081+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T07:05:00+00:00 EmrJobFlowSensor 2021-04-13T08:06:03.131633+00:00 2021-04-13T08:14:05.667669+00:00 0:08:02.536036 16658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T08:06:00.938181+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T08:05:41.178182+00:00 2021-04-13T08:05:42.917262+00:00 0:00:01.739080 16657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T08:05:38.917252+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T07:05:00+00:00 PythonOperator 2021-04-13T08:05:21.141543+00:00 2021-04-13T08:05:23.829218+00:00 0:00:02.687675 16656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T08:05:18.900111+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T07:00:00+00:00 EmrJobFlowSensor 2021-04-13T08:01:01.101414+00:00 2021-04-13T08:10:03.954008+00:00 0:09:02.852594 16655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T08:00:58.474415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T08:00:40.524170+00:00 2021-04-13T08:00:42.199539+00:00 0:00:01.675369 16654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T08:00:38.345213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T07:00:00+00:00 PythonOperator 2021-04-13T08:00:19.130243+00:00 2021-04-13T08:00:21.982296+00:00 0:00:02.852053 16653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T08:00:16.329406+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T06:00:00+00:00 EmrJobFlowSensor 2021-04-13T07:12:12.155059+00:00 2021-04-13T07:21:14.960722+00:00 0:09:02.805663 16651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:12:09.922913+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T06:00:00+00:00 EmrJobFlowSensor 2021-04-13T07:11:58.164619+00:00 2021-04-13T07:22:01.113557+00:00 0:10:02.948938 16650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:11:55.909505+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:11:52.143364+00:00 2021-04-13T07:11:53.942033+00:00 0:00:01.798669 16649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T07:11:49.906834+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:11:36.279635+00:00 2021-04-13T07:11:37.974345+00:00 0:00:01.694710 16648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T07:11:33.954600+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T06:00:00+00:00 PythonOperator 2021-04-13T07:11:30.428466+00:00 2021-04-13T07:11:33.311201+00:00 0:00:02.882735 16647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:11:27.950123+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T06:00:00+00:00 PythonOperator 2021-04-13T07:11:14.175191+00:00 2021-04-13T07:11:17.232668+00:00 0:00:03.057477 16646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:11:11.855231+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T06:00:00+00:00 TriggerDagRunOperator 2021-04-13T07:11:08.567489+00:00 2021-04-13T07:11:09.082911+00:00 0:00:00.515422 16645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:11:05.843617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T06:00:00+00:00 TriggerDagRunOperator 2021-04-13T07:11:08.361213+00:00 2021-04-13T07:11:08.795225+00:00 0:00:00.434012 16644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:11:05.843581+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T06:05:00+00:00 EmrJobFlowSensor 2021-04-13T07:05:55.611798+00:00 2021-04-13T07:13:58.113103+00:00 0:08:02.501305 16643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:05:53.311112+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:05:33.825603+00:00 2021-04-13T07:05:35.491039+00:00 0:00:01.665436 16642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T07:05:31.286129+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T06:05:00+00:00 PythonOperator 2021-04-13T07:05:11.702425+00:00 2021-04-13T07:05:14.400760+00:00 0:00:02.698335 16641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:05:09.285120+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T06:00:00+00:00 EmrJobFlowSensor 2021-04-13T07:00:55.257989+00:00 2021-04-13T07:10:58.135081+00:00 0:10:02.877092 16640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:00:52.846527+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:00:33.102571+00:00 2021-04-13T07:00:34.778432+00:00 0:00:01.675861 16639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T07:00:30.755771+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T06:00:00+00:00 PythonOperator 2021-04-13T07:00:13.023366+00:00 2021-04-13T07:00:15.975954+00:00 0:00:02.952588 16638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T07:00:10.684066+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-13T06:16:58.960524+00:00 PythonOperator 2021-04-13T06:17:27.867948+00:00 2021-04-13T06:17:30.941619+00:00 0:00:03.073671 16636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:17:25.668733+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-13T06:16:58.960524+00:00 PythonOperator 2021-04-13T06:17:07.905636+00:00 2021-04-13T06:17:08.186407+00:00 0:00:00.280771 16635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T06:17:05.644151+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T05:00:00+00:00 EmrJobFlowSensor 2021-04-13T06:11:11.029475+00:00 2021-04-13T06:20:13.703267+00:00 0:09:02.673792 16634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:11:08.792769+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T05:00:00+00:00 EmrJobFlowSensor 2021-04-13T06:11:03.159138+00:00 2021-04-13T06:19:05.597511+00:00 0:08:02.438373 16633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:11:00.785727+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:10:41.624200+00:00 2021-04-13T06:10:43.285379+00:00 0:00:01.661179 16632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T06:10:38.742148+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:10:39.144620+00:00 2021-04-13T06:10:41.289805+00:00 0:00:02.145185 16631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T06:10:36.782445+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T05:00:00+00:00 PythonOperator 2021-04-13T06:10:19.013492+00:00 2021-04-13T06:10:21.890501+00:00 0:00:02.877009 16630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:10:16.721859+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T05:00:00+00:00 PythonOperator 2021-04-13T06:10:17.252525+00:00 2021-04-13T06:10:20.088849+00:00 0:00:02.836324 16629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:10:14.723917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T05:00:00+00:00 TriggerDagRunOperator 2021-04-13T06:10:05.536196+00:00 2021-04-13T06:10:06.050060+00:00 0:00:00.513864 16628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:10:02.713335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T05:00:00+00:00 TriggerDagRunOperator 2021-04-13T06:10:04.878798+00:00 2021-04-13T06:10:05.259518+00:00 0:00:00.380720 16627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:10:02.713368+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T05:05:00+00:00 EmrJobFlowSensor 2021-04-13T06:06:00.853360+00:00 2021-04-13T06:14:03.311171+00:00 0:08:02.457811 16626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:05:58.461308+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:05:40.472426+00:00 2021-04-13T06:05:42.133150+00:00 0:00:01.660724 16625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T06:05:38.317731+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T05:05:00+00:00 PythonOperator 2021-04-13T06:05:18.784562+00:00 2021-04-13T06:05:21.481238+00:00 0:00:02.696676 16624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:05:16.345923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T05:00:00+00:00 EmrJobFlowSensor 2021-04-13T06:00:54.334545+00:00 2021-04-13T06:09:57.196330+00:00 0:09:02.861785 16623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:00:51.907950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:00:33.088137+00:00 2021-04-13T06:00:34.766853+00:00 0:00:01.678716 16622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T06:00:29.886204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T05:00:00+00:00 PythonOperator 2021-04-13T06:00:10.403954+00:00 2021-04-13T06:00:13.176974+00:00 0:00:02.773020 16621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T06:00:07.882206+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T04:00:00+00:00 EmrJobFlowSensor 2021-04-13T05:12:10.806981+00:00 2021-04-13T05:21:13.339195+00:00 0:09:02.532214 16619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:12:08.601999+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T04:00:00+00:00 EmrJobFlowSensor 2021-04-13T05:12:07.043773+00:00 2021-04-13T05:20:09.596689+00:00 0:08:02.552916 16618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:12:04.643377+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:11:50.826908+00:00 2021-04-13T05:11:52.533012+00:00 0:00:01.706104 16617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T05:11:48.584753+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:11:44.999146+00:00 2021-04-13T05:11:46.788843+00:00 0:00:01.789697 16616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T05:11:42.652381+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T04:00:00+00:00 PythonOperator 2021-04-13T05:11:29.057561+00:00 2021-04-13T05:11:32.151127+00:00 0:00:03.093566 16615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:11:26.518119+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T04:00:00+00:00 PythonOperator 2021-04-13T05:11:24.745436+00:00 2021-04-13T05:11:27.742883+00:00 0:00:02.997447 16614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:11:22.520642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T04:00:00+00:00 TriggerDagRunOperator 2021-04-13T05:11:05.842632+00:00 2021-04-13T05:11:06.370871+00:00 0:00:00.528239 16613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:11:02.507264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T04:00:00+00:00 TriggerDagRunOperator 2021-04-13T05:11:05.753299+00:00 2021-04-13T05:11:06.156505+00:00 0:00:00.403206 16612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:11:02.507303+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T04:05:00+00:00 EmrJobFlowSensor 2021-04-13T05:06:04.604619+00:00 2021-04-13T05:14:07.223743+00:00 0:08:02.619124 16611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:06:02.071287+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:05:42.179506+00:00 2021-04-13T05:05:43.798863+00:00 0:00:01.619357 16610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T05:05:40.059723+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T04:05:00+00:00 PythonOperator 2021-04-13T05:05:22.166270+00:00 2021-04-13T05:05:24.852659+00:00 0:00:02.686389 16609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:05:19.982773+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T04:00:00+00:00 EmrJobFlowSensor 2021-04-13T05:00:48.811413+00:00 2021-04-13T05:10:51.704575+00:00 0:10:02.893162 16608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:00:45.625119+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:00:25.890453+00:00 2021-04-13T05:00:27.900097+00:00 0:00:02.009644 16607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T05:00:23.620169+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T04:00:00+00:00 PythonOperator 2021-04-13T05:00:04.822655+00:00 2021-04-13T05:00:07.860384+00:00 0:00:03.037729 16606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T05:00:01.650463+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:11:26.037069+00:00 2021-04-13T04:20:28.725944+00:00 0:09:02.688875 16604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:11:23.642221+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:11:21.729038+00:00 2021-04-13T04:20:24.546245+00:00 0:09:02.817207 16603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:11:19.498955+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:11:04.206823+00:00 2021-04-13T04:11:05.966185+00:00 0:00:01.759362 16602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:11:01.487875+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:11:01.621585+00:00 2021-04-13T04:11:03.715862+00:00 0:00:02.094277 16601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:10:59.481649+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:10:42.374202+00:00 2021-04-13T04:10:45.324679+00:00 0:00:02.950477 16600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:10:39.460469+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:10:40.294648+00:00 2021-04-13T04:10:43.383274+00:00 0:00:03.088626 16599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:10:37.457303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T03:00:00+00:00 TriggerDagRunOperator 2021-04-13T04:10:24.331862+00:00 2021-04-13T04:10:24.898049+00:00 0:00:00.566187 16598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:10:21.487875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T03:00:00+00:00 TriggerDagRunOperator 2021-04-13T04:10:23.872058+00:00 2021-04-13T04:10:24.417510+00:00 0:00:00.545452 16597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:10:21.487835+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T03:05:00+00:00 EmrJobFlowSensor 2021-04-13T04:06:03.228704+00:00 2021-04-13T04:15:05.992416+00:00 0:09:02.763712 16596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:06:00.884608+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:05:41.090515+00:00 2021-04-13T04:05:42.729018+00:00 0:00:01.638503 16595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:05:38.871388+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T03:05:00+00:00 PythonOperator 2021-04-13T04:05:19.025067+00:00 2021-04-13T04:05:21.687847+00:00 0:00:02.662780 16594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:05:16.800204+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:01:01.135454+00:00 2021-04-13T04:10:04.006763+00:00 0:09:02.871309 16593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:00:58.641291+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:00:40.651965+00:00 2021-04-13T04:00:42.353699+00:00 0:00:01.701734 16592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T04:00:38.429945+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:00:19.387546+00:00 2021-04-13T04:00:22.233159+00:00 0:00:02.845613 16591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T04:00:16.472355+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T02:00:00+00:00 EmrJobFlowSensor 2021-04-13T03:11:29.396242+00:00 2021-04-13T03:21:32.218841+00:00 0:10:02.822599 16589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:11:26.840681+00:00 2 default_pool