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-05-17T02:05:00+00:00 PythonOperator 2021-05-17T03:05:05.547713+00:00 2021-05-17T03:05:08.663591+00:00 0:00:03.115878 28940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T03:05:03.443528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T02:00:00+00:00 EmrJobFlowSensor 2021-05-17T03:01:01.624674+00:00 2021-05-17T03:11:04.378629+00:00 0:10:02.753955 28939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T03:00:59.157885+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T03:00:39.497757+00:00 2021-05-17T03:00:41.358615+00:00 0:00:01.860858 28938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T03:00:36.993565+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T02:00:00+00:00 PythonOperator 2021-05-17T03:00:19.503793+00:00 2021-05-17T03:00:22.651417+00:00 0:00:03.147624 28937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T03:00:16.880339+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T01:00:00+00:00 EmrJobFlowSensor 2021-05-17T02:12:15.593597+00:00 2021-05-17T02:21:18.277340+00:00 0:09:02.683743 28935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T02:12:13.351040+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T01:00:00+00:00 EmrJobFlowSensor 2021-05-17T02:12:09.565824+00:00 2021-05-17T02:21:12.304812+00:00 0:09:02.738988 28934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T02:12:07.346212+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T02:11:49.981707+00:00 2021-05-17T02:11:51.822161+00:00 0:00:01.840454 28933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T02:11:47.295145+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T02:11:41.666540+00:00 2021-05-17T02:11:43.456285+00:00 0:00:01.789745 28932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T02:11:39.347801+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T01:00:00+00:00 PythonOperator 2021-05-17T02:11:27.492855+00:00 2021-05-17T02:11:30.643494+00:00 0:00:03.150639 28931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T02:11:25.230815+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T01:00:00+00:00 PythonOperator 2021-05-17T02:11:19.392700+00:00 2021-05-17T02:11:22.740478+00:00 0:00:03.347778 28930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T02:11:17.222099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T01:00:00+00:00 TriggerDagRunOperator 2021-05-17T02:11:03.674649+00:00 2021-05-17T02:11:04.150034+00:00 0:00:00.475385 28929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T02:11:01.210458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T01:00:00+00:00 TriggerDagRunOperator 2021-05-17T02:11:03.568169+00:00 2021-05-17T02:11:04.131179+00:00 0:00:00.563010 28928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T02:11:01.210492+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T01:05:00+00:00 EmrJobFlowSensor 2021-05-17T02:05:54.794320+00:00 2021-05-17T02:14:57.392148+00:00 0:09:02.597828 28927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T02:05:52.703246+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T02:05:32.816992+00:00 2021-05-17T02:05:34.450550+00:00 0:00:01.633558 28926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T02:05:30.684983+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T01:05:00+00:00 PythonOperator 2021-05-17T02:05:10.981734+00:00 2021-05-17T02:05:14.282287+00:00 0:00:03.300553 28925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T02:05:08.653362+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T01:00:00+00:00 EmrJobFlowSensor 2021-05-17T02:00:54.453943+00:00 2021-05-17T02:10:57.268645+00:00 0:10:02.814702 28924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T02:00:52.145359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T02:00:32.559223+00:00 2021-05-17T02:00:34.286991+00:00 0:00:01.727768 28923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T02:00:30.144382+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T01:00:00+00:00 PythonOperator 2021-05-17T02:00:12.312111+00:00 2021-05-17T02:00:15.493084+00:00 0:00:03.180973 28922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T02:00:10.042937+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T00:00:00+00:00 EmrJobFlowSensor 2021-05-17T01:11:26.424403+00:00 2021-05-17T01:19:29.165869+00:00 0:08:02.741466 28920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T01:11:24.040751+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T00:00:00+00:00 EmrJobFlowSensor 2021-05-17T01:11:20.211113+00:00 2021-05-17T01:21:23.117999+00:00 0:10:02.906886 28919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T01:11:17.940630+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T01:11:06.151340+00:00 2021-05-17T01:11:07.978661+00:00 0:00:01.827321 28918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T01:11:03.933438+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T01:11:00.332830+00:00 2021-05-17T01:11:02.119543+00:00 0:00:01.786713 28917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T01:10:57.946511+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T00:00:00+00:00 PythonOperator 2021-05-17T01:10:42.270282+00:00 2021-05-17T01:10:45.422230+00:00 0:00:03.151948 28916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T01:10:39.962517+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T00:00:00+00:00 PythonOperator 2021-05-17T01:10:38.429605+00:00 2021-05-17T01:10:41.713940+00:00 0:00:03.284335 28915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T01:10:35.963121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T00:00:00+00:00 TriggerDagRunOperator 2021-05-17T01:10:22.158796+00:00 2021-05-17T01:10:22.759526+00:00 0:00:00.600730 28914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T01:10:19.897497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T00:00:00+00:00 TriggerDagRunOperator 2021-05-17T01:10:22.053484+00:00 2021-05-17T01:10:22.465208+00:00 0:00:00.411724 28913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T01:10:19.897530+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T00:05:00+00:00 EmrJobFlowSensor 2021-05-17T01:06:17.757856+00:00 2021-05-17T01:15:20.378244+00:00 0:09:02.620388 28912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T01:06:15.555711+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T01:05:47.496730+00:00 2021-05-17T01:05:49.124353+00:00 0:00:01.627623 28911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T01:05:45.428143+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T00:05:00+00:00 PythonOperator 2021-05-17T01:05:21.460684+00:00 2021-05-17T01:05:24.640499+00:00 0:00:03.179815 28910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T01:05:19.402472+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T00:00:00+00:00 EmrJobFlowSensor 2021-05-17T01:00:59.024318+00:00 2021-05-17T01:10:01.784212+00:00 0:09:02.759894 28909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T01:00:56.840413+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T01:00:37.220433+00:00 2021-05-17T01:00:39.073770+00:00 0:00:01.853337 28908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T01:00:34.940859+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T00:00:00+00:00 PythonOperator 2021-05-17T01:00:17.561676+00:00 2021-05-17T01:00:20.767639+00:00 0:00:03.205963 28907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T01:00:14.771461+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-16T23:00:00+00:00 EmrJobFlowSensor 2021-05-17T00:12:09.724047+00:00 2021-05-17T00:21:12.445518+00:00 0:09:02.721471 28905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T00:12:07.468020+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-16T23:00:00+00:00 EmrJobFlowSensor 2021-05-17T00:11:56.078498+00:00 2021-05-17T00:20:58.872259+00:00 0:09:02.793761 28904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T00:11:53.399897+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T00:11:47.688888+00:00 2021-05-17T00:11:49.422798+00:00 0:00:01.733910 28903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T00:11:45.457941+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T00:11:33.519414+00:00 2021-05-17T00:11:35.309402+00:00 0:00:01.789988 28902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T00:11:31.372347+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-16T23:00:00+00:00 PythonOperator 2021-05-17T00:11:27.540636+00:00 2021-05-17T00:11:30.897159+00:00 0:00:03.356523 28901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T00:11:25.366269+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-16T23:00:00+00:00 PythonOperator 2021-05-17T00:11:14.333767+00:00 2021-05-17T00:11:17.458126+00:00 0:00:03.124359 28900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T00:11:11.358672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-16T23:00:00+00:00 TriggerDagRunOperator 2021-05-17T00:11:06.081491+00:00 2021-05-17T00:11:06.482516+00:00 0:00:00.401025 28899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T00:11:03.324301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-16T23:00:00+00:00 TriggerDagRunOperator 2021-05-17T00:11:05.768887+00:00 2021-05-17T00:11:06.312982+00:00 0:00:00.544095 28898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T00:11:03.324348+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-16T23:05:00+00:00 EmrJobFlowSensor 2021-05-17T00:06:05.050078+00:00 2021-05-17T00:14:07.461154+00:00 0:08:02.411076 28897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T00:06:02.791642+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-16T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T00:05:40.928805+00:00 2021-05-17T00:05:42.663176+00:00 0:00:01.734371 28896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T00:05:38.801489+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-16T23:05:00+00:00 PythonOperator 2021-05-17T00:05:14.981070+00:00 2021-05-17T00:05:18.087944+00:00 0:00:03.106874 28895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T00:05:12.720371+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-16T23:00:00+00:00 EmrJobFlowSensor 2021-05-17T00:00:54.326126+00:00 2021-05-17T00:10:57.218003+00:00 0:10:02.891877 28894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T00:00:52.133260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T00:00:32.581283+00:00 2021-05-17T00:00:34.417390+00:00 0:00:01.836107 28893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T00:00:30.183769+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-16T23:00:00+00:00 PythonOperator 2021-05-17T00:00:10.415225+00:00 2021-05-17T00:00:13.773813+00:00 0:00:03.358588 28892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T00:00:08.089281+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-16T22:00:00+00:00 EmrJobFlowSensor 2021-05-16T23:11:27.416690+00:00 2021-05-16T23:20:30.213808+00:00 0:09:02.797118 28890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T23:11:24.984171+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-16T22:00:00+00:00 EmrJobFlowSensor 2021-05-16T23:11:19.291880+00:00 2021-05-16T23:19:21.887474+00:00 0:08:02.595594 28889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T23:11:16.967903+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T23:11:07.089702+00:00 2021-05-16T23:11:08.756123+00:00 0:00:01.666421 28888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T23:11:04.896945+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T23:10:57.013133+00:00 2021-05-16T23:10:58.695390+00:00 0:00:01.682257 28887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T23:10:54.886748+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-16T22:00:00+00:00 PythonOperator 2021-05-16T23:10:45.194227+00:00 2021-05-16T23:10:48.579158+00:00 0:00:03.384931 28886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T23:10:42.876814+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-16T22:00:00+00:00 PythonOperator 2021-05-16T23:10:37.043923+00:00 2021-05-16T23:10:40.186630+00:00 0:00:03.142707 28885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T23:10:34.868060+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-16T22:00:00+00:00 TriggerDagRunOperator 2021-05-16T23:10:25.162510+00:00 2021-05-16T23:10:25.698561+00:00 0:00:00.536051 28884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T23:10:22.859175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-16T22:00:00+00:00 TriggerDagRunOperator 2021-05-16T23:10:25.115382+00:00 2021-05-16T23:10:25.506190+00:00 0:00:00.390808 28883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T23:10:22.859209+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-16T22:05:00+00:00 EmrJobFlowSensor 2021-05-16T23:05:46.616409+00:00 2021-05-16T23:13:49.141213+00:00 0:08:02.524804 28882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T23:05:44.376024+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-16T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-16T23:05:24.782851+00:00 2021-05-16T23:05:26.565001+00:00 0:00:01.782150 28881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T23:05:22.364012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-16T22:05:00+00:00 PythonOperator 2021-05-16T23:05:04.418124+00:00 2021-05-16T23:05:07.581089+00:00 0:00:03.162965 28880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T23:05:02.285696+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-16T22:00:00+00:00 EmrJobFlowSensor 2021-05-16T23:00:58.168834+00:00 2021-05-16T23:10:00.896609+00:00 0:09:02.727775 28879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T23:00:55.985537+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-15T23:00:00+00:00 EmrJobFlowSensor 2021-05-16T23:00:50.160655+00:00 2021-05-16T23:10:53.014247+00:00 0:10:02.853592 28878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T23:00:47.933368+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T23:00:38.485286+00:00 2021-05-16T23:00:40.202549+00:00 0:00:01.717263 28877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-16T23:00:35.922968+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-15T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T23:00:28.360481+00:00 2021-05-16T23:00:30.090678+00:00 0:00:01.730197 28876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T23:00:25.965334+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-16T22:00:00+00:00 PythonOperator 2021-05-16T23:00:14.462922+00:00 2021-05-16T23:00:17.656855+00:00 0:00:03.193933 28875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-16T23:00:11.960617+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-15T23:00:00+00:00 PythonOperator 2021-05-16T23:00:08.659521+00:00 2021-05-16T23:00:11.921068+00:00 0:00:03.261547 28874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T23:00:05.855470+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-16T21:00:00+00:00 EmrJobFlowSensor 2021-05-16T22:11:50.371376+00:00 2021-05-16T22:20:52.961661+00:00 0:09:02.590285 28872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T22:11:48.126404+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-16T21:00:00+00:00 EmrJobFlowSensor 2021-05-16T22:11:44.380457+00:00 2021-05-16T22:20:47.136079+00:00 0:09:02.755622 28871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T22:11:42.123441+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T22:11:28.469804+00:00 2021-05-16T22:11:30.227913+00:00 0:00:01.758109 28870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T22:11:26.148930+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T22:11:22.451186+00:00 2021-05-16T22:11:24.239818+00:00 0:00:01.788632 28869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T22:11:20.157608+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-16T21:00:00+00:00 PythonOperator 2021-05-16T22:11:08.908115+00:00 2021-05-16T22:11:12.005869+00:00 0:00:03.097754 28868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T22:11:06.101965+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-16T21:00:00+00:00 PythonOperator 2021-05-16T22:11:00.704443+00:00 2021-05-16T22:11:04.163167+00:00 0:00:03.458724 28867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T22:10:58.170341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-16T21:00:00+00:00 TriggerDagRunOperator 2021-05-16T22:10:56.944351+00:00 2021-05-16T22:10:57.473457+00:00 0:00:00.529106 28866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T22:10:54.153637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-16T21:00:00+00:00 TriggerDagRunOperator 2021-05-16T22:10:56.549901+00:00 2021-05-16T22:10:57.003132+00:00 0:00:00.453231 28865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T22:10:54.153684+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-16T21:05:00+00:00 EmrJobFlowSensor 2021-05-16T22:05:57.804860+00:00 2021-05-16T22:14:00.299260+00:00 0:08:02.494400 28864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T22:05:55.676318+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-16T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-16T22:05:36.082567+00:00 2021-05-16T22:05:37.819386+00:00 0:00:01.736819 28863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T22:05:33.668833+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-16T21:05:00+00:00 PythonOperator 2021-05-16T22:05:14.029187+00:00 2021-05-16T22:05:17.169604+00:00 0:00:03.140417 28862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T22:05:11.682074+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-16T21:00:00+00:00 EmrJobFlowSensor 2021-05-16T22:00:49.643051+00:00 2021-05-16T22:10:52.702176+00:00 0:10:03.059125 28861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T22:00:47.054330+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T22:00:27.003092+00:00 2021-05-16T22:00:28.803241+00:00 0:00:01.800149 28860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-16T22:00:24.853653+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-16T21:00:00+00:00 PythonOperator 2021-05-16T22:00:07.379392+00:00 2021-05-16T22:00:10.567045+00:00 0:00:03.187653 28859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-16T22:00:04.837754+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-16T20:00:00+00:00 EmrJobFlowSensor 2021-05-16T21:11:13.366376+00:00 2021-05-16T21:20:15.941920+00:00 0:09:02.575544 28857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T21:11:11.202113+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-16T20:00:00+00:00 EmrJobFlowSensor 2021-05-16T21:10:59.323083+00:00 2021-05-16T21:21:02.200967+00:00 0:10:02.877884 28856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T21:10:57.192538+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T21:10:51.514046+00:00 2021-05-16T21:10:53.321747+00:00 0:00:01.807701 28855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T21:10:49.185564+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T21:10:37.509369+00:00 2021-05-16T21:10:39.166888+00:00 0:00:01.657519 28854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T21:10:35.244534+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-16T20:00:00+00:00 PythonOperator 2021-05-16T21:10:31.405408+00:00 2021-05-16T21:10:34.521083+00:00 0:00:03.115675 28853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T21:10:29.137168+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-16T20:00:00+00:00 PythonOperator 2021-05-16T21:10:17.199615+00:00 2021-05-16T21:10:20.703327+00:00 0:00:03.503712 28852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T21:10:15.087490+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-16T20:00:00+00:00 TriggerDagRunOperator 2021-05-16T21:10:11.329621+00:00 2021-05-16T21:10:11.848158+00:00 0:00:00.518537 28851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T21:10:09.081995+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-16T20:00:00+00:00 TriggerDagRunOperator 2021-05-16T21:10:11.202295+00:00 2021-05-16T21:10:11.631609+00:00 0:00:00.429314 28850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T21:10:09.082023+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-16T20:05:00+00:00 EmrJobFlowSensor 2021-05-16T21:06:13.171122+00:00 2021-05-16T21:15:15.841073+00:00 0:09:02.669951 28849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T21:06:10.790067+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-16T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-16T21:05:52.903485+00:00 2021-05-16T21:05:54.567398+00:00 0:00:01.663913 28848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T21:05:50.755311+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-16T20:05:00+00:00 PythonOperator 2021-05-16T21:05:26.860482+00:00 2021-05-16T21:05:29.996087+00:00 0:00:03.135605 28847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T21:05:24.730958+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-16T20:00:00+00:00 EmrJobFlowSensor 2021-05-16T21:00:54.869337+00:00 2021-05-16T21:09:57.716930+00:00 0:09:02.847593 28846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T21:00:52.362105+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T21:00:32.532884+00:00 2021-05-16T21:00:34.273278+00:00 0:00:01.740394 28845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-16T21:00:30.268099+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-16T20:00:00+00:00 PythonOperator 2021-05-16T21:00:12.572597+00:00 2021-05-16T21:00:15.776153+00:00 0:00:03.203556 28844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-16T21:00:10.183757+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-16T19:00:00+00:00 EmrJobFlowSensor 2021-05-16T20:10:50.633376+00:00 2021-05-16T20:19:53.388487+00:00 0:09:02.755111 28842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T20:10:48.384414+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-16T19:00:00+00:00 EmrJobFlowSensor 2021-05-16T20:10:44.532521+00:00 2021-05-16T20:20:47.241716+00:00 0:10:02.709195 28841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T20:10:42.338328+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T20:10:30.577004+00:00 2021-05-16T20:10:32.268519+00:00 0:00:01.691515 28840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T20:10:28.350543+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-16T20:10:24.594391+00:00 2021-05-16T20:10:26.412823+00:00 0:00:01.818432 28839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-16T20:10:22.324976+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-16T19:00:00+00:00 PythonOperator 2021-05-16T20:10:08.660442+00:00 2021-05-16T20:10:11.879736+00:00 0:00:03.219294 28838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T20:10:06.306294+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-16T19:00:00+00:00 PythonOperator 2021-05-16T20:10:02.473614+00:00 2021-05-16T20:10:05.861474+00:00 0:00:03.387860 28837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-16T20:10:00.308408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-16T19:00:00+00:00 TriggerDagRunOperator 2021-05-16T20:09:42.868956+00:00 2021-05-16T20:09:43.372037+00:00 0:00:00.503081 28836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T20:09:40.356588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-16T19:00:00+00:00 TriggerDagRunOperator 2021-05-16T20:09:42.661534+00:00 2021-05-16T20:09:43.082960+00:00 0:00:00.421426 28835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T20:09:40.356637+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-16T19:05:00+00:00 EmrJobFlowSensor 2021-05-16T20:05:54.192907+00:00 2021-05-16T20:14:56.889282+00:00 0:09:02.696375 28834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-16T20:05:51.901014+00:00 2 default_pool