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 create_cluster_and_add_emr_steps 2021-05-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T21:00:32.404322+00:00 2021-05-11T21:00:34.075583+00:00 0:00:01.671261 27035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T21:00:29.990151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T20:00:00+00:00 PythonOperator 2021-05-11T21:00:10.655048+00:00 2021-05-11T21:00:13.813635+00:00 0:00:03.158587 27034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T21:00:07.964369+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T19:00:00+00:00 EmrJobFlowSensor 2021-05-11T20:10:19.786290+00:00 2021-05-11T20:19:22.452955+00:00 0:09:02.666665 27032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T20:10:17.371997+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T19:00:00+00:00 EmrJobFlowSensor 2021-05-11T20:10:17.384368+00:00 2021-05-11T20:20:20.427355+00:00 0:10:03.042987 27031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T20:10:15.327864+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T20:09:57.680917+00:00 2021-05-11T20:09:59.372502+00:00 0:00:01.691585 27030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T20:09:55.373842+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T20:09:55.886998+00:00 2021-05-11T20:09:57.878997+00:00 0:00:01.991999 27029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T20:09:53.370252+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T19:00:00+00:00 PythonOperator 2021-05-11T20:09:35.827282+00:00 2021-05-11T20:09:39.127065+00:00 0:00:03.299783 27028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T20:09:33.287754+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T19:00:00+00:00 PythonOperator 2021-05-11T20:09:35.608696+00:00 2021-05-11T20:09:38.748115+00:00 0:00:03.139419 27027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T20:09:33.287716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T19:00:00+00:00 TriggerDagRunOperator 2021-05-11T20:09:25.829500+00:00 2021-05-11T20:09:26.413071+00:00 0:00:00.583571 27026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T20:09:23.262108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T19:00:00+00:00 TriggerDagRunOperator 2021-05-11T20:09:25.701765+00:00 2021-05-11T20:09:26.100872+00:00 0:00:00.399107 27025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T20:09:23.262054+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T19:05:00+00:00 EmrJobFlowSensor 2021-05-11T20:06:07.139363+00:00 2021-05-11T20:15:09.836656+00:00 0:09:02.697293 27024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T20:06:04.918258+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T20:05:43.169957+00:00 2021-05-11T20:05:45.077513+00:00 0:00:01.907556 27023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T20:05:40.893588+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T19:05:00+00:00 PythonOperator 2021-05-11T20:05:22.995591+00:00 2021-05-11T20:05:26.086794+00:00 0:00:03.091203 27022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T20:05:20.845565+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T19:00:00+00:00 EmrJobFlowSensor 2021-05-11T20:01:00.964054+00:00 2021-05-11T20:09:03.732681+00:00 0:08:02.768627 27021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T20:00:58.392313+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T20:00:38.700557+00:00 2021-05-11T20:00:40.418784+00:00 0:00:01.718227 27020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T20:00:36.259375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T19:00:00+00:00 PythonOperator 2021-05-11T20:00:18.565698+00:00 2021-05-11T20:00:21.682414+00:00 0:00:03.116716 27019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T20:00:16.247621+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T18:00:00+00:00 EmrJobFlowSensor 2021-05-11T19:13:02.805757+00:00 2021-05-11T19:21:05.406853+00:00 0:08:02.601096 27018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T19:13:00.571390+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T18:00:00+00:00 EmrJobFlowSensor 2021-05-11T19:12:58.949996+00:00 2021-05-11T19:22:01.656241+00:00 0:09:02.706245 27017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T19:12:56.572237+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T19:12:40.809483+00:00 2021-05-11T19:12:42.652869+00:00 0:00:01.843386 27016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T19:12:38.545736+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T19:12:38.587636+00:00 2021-05-11T19:12:40.285616+00:00 0:00:01.697980 27015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T19:12:36.482949+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T18:00:00+00:00 PythonOperator 2021-05-11T19:12:20.734563+00:00 2021-05-11T19:12:23.812456+00:00 0:00:03.077893 27014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T19:12:18.464675+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T18:00:00+00:00 PythonOperator 2021-05-11T19:12:16.983784+00:00 2021-05-11T19:12:20.331661+00:00 0:00:03.347877 27013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T19:12:14.505300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T18:00:00+00:00 TriggerDagRunOperator 2021-05-11T19:11:14.626042+00:00 2021-05-11T19:11:15.038182+00:00 0:00:00.412140 27011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T19:11:11.825538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T18:00:00+00:00 TriggerDagRunOperator 2021-05-11T19:11:14.470385+00:00 2021-05-11T19:11:15.022755+00:00 0:00:00.552370 27010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T19:11:11.825567+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T18:05:00+00:00 EmrJobFlowSensor 2021-05-11T19:05:47.210468+00:00 2021-05-11T19:14:49.845161+00:00 0:09:02.634693 27009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T19:05:44.982318+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T19:05:27.003622+00:00 2021-05-11T19:05:28.669514+00:00 0:00:01.665892 27008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T19:05:24.906553+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T18:05:00+00:00 PythonOperator 2021-05-11T19:05:05.179757+00:00 2021-05-11T19:05:08.239594+00:00 0:00:03.059837 27007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T19:05:02.875145+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T18:00:00+00:00 EmrJobFlowSensor 2021-05-11T19:01:02.600297+00:00 2021-05-11T19:11:05.561841+00:00 0:10:02.961544 27006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T19:01:00.341001+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T19:00:40.434714+00:00 2021-05-11T19:00:42.258102+00:00 0:00:01.823388 27005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T19:00:38.194762+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T18:00:00+00:00 PythonOperator 2021-05-11T19:00:08.308086+00:00 2021-05-11T19:00:11.463302+00:00 0:00:03.155216 27004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T19:00:06.118334+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T17:00:00+00:00 EmrJobFlowSensor 2021-05-11T18:12:36.569191+00:00 2021-05-11T18:22:39.441659+00:00 0:10:02.872468 27003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T18:12:34.045020+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T17:00:00+00:00 EmrJobFlowSensor 2021-05-11T18:12:32.174519+00:00 2021-05-11T18:21:34.909407+00:00 0:09:02.734888 27002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T18:12:29.913265+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T18:12:14.159089+00:00 2021-05-11T18:12:15.865027+00:00 0:00:01.705938 27001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T18:12:11.955579+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T18:12:12.114093+00:00 2021-05-11T18:12:14.025738+00:00 0:00:01.911645 27000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T18:12:09.887347+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T17:00:00+00:00 PythonOperator 2021-05-11T18:11:54.571878+00:00 2021-05-11T18:11:58.009145+00:00 0:00:03.437267 26999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T18:11:51.846662+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T17:00:00+00:00 PythonOperator 2021-05-11T18:11:50.073292+00:00 2021-05-11T18:11:53.797344+00:00 0:00:03.724052 26998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T18:11:47.837823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T17:00:00+00:00 TriggerDagRunOperator 2021-05-11T18:11:28.524368+00:00 2021-05-11T18:11:29.098937+00:00 0:00:00.574569 26997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T18:11:25.634514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T17:00:00+00:00 TriggerDagRunOperator 2021-05-11T18:11:28.352898+00:00 2021-05-11T18:11:28.769867+00:00 0:00:00.416969 26996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T18:11:25.634564+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T17:05:00+00:00 EmrJobFlowSensor 2021-05-11T18:05:47.587862+00:00 2021-05-11T18:14:50.251017+00:00 0:09:02.663155 26994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T18:05:45.232665+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T18:05:27.295519+00:00 2021-05-11T18:05:28.917639+00:00 0:00:01.622120 26993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T18:05:25.219186+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T17:05:00+00:00 PythonOperator 2021-05-11T18:05:05.322140+00:00 2021-05-11T18:05:08.371635+00:00 0:00:03.049495 26992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T18:05:03.189500+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T17:00:00+00:00 EmrJobFlowSensor 2021-05-11T18:01:02.993175+00:00 2021-05-11T18:09:05.632110+00:00 0:08:02.638935 26991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T18:01:00.651334+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T18:00:40.790511+00:00 2021-05-11T18:00:42.497691+00:00 0:00:01.707180 26990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T18:00:38.593530+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T17:00:00+00:00 PythonOperator 2021-05-11T18:00:18.901295+00:00 2021-05-11T18:00:22.019183+00:00 0:00:03.117888 26989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T18:00:16.545581+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T16:00:00+00:00 EmrJobFlowSensor 2021-05-11T17:11:08.144786+00:00 2021-05-11T17:20:10.941506+00:00 0:09:02.796720 26988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:11:05.887634+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T16:00:00+00:00 EmrJobFlowSensor 2021-05-11T17:11:08.077891+00:00 2021-05-11T17:22:11.152812+00:00 0:11:03.074921 26987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:11:05.887670+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T17:10:47.941242+00:00 2021-05-11T17:10:49.640225+00:00 0:00:01.698983 26986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T17:10:45.796182+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T17:10:44.317954+00:00 2021-05-11T17:10:46.035682+00:00 0:00:01.717728 26985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T17:10:41.850295+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T16:00:00+00:00 PythonOperator 2021-05-11T17:10:24.284728+00:00 2021-05-11T17:10:27.425380+00:00 0:00:03.140652 26984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T17:10:21.769448+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T16:00:00+00:00 PythonOperator 2021-05-11T17:10:21.797996+00:00 2021-05-11T17:10:25.134913+00:00 0:00:03.336917 26983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T17:10:19.712053+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T16:00:00+00:00 TriggerDagRunOperator 2021-05-11T17:10:18.442859+00:00 2021-05-11T17:10:19.025880+00:00 0:00:00.583021 26982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:10:15.861793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T16:00:00+00:00 TriggerDagRunOperator 2021-05-11T17:10:18.177485+00:00 2021-05-11T17:10:18.647059+00:00 0:00:00.469574 26981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:10:15.861837+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T16:05:00+00:00 EmrJobFlowSensor 2021-05-11T17:09:10.267892+00:00 2021-05-11T17:17:12.846826+00:00 0:08:02.578934 26980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:09:07.741094+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T17:08:49.980964+00:00 2021-05-11T17:08:51.740240+00:00 0:00:01.759276 26979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T17:08:47.594333+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T16:05:00+00:00 PythonOperator 2021-05-11T17:08:28.062747+00:00 2021-05-11T17:08:31.151584+00:00 0:00:03.088837 26978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T17:08:25.565934+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T16:00:00+00:00 EmrJobFlowSensor 2021-05-11T17:01:05.300919+00:00 2021-05-11T17:10:08.035587+00:00 0:09:02.734668 26976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T17:01:03.085074+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T17:00:43.213009+00:00 2021-05-11T17:00:44.915130+00:00 0:00:01.702121 26975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T17:00:40.991724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T16:00:00+00:00 PythonOperator 2021-05-11T17:00:21.161962+00:00 2021-05-11T17:00:24.280027+00:00 0:00:03.118065 26974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T17:00:18.931149+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T15:00:00+00:00 EmrJobFlowSensor 2021-05-11T16:14:40.143600+00:00 2021-05-11T16:23:42.750994+00:00 0:09:02.607394 26973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:14:38.005395+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T15:00:00+00:00 EmrJobFlowSensor 2021-05-11T16:14:38.321818+00:00 2021-05-11T16:23:41.067072+00:00 0:09:02.745254 26972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:14:36.004481+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T16:14:20.123117+00:00 2021-05-11T16:14:21.808296+00:00 0:00:01.685179 26971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T16:14:17.986232+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T16:14:16.089006+00:00 2021-05-11T16:14:17.825641+00:00 0:00:01.736635 26970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T16:14:14.000700+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T15:00:00+00:00 PythonOperator 2021-05-11T16:13:58.515502+00:00 2021-05-11T16:14:01.607225+00:00 0:00:03.091723 26969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T16:13:55.944616+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T15:00:00+00:00 PythonOperator 2021-05-11T16:13:56.292716+00:00 2021-05-11T16:13:59.816853+00:00 0:00:03.524137 26968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T16:13:53.940260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T15:00:00+00:00 TriggerDagRunOperator 2021-05-11T16:13:50.441326+00:00 2021-05-11T16:13:50.953801+00:00 0:00:00.512475 26967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:13:47.939073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T15:00:00+00:00 TriggerDagRunOperator 2021-05-11T16:13:50.296754+00:00 2021-05-11T16:13:50.714957+00:00 0:00:00.418203 26966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:13:47.939042+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T15:05:00+00:00 EmrJobFlowSensor 2021-05-11T16:06:01.369421+00:00 2021-05-11T16:14:03.856195+00:00 0:08:02.486774 26965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:05:59.270900+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T16:05:35.356061+00:00 2021-05-11T16:05:37.015239+00:00 0:00:01.659178 26964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T16:05:33.241653+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T15:05:00+00:00 PythonOperator 2021-05-11T16:05:07.277808+00:00 2021-05-11T16:05:10.362086+00:00 0:00:03.084278 26963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T16:05:05.210976+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T15:00:00+00:00 EmrJobFlowSensor 2021-05-11T16:04:37.315851+00:00 2021-05-11T16:13:40.039805+00:00 0:09:02.723954 26962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T16:04:35.185129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T16:04:15.295283+00:00 2021-05-11T16:04:16.971844+00:00 0:00:01.676561 26961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T16:04:13.170206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T15:00:00+00:00 PythonOperator 2021-05-11T16:03:55.744129+00:00 2021-05-11T16:03:59.070026+00:00 0:00:03.325897 26960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T16:03:53.142373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T14:00:00+00:00 EmrJobFlowSensor 2021-05-11T15:23:34.602841+00:00 2021-05-11T15:34:37.744889+00:00 0:11:03.142048 26958 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:23:32.226774+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T14:00:00+00:00 EmrJobFlowSensor 2021-05-11T15:23:30.488548+00:00 2021-05-11T15:33:33.261540+00:00 0:10:02.772992 26957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:23:28.253140+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T15:23:14.659911+00:00 2021-05-11T15:23:16.509034+00:00 0:00:01.849123 26956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T15:23:12.104814+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T15:23:08.366141+00:00 2021-05-11T15:23:10.160289+00:00 0:00:01.794148 26955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T15:23:06.101383+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T14:00:00+00:00 PythonOperator 2021-05-11T15:22:52.269402+00:00 2021-05-11T15:22:55.542564+00:00 0:00:03.273162 26954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T15:22:50.090056+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T14:00:00+00:00 PythonOperator 2021-05-11T15:22:46.506555+00:00 2021-05-11T15:22:49.636787+00:00 0:00:03.130232 26953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T15:22:44.367321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T14:00:00+00:00 TriggerDagRunOperator 2021-05-11T15:22:28.813566+00:00 2021-05-11T15:22:29.321133+00:00 0:00:00.507567 26952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:22:25.979560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T14:00:00+00:00 TriggerDagRunOperator 2021-05-11T15:22:28.599678+00:00 2021-05-11T15:22:29.017771+00:00 0:00:00.418093 26951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:22:25.979532+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T14:05:00+00:00 EmrJobFlowSensor 2021-05-11T15:06:00.553722+00:00 2021-05-11T15:14:03.010179+00:00 0:08:02.456457 26950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:05:58.341476+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T15:05:38.354785+00:00 2021-05-11T15:05:39.987158+00:00 0:00:01.632373 26949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T15:05:36.151246+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T14:05:00+00:00 PythonOperator 2021-05-11T15:05:16.343119+00:00 2021-05-11T15:05:19.617460+00:00 0:00:03.274341 26948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T15:05:14.061547+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T14:00:00+00:00 EmrJobFlowSensor 2021-05-11T15:01:03.780319+00:00 2021-05-11T15:22:08.355920+00:00 0:21:04.575601 26947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T15:01:01.599501+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T15:00:37.809300+00:00 2021-05-11T15:00:39.488114+00:00 0:00:01.678814 26946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T15:00:35.548107+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T14:00:00+00:00 PythonOperator 2021-05-11T15:00:15.954243+00:00 2021-05-11T15:00:19.150370+00:00 0:00:03.196127 26945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T15:00:13.530875+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T13:00:00+00:00 EmrJobFlowSensor 2021-05-11T14:11:15.517941+00:00 2021-05-11T14:19:18.018430+00:00 0:08:02.500489 26943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:11:13.315752+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T13:00:00+00:00 EmrJobFlowSensor 2021-05-11T14:11:07.371716+00:00 2021-05-11T14:21:10.254033+00:00 0:10:02.882317 26942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:11:05.308624+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T14:10:53.892775+00:00 2021-05-11T14:10:55.616510+00:00 0:00:01.723735 26941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T14:10:51.351300+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T14:10:45.504784+00:00 2021-05-11T14:10:47.190716+00:00 0:00:01.685932 26940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T14:10:43.293785+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T13:00:00+00:00 PythonOperator 2021-05-11T14:10:33.852360+00:00 2021-05-11T14:10:37.033453+00:00 0:00:03.181093 26939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T14:10:31.285836+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T13:00:00+00:00 PythonOperator 2021-05-11T14:10:25.402453+00:00 2021-05-11T14:10:28.759500+00:00 0:00:03.357047 26938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T14:10:23.203630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T13:00:00+00:00 TriggerDagRunOperator 2021-05-11T14:10:15.713526+00:00 2021-05-11T14:10:16.261962+00:00 0:00:00.548436 26937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:10:13.257640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T13:00:00+00:00 TriggerDagRunOperator 2021-05-11T14:10:15.565171+00:00 2021-05-11T14:10:15.985620+00:00 0:00:00.420449 26936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:10:13.257675+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T13:05:00+00:00 EmrJobFlowSensor 2021-05-11T14:05:52.868020+00:00 2021-05-11T14:14:55.569775+00:00 0:09:02.701755 26935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:05:50.647828+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T14:05:32.876023+00:00 2021-05-11T14:05:34.687620+00:00 0:00:01.811597 26934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T14:05:30.558274+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T13:05:00+00:00 PythonOperator 2021-05-11T14:05:10.558794+00:00 2021-05-11T14:05:13.741410+00:00 0:00:03.182616 26933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T14:05:08.421357+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T13:00:00+00:00 EmrJobFlowSensor 2021-05-11T14:00:52.029555+00:00 2021-05-11T14:09:54.775383+00:00 0:09:02.745828 26932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T14:00:49.940869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T14:00:30.125093+00:00 2021-05-11T14:00:31.850590+00:00 0:00:01.725497 26931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T14:00:27.919868+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T13:00:00+00:00 PythonOperator 2021-05-11T14:00:08.780114+00:00 2021-05-11T14:00:11.873953+00:00 0:00:03.093839 26930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T14:00:05.966546+00:00 2 default_pool