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 check_cluster_status 2021-03-24T02:05:00+00:00 EmrJobFlowSensor 2021-03-24T03:06:08.625332+00:00 2021-03-24T03:15:11.348666+00:00 0:09:02.723334 11102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T03:06:06.324927+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T02:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T03:05:46.530191+00:00 2021-03-24T03:05:48.216043+00:00 0:00:01.685852 11101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T03:05:44.307828+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T02:05:00+00:00 PythonOperator 2021-03-24T03:05:24.707343+00:00 2021-03-24T03:05:27.493653+00:00 0:00:02.786310 11100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T03:05:22.389634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T02:00:00+00:00 EmrJobFlowSensor 2021-03-24T03:00:58.037626+00:00 2021-03-24T03:10:00.925710+00:00 0:09:02.888084 11099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T03:00:55.906143+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T03:00:36.237311+00:00 2021-03-24T03:00:38.021845+00:00 0:00:01.784534 11098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T03:00:33.892138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T02:00:00+00:00 PythonOperator 2021-03-24T03:00:14.332562+00:00 2021-03-24T03:00:17.076680+00:00 0:00:02.744118 11097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T03:00:11.821359+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T01:00:00+00:00 EmrJobFlowSensor 2021-03-24T02:12:35.917099+00:00 2021-03-24T02:22:38.825376+00:00 0:10:02.908277 11095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:12:33.598252+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T01:00:00+00:00 EmrJobFlowSensor 2021-03-24T02:12:22.095986+00:00 2021-03-24T02:21:24.931671+00:00 0:09:02.835685 11094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:12:19.651801+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:12:11.811370+00:00 2021-03-24T02:12:13.566838+00:00 0:00:01.755468 11093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T02:12:09.571893+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:11:51.756951+00:00 2021-03-24T02:11:53.512983+00:00 0:00:01.756032 11092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T02:11:49.553529+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T01:00:00+00:00 PythonOperator 2021-03-24T02:11:45.762928+00:00 2021-03-24T02:11:48.668677+00:00 0:00:02.905749 11091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:11:43.543114+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T01:00:00+00:00 PythonOperator 2021-03-24T02:11:25.785953+00:00 2021-03-24T02:11:28.554565+00:00 0:00:02.768612 11090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:11:23.618494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T01:00:00+00:00 TriggerDagRunOperator 2021-03-24T02:11:21.840804+00:00 2021-03-24T02:11:22.345207+00:00 0:00:00.504403 11089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:11:19.523262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T01:00:00+00:00 TriggerDagRunOperator 2021-03-24T02:11:21.701158+00:00 2021-03-24T02:11:22.111147+00:00 0:00:00.409989 11088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:11:19.523230+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T01:05:00+00:00 EmrJobFlowSensor 2021-03-24T02:06:05.496252+00:00 2021-03-24T02:15:08.142614+00:00 0:09:02.646362 11087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T02:06:03.088066+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T01:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:05:43.078935+00:00 2021-03-24T02:05:44.705356+00:00 0:00:01.626421 11086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T02:05:40.951667+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T01:05:00+00:00 PythonOperator 2021-03-24T02:05:23.184516+00:00 2021-03-24T02:05:26.052586+00:00 0:00:02.868070 11085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:05:20.901429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T01:00:00+00:00 EmrJobFlowSensor 2021-03-24T02:01:04.808534+00:00 2021-03-24T02:11:07.980947+00:00 0:10:03.172413 11084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T02:01:02.494566+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T02:00:42.618869+00:00 2021-03-24T02:00:44.388166+00:00 0:00:01.769297 11083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T02:00:40.420450+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T01:00:00+00:00 PythonOperator 2021-03-24T02:00:21.182913+00:00 2021-03-24T02:00:23.997661+00:00 0:00:02.814748 11082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T02:00:18.464334+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T00:00:00+00:00 EmrJobFlowSensor 2021-03-24T01:12:26.883726+00:00 2021-03-24T01:22:29.635366+00:00 0:10:02.751640 11080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:12:24.465733+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T00:00:00+00:00 EmrJobFlowSensor 2021-03-24T01:12:16.660233+00:00 2021-03-24T01:21:19.456718+00:00 0:09:02.796485 11079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:12:14.399968+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:12:06.808232+00:00 2021-03-24T01:12:08.538663+00:00 0:00:01.730431 11078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T01:12:04.392891+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:11:54.652670+00:00 2021-03-24T01:11:56.303590+00:00 0:00:01.650920 11077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T01:11:52.359377+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T00:00:00+00:00 PythonOperator 2021-03-24T01:11:44.626503+00:00 2021-03-24T01:11:47.739411+00:00 0:00:03.112908 11076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:11:42.347972+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T00:00:00+00:00 PythonOperator 2021-03-24T01:11:34.618565+00:00 2021-03-24T01:11:37.320146+00:00 0:00:02.701581 11075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:11:32.340452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T00:00:00+00:00 TriggerDagRunOperator 2021-03-24T01:11:18.997495+00:00 2021-03-24T01:11:19.509036+00:00 0:00:00.511541 11074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:11:16.377286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T00:00:00+00:00 TriggerDagRunOperator 2021-03-24T01:11:18.920258+00:00 2021-03-24T01:11:19.317770+00:00 0:00:00.397512 11073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:11:16.377340+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T00:05:00+00:00 EmrJobFlowSensor 2021-03-24T01:05:50.020164+00:00 2021-03-24T01:14:52.568480+00:00 0:09:02.548316 11072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T01:05:47.814849+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T00:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:05:28.123426+00:00 2021-03-24T01:05:29.800964+00:00 0:00:01.677538 11071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T01:05:25.867998+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T00:05:00+00:00 PythonOperator 2021-03-24T01:05:07.873312+00:00 2021-03-24T01:05:10.534043+00:00 0:00:02.660731 11070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:05:05.738847+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T00:00:00+00:00 EmrJobFlowSensor 2021-03-24T01:00:51.595112+00:00 2021-03-24T01:10:54.444882+00:00 0:10:02.849770 11069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T01:00:49.283644+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T01:00:29.446809+00:00 2021-03-24T01:00:31.158011+00:00 0:00:01.711202 11068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T01:00:27.264642+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T00:00:00+00:00 PythonOperator 2021-03-24T01:00:09.497433+00:00 2021-03-24T01:00:12.217241+00:00 0:00:02.719808 11067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T01:00:07.211379+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T23:00:00+00:00 EmrJobFlowSensor 2021-03-24T00:10:22.495719+00:00 2021-03-24T00:20:25.225411+00:00 0:10:02.729692 11065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T00:10:20.245277+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T23:00:00+00:00 EmrJobFlowSensor 2021-03-24T00:10:16.523594+00:00 2021-03-24T00:19:19.293559+00:00 0:09:02.769965 11064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T00:10:14.240477+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T00:10:00.622072+00:00 2021-03-24T00:10:02.372782+00:00 0:00:01.750710 11063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T00:09:58.254442+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T00:09:56.389747+00:00 2021-03-24T00:09:58.143414+00:00 0:00:01.753667 11062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T00:09:54.134252+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T23:00:00+00:00 PythonOperator 2021-03-24T00:09:38.393324+00:00 2021-03-24T00:09:41.155603+00:00 0:00:02.762279 11061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T00:09:36.167579+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T23:00:00+00:00 PythonOperator 2021-03-24T00:09:34.290299+00:00 2021-03-24T00:09:37.353006+00:00 0:00:03.062707 11060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T00:09:32.103385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T23:00:00+00:00 TriggerDagRunOperator 2021-03-24T00:09:18.550184+00:00 2021-03-24T00:09:19.155873+00:00 0:00:00.605689 11059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T00:09:16.152002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T23:00:00+00:00 TriggerDagRunOperator 2021-03-24T00:09:18.343637+00:00 2021-03-24T00:09:18.745498+00:00 0:00:00.401861 11058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T00:09:16.151961+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T23:05:00+00:00 EmrJobFlowSensor 2021-03-24T00:06:13.940795+00:00 2021-03-24T00:15:16.618832+00:00 0:09:02.678037 11057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T00:06:11.795126+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T23:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T00:05:51.890735+00:00 2021-03-24T00:05:53.532253+00:00 0:00:01.641518 11056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T00:05:49.736421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T23:05:00+00:00 PythonOperator 2021-03-24T00:05:24.205866+00:00 2021-03-24T00:05:26.988634+00:00 0:00:02.782768 11055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T00:05:21.712262+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T23:00:00+00:00 EmrJobFlowSensor 2021-03-24T00:01:06.077679+00:00 2021-03-24T00:09:08.721420+00:00 0:08:02.643741 11054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T00:01:03.544520+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T00:00:45.792163+00:00 2021-03-24T00:00:47.511661+00:00 0:00:01.719498 11053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T00:00:43.457371+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T23:00:00+00:00 PythonOperator 2021-03-24T00:00:23.759361+00:00 2021-03-24T00:00:26.576457+00:00 0:00:02.817096 11052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T00:00:21.380617+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T22:00:00+00:00 EmrJobFlowSensor 2021-03-23T23:11:38.655288+00:00 2021-03-23T23:21:41.438158+00:00 0:10:02.782870 11050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T23:11:36.190067+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T22:00:00+00:00 EmrJobFlowSensor 2021-03-23T23:11:38.490436+00:00 2021-03-23T23:20:41.191278+00:00 0:09:02.700842 11049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T23:11:36.190104+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T23:11:18.449098+00:00 2021-03-23T23:11:20.169843+00:00 0:00:01.720745 11048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T23:11:16.183403+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T23:11:16.533837+00:00 2021-03-23T23:11:18.381497+00:00 0:00:01.847660 11047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T23:11:14.243776+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T22:00:00+00:00 PythonOperator 2021-03-23T23:10:56.675773+00:00 2021-03-23T23:10:59.766046+00:00 0:00:03.090273 11046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T23:10:54.115817+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T22:00:00+00:00 PythonOperator 2021-03-23T23:10:56.496042+00:00 2021-03-23T23:10:59.223214+00:00 0:00:02.727172 11045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T23:10:54.115782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T22:00:00+00:00 TriggerDagRunOperator 2021-03-23T23:10:34.623861+00:00 2021-03-23T23:10:35.119239+00:00 0:00:00.495378 11044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T23:10:32.094599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T22:00:00+00:00 TriggerDagRunOperator 2021-03-23T23:10:34.420436+00:00 2021-03-23T23:10:34.865993+00:00 0:00:00.445557 11043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T23:10:32.094635+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T22:05:00+00:00 EmrJobFlowSensor 2021-03-23T23:05:47.770790+00:00 2021-03-23T23:13:50.316121+00:00 0:08:02.545331 11042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T23:05:45.549785+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T22:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T23:05:25.637847+00:00 2021-03-23T23:05:27.291221+00:00 0:00:01.653374 11041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T23:05:23.537643+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T22:05:00+00:00 PythonOperator 2021-03-23T23:05:05.846426+00:00 2021-03-23T23:05:08.531441+00:00 0:00:02.685015 11040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T23:05:03.418141+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T22:00:00+00:00 EmrJobFlowSensor 2021-03-23T23:01:09.312741+00:00 2021-03-23T23:10:12.043228+00:00 0:09:02.730487 11039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T23:01:07.060796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T23:00:47.344363+00:00 2021-03-23T23:00:49.190549+00:00 0:00:01.846186 11038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T23:00:45.089947+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T22:00:00+00:00 PythonOperator 2021-03-23T23:00:27.326243+00:00 2021-03-23T23:00:30.084617+00:00 0:00:02.758374 11037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T23:00:25.029311+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T21:00:00+00:00 EmrJobFlowSensor 2021-03-23T22:11:26.075466+00:00 2021-03-23T22:21:28.763410+00:00 0:10:02.687944 11035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T22:11:23.673425+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T21:00:00+00:00 EmrJobFlowSensor 2021-03-23T22:11:19.993119+00:00 2021-03-23T22:21:22.925201+00:00 0:10:02.932082 11034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T22:11:17.565020+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T22:11:05.991475+00:00 2021-03-23T22:11:07.838967+00:00 0:00:01.847492 11033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T22:11:03.562491+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T22:11:00.011152+00:00 2021-03-23T22:11:01.769574+00:00 0:00:01.758422 11032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T22:10:57.564889+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T21:00:00+00:00 PythonOperator 2021-03-23T22:10:43.682322+00:00 2021-03-23T22:10:46.721052+00:00 0:00:03.038730 11031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T22:10:41.427915+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T21:00:00+00:00 PythonOperator 2021-03-23T22:10:37.667546+00:00 2021-03-23T22:10:40.493815+00:00 0:00:02.826269 11030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T22:10:35.424280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T21:00:00+00:00 TriggerDagRunOperator 2021-03-23T22:10:17.931610+00:00 2021-03-23T22:10:18.478163+00:00 0:00:00.546553 11029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T22:10:15.467724+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T21:00:00+00:00 TriggerDagRunOperator 2021-03-23T22:10:17.876535+00:00 2021-03-23T22:10:18.399846+00:00 0:00:00.523311 11028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T22:10:15.467774+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T21:05:00+00:00 EmrJobFlowSensor 2021-03-23T22:06:07.228234+00:00 2021-03-23T22:15:09.782842+00:00 0:09:02.554608 11027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T22:06:04.989530+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T21:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T22:05:47.041139+00:00 2021-03-23T22:05:48.669443+00:00 0:00:01.628304 11026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T22:05:44.917791+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T21:05:00+00:00 PythonOperator 2021-03-23T22:05:25.257189+00:00 2021-03-23T22:05:27.933960+00:00 0:00:02.676771 11025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T22:05:22.969404+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T21:00:00+00:00 EmrJobFlowSensor 2021-03-23T22:00:58.931814+00:00 2021-03-23T22:10:01.515356+00:00 0:09:02.583542 11024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T22:00:56.560427+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T22:00:38.606066+00:00 2021-03-23T22:00:40.367945+00:00 0:00:01.761879 11023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T22:00:36.445132+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T21:00:00+00:00 PythonOperator 2021-03-23T22:00:16.866497+00:00 2021-03-23T22:00:19.700651+00:00 0:00:02.834154 11022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T22:00:14.425574+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T20:00:00+00:00 EmrJobFlowSensor 2021-03-23T21:11:11.256665+00:00 2021-03-23T21:21:13.983913+00:00 0:10:02.727248 11020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T21:11:08.961714+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T20:00:00+00:00 EmrJobFlowSensor 2021-03-23T21:10:50.974564+00:00 2021-03-23T21:19:53.762271+00:00 0:09:02.787707 11019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T21:10:48.795307+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T21:10:49.013851+00:00 2021-03-23T21:10:50.699161+00:00 0:00:01.685310 11018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T21:10:46.801813+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T21:10:31.435425+00:00 2021-03-23T21:10:33.192617+00:00 0:00:01.757192 11017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T21:10:28.787129+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T20:00:00+00:00 PythonOperator 2021-03-23T21:10:28.959245+00:00 2021-03-23T21:10:32.280979+00:00 0:00:03.321734 11016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T21:10:26.742669+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T20:00:00+00:00 PythonOperator 2021-03-23T21:10:09.289010+00:00 2021-03-23T21:10:12.037725+00:00 0:00:02.748715 11015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T21:10:06.690965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T20:00:00+00:00 TriggerDagRunOperator 2021-03-23T21:10:03.344890+00:00 2021-03-23T21:10:03.742949+00:00 0:00:00.398059 11014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T21:10:00.751486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T20:00:00+00:00 TriggerDagRunOperator 2021-03-23T21:10:03.370977+00:00 2021-03-23T21:10:03.875539+00:00 0:00:00.504562 11013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T21:10:00.751455+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T20:05:00+00:00 EmrJobFlowSensor 2021-03-23T21:05:54.390444+00:00 2021-03-23T21:14:56.934854+00:00 0:09:02.544410 11012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T21:05:52.217409+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T20:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T21:05:30.673013+00:00 2021-03-23T21:05:32.299827+00:00 0:00:01.626814 11011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T21:05:28.277540+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T20:05:00+00:00 PythonOperator 2021-03-23T21:05:08.303787+00:00 2021-03-23T21:05:11.065734+00:00 0:00:02.761947 11010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T21:05:06.130913+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T20:00:00+00:00 EmrJobFlowSensor 2021-03-23T21:00:56.010685+00:00 2021-03-23T21:09:58.581315+00:00 0:09:02.570630 11009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T21:00:53.802858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T21:00:36.097656+00:00 2021-03-23T21:00:37.891223+00:00 0:00:01.793567 11008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T21:00:33.788420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T20:00:00+00:00 PythonOperator 2021-03-23T21:00:12.216546+00:00 2021-03-23T21:00:14.954615+00:00 0:00:02.738069 11007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T21:00:09.844424+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T19:00:00+00:00 EmrJobFlowSensor 2021-03-23T20:12:53.024218+00:00 2021-03-23T20:21:55.578128+00:00 0:09:02.553910 11006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T20:12:50.878373+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T19:00:00+00:00 EmrJobFlowSensor 2021-03-23T20:12:45.430604+00:00 2021-03-23T20:21:48.182893+00:00 0:09:02.752289 11005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T20:12:42.871962+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T20:11:55.038152+00:00 2021-03-23T20:11:56.875440+00:00 0:00:01.837288 11003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T20:11:52.257763+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T20:11:54.693612+00:00 2021-03-23T20:11:56.416702+00:00 0:00:01.723090 11002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T20:11:52.257720+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T19:00:00+00:00 PythonOperator 2021-03-23T20:11:34.596936+00:00 2021-03-23T20:11:37.313034+00:00 0:00:02.716098 11001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T20:11:32.167789+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T19:00:00+00:00 PythonOperator 2021-03-23T20:11:32.395054+00:00 2021-03-23T20:11:35.449031+00:00 0:00:03.053977 11000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T20:11:30.163362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T19:00:00+00:00 TriggerDagRunOperator 2021-03-23T20:11:16.577085+00:00 2021-03-23T20:11:16.996140+00:00 0:00:00.419055 10999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T20:11:14.093030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T19:00:00+00:00 TriggerDagRunOperator 2021-03-23T20:11:16.465220+00:00 2021-03-23T20:11:16.996102+00:00 0:00:00.530882 10998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T20:11:14.093002+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T19:05:00+00:00 EmrJobFlowSensor 2021-03-23T20:06:03.693571+00:00 2021-03-23T20:15:06.279801+00:00 0:09:02.586230 10997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T20:06:01.574883+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T20:05:41.668101+00:00 2021-03-23T20:05:43.380504+00:00 0:00:01.712403 10996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T20:05:39.521528+00:00 2 default_pool