Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 check_cluster_status 2021-05-09T04:00:00+00:00 EmrJobFlowSensor 2021-05-09T05:01:04.469828+00:00 2021-05-09T05:10:07.310834+00:00 0:09:02.841006 26070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T05:01:02.109283+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T05:00:42.299591+00:00 2021-05-09T05:00:44.061059+00:00 0:00:01.761468 26069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T05:00:40.090276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T04:00:00+00:00 PythonOperator 2021-05-09T05:00:18.586203+00:00 2021-05-09T05:00:21.677507+00:00 0:00:03.091304 26068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T05:00:16.017522+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T03:00:00+00:00 EmrJobFlowSensor 2021-05-09T04:10:59.157399+00:00 2021-05-09T04:21:01.912936+00:00 0:10:02.755537 26066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:10:56.941180+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T03:00:00+00:00 EmrJobFlowSensor 2021-05-09T04:10:47.100130+00:00 2021-05-09T04:20:49.822472+00:00 0:10:02.722342 26065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:10:44.958099+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T04:10:39.503881+00:00 2021-05-09T04:10:41.320684+00:00 0:00:01.816803 26064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T04:10:36.941333+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T04:10:27.062475+00:00 2021-05-09T04:10:28.852100+00:00 0:00:01.789625 26063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T04:10:24.723860+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T03:00:00+00:00 PythonOperator 2021-05-09T04:10:16.859517+00:00 2021-05-09T04:10:20.154927+00:00 0:00:03.295410 26062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T04:10:14.719913+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T03:00:00+00:00 PythonOperator 2021-05-09T04:10:05.123530+00:00 2021-05-09T04:10:08.171400+00:00 0:00:03.047870 26061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T04:10:02.701397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T03:00:00+00:00 TriggerDagRunOperator 2021-05-09T04:09:55.151714+00:00 2021-05-09T04:09:55.697058+00:00 0:00:00.545344 26060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:09:52.694621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T03:00:00+00:00 TriggerDagRunOperator 2021-05-09T04:09:55.030580+00:00 2021-05-09T04:09:55.472466+00:00 0:00:00.441886 26059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:09:52.694664+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T03:05:00+00:00 EmrJobFlowSensor 2021-05-09T04:05:48.466104+00:00 2021-05-09T04:14:51.051804+00:00 0:09:02.585700 26058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:05:46.303897+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T04:05:28.409594+00:00 2021-05-09T04:05:30.094671+00:00 0:00:01.685077 26057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T04:05:26.298656+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T03:05:00+00:00 PythonOperator 2021-05-09T04:05:06.345461+00:00 2021-05-09T04:05:09.408452+00:00 0:00:03.062991 26056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T04:05:04.236556+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T03:00:00+00:00 EmrJobFlowSensor 2021-05-09T04:00:46.176818+00:00 2021-05-09T04:09:48.922270+00:00 0:09:02.745452 26055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T04:00:43.853386+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T04:00:26.365193+00:00 2021-05-09T04:00:28.169513+00:00 0:00:01.804320 26054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T04:00:23.859946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T03:00:00+00:00 PythonOperator 2021-05-09T04:00:04.443283+00:00 2021-05-09T04:00:07.567333+00:00 0:00:03.124050 26053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T04:00:01.644780+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T02:00:00+00:00 EmrJobFlowSensor 2021-05-09T03:12:29.715975+00:00 2021-05-09T03:20:32.278529+00:00 0:08:02.562554 26051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T03:12:27.177369+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T02:00:00+00:00 EmrJobFlowSensor 2021-05-09T03:12:25.379652+00:00 2021-05-09T03:21:28.099208+00:00 0:09:02.719556 26050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T03:12:23.162254+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T03:12:09.662204+00:00 2021-05-09T03:12:11.356632+00:00 0:00:01.694428 26049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T03:12:07.147548+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T03:12:03.417199+00:00 2021-05-09T03:12:05.175975+00:00 0:00:01.758776 26048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T03:12:01.141007+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T02:00:00+00:00 PythonOperator 2021-05-09T03:11:47.514951+00:00 2021-05-09T03:11:50.569662+00:00 0:00:03.054711 26047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T03:11:45.071499+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T02:00:00+00:00 PythonOperator 2021-05-09T03:11:41.327437+00:00 2021-05-09T03:11:44.681501+00:00 0:00:03.354064 26046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T03:11:39.060396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T02:00:00+00:00 TriggerDagRunOperator 2021-05-09T03:11:23.383167+00:00 2021-05-09T03:11:23.929127+00:00 0:00:00.545960 26045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T03:11:20.916036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T02:00:00+00:00 TriggerDagRunOperator 2021-05-09T03:11:23.225822+00:00 2021-05-09T03:11:23.677853+00:00 0:00:00.452031 26044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T03:11:20.915991+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T02:05:00+00:00 EmrJobFlowSensor 2021-05-09T03:05:54.496000+00:00 2021-05-09T03:14:57.163704+00:00 0:09:02.667704 26043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T03:05:52.208107+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T03:05:32.746048+00:00 2021-05-09T03:05:34.427612+00:00 0:00:01.681564 26042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T03:05:30.271724+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T02:05:00+00:00 PythonOperator 2021-05-09T03:05:06.393949+00:00 2021-05-09T03:05:09.461762+00:00 0:00:03.067813 26041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T03:05:04.119767+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T02:00:00+00:00 EmrJobFlowSensor 2021-05-09T03:00:56.050949+00:00 2021-05-09T03:10:59.013710+00:00 0:10:02.962761 26040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T03:00:53.631608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T03:00:30.186459+00:00 2021-05-09T03:00:32.054668+00:00 0:00:01.868209 26039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T03:00:27.607807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T02:00:00+00:00 PythonOperator 2021-05-09T03:00:08.247314+00:00 2021-05-09T03:00:11.457540+00:00 0:00:03.210226 26038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T03:00:05.598947+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T01:00:00+00:00 EmrJobFlowSensor 2021-05-09T02:12:09.585332+00:00 2021-05-09T02:22:12.305004+00:00 0:10:02.719672 26036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T02:12:07.451354+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T01:00:00+00:00 EmrJobFlowSensor 2021-05-09T02:12:03.737378+00:00 2021-05-09T02:21:06.582654+00:00 0:09:02.845276 26035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T02:12:01.444110+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T02:11:47.564630+00:00 2021-05-09T02:11:49.271295+00:00 0:00:01.706665 26034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T02:11:45.397771+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T02:11:39.998818+00:00 2021-05-09T02:11:41.764645+00:00 0:00:01.765827 26033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T02:11:37.457126+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T01:00:00+00:00 PythonOperator 2021-05-09T02:11:25.566578+00:00 2021-05-09T02:11:28.907529+00:00 0:00:03.340951 26032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T02:11:23.342805+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T01:00:00+00:00 PythonOperator 2021-05-09T02:11:20.091917+00:00 2021-05-09T02:11:23.131602+00:00 0:00:03.039685 26031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T02:11:17.347563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T01:00:00+00:00 TriggerDagRunOperator 2021-05-09T02:11:13.649158+00:00 2021-05-09T02:11:14.165823+00:00 0:00:00.516665 26030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T02:11:11.297676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T01:00:00+00:00 TriggerDagRunOperator 2021-05-09T02:11:13.526994+00:00 2021-05-09T02:11:13.946146+00:00 0:00:00.419152 26029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T02:11:11.297640+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T01:05:00+00:00 EmrJobFlowSensor 2021-05-09T02:05:50.734168+00:00 2021-05-09T02:14:53.379680+00:00 0:09:02.645512 26028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T02:05:48.480431+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T02:05:30.590981+00:00 2021-05-09T02:05:32.265347+00:00 0:00:01.674366 26027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T02:05:28.167871+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T01:05:00+00:00 PythonOperator 2021-05-09T02:05:08.474996+00:00 2021-05-09T02:05:11.509546+00:00 0:00:03.034550 26026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T02:05:05.984923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T01:00:00+00:00 EmrJobFlowSensor 2021-05-09T02:01:51.880469+00:00 2021-05-09T02:10:54.840997+00:00 0:09:02.960528 26025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T02:01:49.547634+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T02:00:33.581301+00:00 2021-05-09T02:00:35.275921+00:00 0:00:01.694620 26024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T02:00:31.438407+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T01:00:00+00:00 PythonOperator 2021-05-09T02:00:11.683483+00:00 2021-05-09T02:00:14.792717+00:00 0:00:03.109234 26023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T02:00:09.353386+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T00:00:00+00:00 EmrJobFlowSensor 2021-05-09T01:11:24.597210+00:00 2021-05-09T01:21:27.413937+00:00 0:10:02.816727 26021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T01:11:22.228068+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T00:00:00+00:00 EmrJobFlowSensor 2021-05-09T01:11:08.972361+00:00 2021-05-09T01:20:11.721590+00:00 0:09:02.749229 26020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T01:11:06.217457+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T01:11:00.775638+00:00 2021-05-09T01:11:02.456789+00:00 0:00:01.681151 26019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T01:10:58.271030+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T01:10:46.477123+00:00 2021-05-09T01:10:48.184531+00:00 0:00:01.707408 26018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T01:10:44.244247+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T00:00:00+00:00 PythonOperator 2021-05-09T01:10:38.606860+00:00 2021-05-09T01:10:41.634683+00:00 0:00:03.027823 26017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T01:10:36.262686+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T00:00:00+00:00 PythonOperator 2021-05-09T01:10:24.496792+00:00 2021-05-09T01:10:27.881270+00:00 0:00:03.384478 26016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T01:10:22.175933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T00:00:00+00:00 TriggerDagRunOperator 2021-05-09T01:10:20.496863+00:00 2021-05-09T01:10:21.017900+00:00 0:00:00.521037 26015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T01:10:18.159734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T00:00:00+00:00 TriggerDagRunOperator 2021-05-09T01:10:20.393474+00:00 2021-05-09T01:10:20.798967+00:00 0:00:00.405493 26014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T01:10:18.159699+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T00:05:00+00:00 EmrJobFlowSensor 2021-05-09T01:06:01.864383+00:00 2021-05-09T01:15:04.558035+00:00 0:09:02.693652 26013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T01:05:59.761777+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T01:05:39.937480+00:00 2021-05-09T01:05:41.702026+00:00 0:00:01.764546 26012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T01:05:37.688198+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T00:05:00+00:00 PythonOperator 2021-05-09T01:05:18.018653+00:00 2021-05-09T01:05:21.037761+00:00 0:00:03.019108 26011 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T01:05:15.661200+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T00:00:00+00:00 EmrJobFlowSensor 2021-05-09T01:01:03.242642+00:00 2021-05-09T01:10:06.087392+00:00 0:09:02.844750 26010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T01:01:01.040865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T01:00:41.231910+00:00 2021-05-09T01:00:43.066425+00:00 0:00:01.834515 26009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T01:00:38.894024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T00:00:00+00:00 PythonOperator 2021-05-09T01:00:19.681073+00:00 2021-05-09T01:00:22.748757+00:00 0:00:03.067684 26008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T01:00:16.864757+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T23:00:00+00:00 EmrJobFlowSensor 2021-05-09T00:13:10.825099+00:00 2021-05-09T00:23:13.716910+00:00 0:10:02.891811 26006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T00:13:08.600628+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T23:00:00+00:00 EmrJobFlowSensor 2021-05-09T00:13:08.691095+00:00 2021-05-09T00:33:13.114350+00:00 0:20:04.423255 26005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T00:13:06.593938+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T00:12:50.680079+00:00 2021-05-09T00:12:52.331144+00:00 0:00:01.651065 26004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T00:12:48.491569+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T00:12:46.828967+00:00 2021-05-09T00:12:48.669489+00:00 0:00:01.840522 26003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T00:12:44.493855+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T23:00:00+00:00 PythonOperator 2021-05-09T00:12:29.376103+00:00 2021-05-09T00:12:32.986324+00:00 0:00:03.610221 26002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T00:12:26.480936+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T23:00:00+00:00 PythonOperator 2021-05-09T00:12:24.737040+00:00 2021-05-09T00:12:28.327745+00:00 0:00:03.590705 26001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T00:12:22.458204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T23:00:00+00:00 TriggerDagRunOperator 2021-05-09T00:12:10.911892+00:00 2021-05-09T00:12:11.439006+00:00 0:00:00.527114 26000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T00:12:08.444637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T23:00:00+00:00 TriggerDagRunOperator 2021-05-09T00:12:10.667878+00:00 2021-05-09T00:12:11.096665+00:00 0:00:00.428787 25999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T00:12:08.444580+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T23:05:00+00:00 EmrJobFlowSensor 2021-05-09T00:05:59.745025+00:00 2021-05-09T00:15:02.403058+00:00 0:09:02.658033 25998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T00:05:57.468217+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T00:05:39.666488+00:00 2021-05-09T00:05:41.278142+00:00 0:00:01.611654 25997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T00:05:37.414303+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T23:05:00+00:00 PythonOperator 2021-05-09T00:05:17.785143+00:00 2021-05-09T00:05:20.898948+00:00 0:00:03.113805 25996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T00:05:15.459930+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T23:00:00+00:00 EmrJobFlowSensor 2021-05-09T00:00:56.716889+00:00 2021-05-09T00:11:59.608359+00:00 0:11:02.891470 25995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T00:00:54.608422+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T00:00:36.846469+00:00 2021-05-09T00:00:38.670554+00:00 0:00:01.824085 25994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T00:00:34.587410+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T23:00:00+00:00 PythonOperator 2021-05-09T00:00:13.092383+00:00 2021-05-09T00:00:16.256207+00:00 0:00:03.163824 25993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T00:00:10.577686+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T22:00:00+00:00 EmrJobFlowSensor 2021-05-08T23:11:09.450230+00:00 2021-05-08T23:20:12.083940+00:00 0:09:02.633710 25991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:11:07.245345+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T22:00:00+00:00 EmrJobFlowSensor 2021-05-08T23:11:03.453940+00:00 2021-05-08T23:20:06.056412+00:00 0:09:02.602472 25990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:11:01.233978+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:10:47.505982+00:00 2021-05-08T23:10:49.173107+00:00 0:00:01.667125 25989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T23:10:45.180995+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:10:41.291618+00:00 2021-05-08T23:10:42.937836+00:00 0:00:01.646218 25988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T23:10:39.158031+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T22:00:00+00:00 PythonOperator 2021-05-08T23:10:25.570960+00:00 2021-05-08T23:10:29.067624+00:00 0:00:03.496664 25987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:10:23.174655+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T22:00:00+00:00 PythonOperator 2021-05-08T23:10:19.644951+00:00 2021-05-08T23:10:22.724951+00:00 0:00:03.080000 25986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:10:17.099770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T22:00:00+00:00 TriggerDagRunOperator 2021-05-08T23:10:11.583401+00:00 2021-05-08T23:10:12.163927+00:00 0:00:00.580526 25985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:10:09.169629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T22:00:00+00:00 TriggerDagRunOperator 2021-05-08T23:10:11.455366+00:00 2021-05-08T23:10:11.875563+00:00 0:00:00.420197 25984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:10:09.169589+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T22:05:00+00:00 EmrJobFlowSensor 2021-05-08T23:06:10.851586+00:00 2021-05-08T23:14:13.502863+00:00 0:08:02.651277 25983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:06:08.455450+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:05:44.494701+00:00 2021-05-08T23:05:46.139036+00:00 0:00:01.644335 25982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T23:05:42.298293+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T22:05:00+00:00 PythonOperator 2021-05-08T23:05:18.642279+00:00 2021-05-08T23:05:21.639203+00:00 0:00:02.996924 25981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:05:16.289837+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-07T23:00:00+00:00 EmrJobFlowSensor 2021-05-08T23:01:03.838198+00:00 2021-05-08T23:09:06.439387+00:00 0:08:02.601189 25980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T23:01:01.670670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T22:00:00+00:00 EmrJobFlowSensor 2021-05-08T23:00:50.191338+00:00 2021-05-08T23:09:52.846641+00:00 0:09:02.655303 25979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:00:47.661414+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:00:41.753267+00:00 2021-05-08T23:00:43.417411+00:00 0:00:01.664144 25978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T23:00:39.653497+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T23:00:28.375082+00:00 2021-05-08T23:00:30.061291+00:00 0:00:01.686209 25977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T23:00:25.563000+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-07T23:00:00+00:00 PythonOperator 2021-05-08T23:00:19.931942+00:00 2021-05-08T23:00:23.041444+00:00 0:00:03.109502 25976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T23:00:17.564184+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T22:00:00+00:00 PythonOperator 2021-05-08T23:00:06.016047+00:00 2021-05-08T23:00:09.162547+00:00 0:00:03.146500 25975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T23:00:03.578766+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T21:00:00+00:00 EmrJobFlowSensor 2021-05-08T22:23:30.675755+00:00 2021-05-08T22:32:33.289675+00:00 0:09:02.613920 25974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:23:28.552262+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T21:00:00+00:00 EmrJobFlowSensor 2021-05-08T22:23:16.714127+00:00 2021-05-08T22:33:19.724595+00:00 0:10:03.010468 25973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:23:14.529996+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:23:08.785852+00:00 2021-05-08T22:23:10.506938+00:00 0:00:01.721086 25972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T22:23:06.518552+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:22:56.687928+00:00 2021-05-08T22:22:58.387205+00:00 0:00:01.699277 25971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T22:22:54.501625+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T21:00:00+00:00 PythonOperator 2021-05-08T22:22:46.614960+00:00 2021-05-08T22:22:49.698541+00:00 0:00:03.083581 25970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:22:44.494928+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T21:00:00+00:00 PythonOperator 2021-05-08T22:22:34.917505+00:00 2021-05-08T22:22:38.202944+00:00 0:00:03.285439 25969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:22:32.563820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T21:00:00+00:00 TriggerDagRunOperator 2021-05-08T22:22:23.313139+00:00 2021-05-08T22:22:23.752925+00:00 0:00:00.439786 25968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:22:20.461679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T21:00:00+00:00 TriggerDagRunOperator 2021-05-08T22:22:23.323843+00:00 2021-05-08T22:22:23.918953+00:00 0:00:00.595110 25967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:22:20.461633+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T21:05:00+00:00 EmrJobFlowSensor 2021-05-08T22:05:54.970685+00:00 2021-05-08T22:13:57.510459+00:00 0:08:02.539774 25965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T22:05:52.551001+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:05:32.824595+00:00 2021-05-08T22:05:34.543450+00:00 0:00:01.718855 25964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T22:05:30.468515+00:00 2 default_pool