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-04-06T01:05:00+00:00 EmrJobFlowSensor 2021-04-06T02:06:12.440081+00:00 2021-04-06T02:15:15.045409+00:00 0:09:02.605328 14045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T02:06:10.251244+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T02:05:50.359191+00:00 2021-04-06T02:05:51.973431+00:00 0:00:01.614240 14044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T02:05:48.235471+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T01:05:00+00:00 PythonOperator 2021-04-06T02:05:20.495800+00:00 2021-04-06T02:05:23.221687+00:00 0:00:02.725887 14043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T02:05:18.208672+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T01:00:00+00:00 EmrJobFlowSensor 2021-04-06T02:01:10.418709+00:00 2021-04-06T02:09:13.082308+00:00 0:08:02.663599 14042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T02:01:07.866326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T02:00:38.049337+00:00 2021-04-06T02:00:39.883368+00:00 0:00:01.834031 14041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T02:00:35.792378+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T01:00:00+00:00 PythonOperator 2021-04-06T02:00:14.120896+00:00 2021-04-06T02:00:16.986289+00:00 0:00:02.865393 14040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T02:00:11.737190+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T00:00:00+00:00 EmrJobFlowSensor 2021-04-06T01:12:00.985485+00:00 2021-04-06T01:21:03.609982+00:00 0:09:02.624497 14038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:11:58.688147+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T00:00:00+00:00 EmrJobFlowSensor 2021-04-06T01:11:50.819821+00:00 2021-04-06T01:21:53.659846+00:00 0:10:02.840025 14037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:11:48.624613+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:11:32.813514+00:00 2021-04-06T01:11:34.483089+00:00 0:00:01.669575 14036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T01:11:30.612319+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:11:25.133210+00:00 2021-04-06T01:11:27.116569+00:00 0:00:01.983359 14035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T01:11:22.651581+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T00:00:00+00:00 PythonOperator 2021-04-06T01:11:11.158257+00:00 2021-04-06T01:11:13.875777+00:00 0:00:02.717520 14034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:11:08.591038+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T00:00:00+00:00 PythonOperator 2021-04-06T01:11:05.321552+00:00 2021-04-06T01:11:08.357442+00:00 0:00:03.035890 14033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:11:02.666977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T00:00:00+00:00 TriggerDagRunOperator 2021-04-06T01:10:59.220141+00:00 2021-04-06T01:10:59.783810+00:00 0:00:00.563669 14032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:10:56.655232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T00:00:00+00:00 TriggerDagRunOperator 2021-04-06T01:10:59.200403+00:00 2021-04-06T01:10:59.614693+00:00 0:00:00.414290 14031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:10:56.655196+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T00:05:00+00:00 EmrJobFlowSensor 2021-04-06T01:05:48.352573+00:00 2021-04-06T01:13:50.771972+00:00 0:08:02.419399 14030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:05:46.124683+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:05:26.577140+00:00 2021-04-06T01:05:28.303101+00:00 0:00:01.725961 14029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T01:05:24.180851+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T00:05:00+00:00 PythonOperator 2021-04-06T01:05:04.387458+00:00 2021-04-06T01:05:07.090347+00:00 0:00:02.702889 14028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:05:02.091073+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T00:00:00+00:00 EmrJobFlowSensor 2021-04-06T01:00:50.124547+00:00 2021-04-06T01:10:52.729938+00:00 0:10:02.605391 14027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:00:47.764012+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:00:30.081444+00:00 2021-04-06T01:00:31.772009+00:00 0:00:01.690565 14026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T01:00:27.747044+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T00:00:00+00:00 PythonOperator 2021-04-06T01:00:08.054677+00:00 2021-04-06T01:00:10.759299+00:00 0:00:02.704622 14025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T01:00:05.660682+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T23:00:00+00:00 EmrJobFlowSensor 2021-04-06T00:11:05.730854+00:00 2021-04-06T00:21:08.603759+00:00 0:10:02.872905 14023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:11:03.431926+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T23:00:00+00:00 EmrJobFlowSensor 2021-04-06T00:11:03.785521+00:00 2021-04-06T00:20:06.495887+00:00 0:09:02.710366 14022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:11:01.431390+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:10:45.758329+00:00 2021-04-06T00:10:47.517678+00:00 0:00:01.759349 14021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T00:10:43.417859+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:10:39.800229+00:00 2021-04-06T00:10:41.494376+00:00 0:00:01.694147 14020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T00:10:37.469046+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T23:00:00+00:00 PythonOperator 2021-04-06T00:10:23.890771+00:00 2021-04-06T00:10:26.961753+00:00 0:00:03.070982 14019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:10:21.458424+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T23:00:00+00:00 PythonOperator 2021-04-06T00:10:19.743728+00:00 2021-04-06T00:10:22.465752+00:00 0:00:02.722024 14018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:10:17.478669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T23:00:00+00:00 TriggerDagRunOperator 2021-04-06T00:10:03.913065+00:00 2021-04-06T00:10:04.364079+00:00 0:00:00.451014 14017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:10:01.350584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T23:00:00+00:00 TriggerDagRunOperator 2021-04-06T00:10:03.853089+00:00 2021-04-06T00:10:04.451012+00:00 0:00:00.597923 14016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:10:01.350554+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T23:05:00+00:00 EmrJobFlowSensor 2021-04-06T00:06:01.555951+00:00 2021-04-06T00:15:04.182030+00:00 0:09:02.626079 14015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:05:59.045151+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:05:39.111516+00:00 2021-04-06T00:05:40.741223+00:00 0:00:01.629707 14014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T00:05:36.863115+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T23:05:00+00:00 PythonOperator 2021-04-06T00:05:19.044049+00:00 2021-04-06T00:05:21.746590+00:00 0:00:02.702541 14013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:05:16.841748+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T23:00:00+00:00 EmrJobFlowSensor 2021-04-06T00:00:48.870508+00:00 2021-04-06T00:09:51.603278+00:00 0:09:02.732770 14012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:00:46.499067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:00:28.636567+00:00 2021-04-06T00:00:30.358823+00:00 0:00:01.722256 14011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T00:00:26.446844+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T23:00:00+00:00 PythonOperator 2021-04-06T00:00:06.957092+00:00 2021-04-06T00:00:09.746504+00:00 0:00:02.789412 14010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T00:00:04.477292+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T22:00:00+00:00 EmrJobFlowSensor 2021-04-05T23:12:16.934549+00:00 2021-04-05T23:22:19.857826+00:00 0:10:02.923277 14008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:12:14.134871+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T22:00:00+00:00 EmrJobFlowSensor 2021-04-05T23:12:14.812508+00:00 2021-04-05T23:22:17.807735+00:00 0:10:02.995227 14007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:12:12.130608+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:11:55.082872+00:00 2021-04-05T23:11:56.800367+00:00 0:00:01.717495 14006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T23:11:52.174775+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:11:52.735660+00:00 2021-04-05T23:11:54.716910+00:00 0:00:01.981250 14005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T23:11:50.171455+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T22:00:00+00:00 PythonOperator 2021-04-05T23:11:34.547420+00:00 2021-04-05T23:11:37.584493+00:00 0:00:03.037073 14004 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:11:32.144253+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T22:00:00+00:00 PythonOperator 2021-04-05T23:11:30.733179+00:00 2021-04-05T23:11:33.472408+00:00 0:00:02.739229 14003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:11:28.248173+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T22:00:00+00:00 TriggerDagRunOperator 2021-04-05T23:11:08.535717+00:00 2021-04-05T23:11:09.094062+00:00 0:00:00.558345 14002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:11:06.043829+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T22:00:00+00:00 TriggerDagRunOperator 2021-04-05T23:11:08.174725+00:00 2021-04-05T23:11:08.601651+00:00 0:00:00.426926 14001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:11:06.043794+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T22:05:00+00:00 EmrJobFlowSensor 2021-04-05T23:05:49.955510+00:00 2021-04-05T23:14:52.615913+00:00 0:09:02.660403 14000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:05:47.688847+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:05:27.974864+00:00 2021-04-05T23:05:29.579162+00:00 0:00:01.604298 13999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T23:05:25.672794+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T22:05:00+00:00 PythonOperator 2021-04-05T23:05:07.814972+00:00 2021-04-05T23:05:10.504564+00:00 0:00:02.689592 13998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:05:05.635035+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T22:00:00+00:00 EmrJobFlowSensor 2021-04-05T23:00:59.551816+00:00 2021-04-05T23:11:02.527576+00:00 0:10:02.975760 13997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:00:57.234619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:00:37.548732+00:00 2021-04-05T23:00:39.310008+00:00 0:00:01.761276 13996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T23:00:35.216566+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T22:00:00+00:00 PythonOperator 2021-04-05T23:00:18.037238+00:00 2021-04-05T23:00:20.824444+00:00 0:00:02.787206 13995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T23:00:15.198746+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T21:00:00+00:00 EmrJobFlowSensor 2021-04-05T22:11:58.189679+00:00 2021-04-05T22:21:01.027508+00:00 0:09:02.837829 13993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:55.826883+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T21:00:00+00:00 EmrJobFlowSensor 2021-04-05T22:11:54.280422+00:00 2021-04-05T22:20:57.115870+00:00 0:09:02.835448 13992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:51.823608+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:11:36.285008+00:00 2021-04-05T22:11:37.948732+00:00 0:00:01.663724 13991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T22:11:33.871050+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:11:32.287134+00:00 2021-04-05T22:11:34.066283+00:00 0:00:01.779149 13990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T22:11:29.856245+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T21:00:00+00:00 PythonOperator 2021-04-05T22:11:14.267120+00:00 2021-04-05T22:11:17.261492+00:00 0:00:02.994372 13989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:11:11.854257+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T21:00:00+00:00 PythonOperator 2021-04-05T22:11:10.401153+00:00 2021-04-05T22:11:13.233250+00:00 0:00:02.832097 13988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:11:07.846716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T21:00:00+00:00 TriggerDagRunOperator 2021-04-05T22:11:04.287584+00:00 2021-04-05T22:11:04.701435+00:00 0:00:00.413851 13987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:01.789365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T21:00:00+00:00 TriggerDagRunOperator 2021-04-05T22:11:04.260148+00:00 2021-04-05T22:11:04.827419+00:00 0:00:00.567271 13986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:01.789397+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T21:05:00+00:00 EmrJobFlowSensor 2021-04-05T22:06:03.646744+00:00 2021-04-05T22:15:06.299993+00:00 0:09:02.653249 13985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:06:01.284428+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:05:41.393359+00:00 2021-04-05T22:05:43.032426+00:00 0:00:01.639067 13984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T22:05:39.192303+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T21:05:00+00:00 PythonOperator 2021-04-05T22:05:19.588718+00:00 2021-04-05T22:05:22.391574+00:00 0:00:02.802856 13983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:05:17.144032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T21:00:00+00:00 EmrJobFlowSensor 2021-04-05T22:00:46.852529+00:00 2021-04-05T22:10:49.727257+00:00 0:10:02.874728 13982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:00:44.589928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:00:26.715661+00:00 2021-04-05T22:00:28.465412+00:00 0:00:01.749751 13981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T22:00:24.566237+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T21:00:00+00:00 PythonOperator 2021-04-05T22:00:05.096757+00:00 2021-04-05T22:00:07.976803+00:00 0:00:02.880046 13980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T22:00:02.549373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:12:13.894381+00:00 2021-04-05T21:22:16.651932+00:00 0:10:02.757551 13978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:12:11.642775+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:12:09.921104+00:00 2021-04-05T21:20:12.454623+00:00 0:08:02.533519 13977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:12:07.650806+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:11:51.932262+00:00 2021-04-05T21:11:53.725710+00:00 0:00:01.793448 13976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T21:11:49.626905+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:11:48.014154+00:00 2021-04-05T21:11:49.920804+00:00 0:00:01.906650 13975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T21:11:45.624491+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:11:30.393341+00:00 2021-04-05T21:11:33.376621+00:00 0:00:02.983280 13974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:11:27.748142+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:11:26.172653+00:00 2021-04-05T21:11:29.140944+00:00 0:00:02.968291 13973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:11:23.674470+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T20:00:00+00:00 TriggerDagRunOperator 2021-04-05T21:11:18.233904+00:00 2021-04-05T21:11:18.776973+00:00 0:00:00.543069 13972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:11:15.598674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T20:00:00+00:00 TriggerDagRunOperator 2021-04-05T21:11:17.907121+00:00 2021-04-05T21:11:18.336125+00:00 0:00:00.429004 13971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:11:15.598721+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T20:05:00+00:00 EmrJobFlowSensor 2021-04-05T21:06:01.494531+00:00 2021-04-05T21:15:04.171022+00:00 0:09:02.676491 13970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:05:59.167999+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:05:39.598994+00:00 2021-04-05T21:05:41.303180+00:00 0:00:01.704186 13969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T21:05:37.153549+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T20:05:00+00:00 PythonOperator 2021-04-05T21:05:19.548415+00:00 2021-04-05T21:05:22.288796+00:00 0:00:02.740381 13968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:05:17.149403+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:01:07.135290+00:00 2021-04-05T21:11:10.043234+00:00 0:10:02.907944 13967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:01:04.740837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:00:44.987431+00:00 2021-04-05T21:00:46.761780+00:00 0:00:01.774349 13966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T21:00:42.655616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:00:24.927404+00:00 2021-04-05T21:00:27.694804+00:00 0:00:02.767400 13965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T21:00:22.549956+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T19:00:00+00:00 EmrJobFlowSensor 2021-04-05T20:11:59.387146+00:00 2021-04-05T20:21:02.139979+00:00 0:09:02.752833 13963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:11:57.166326+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T19:00:00+00:00 EmrJobFlowSensor 2021-04-05T20:11:51.355666+00:00 2021-04-05T20:19:54.017763+00:00 0:08:02.662097 13962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:11:49.154218+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:11:37.383414+00:00 2021-04-05T20:11:39.097500+00:00 0:00:01.714086 13961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T20:11:35.143207+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:11:29.281886+00:00 2021-04-05T20:11:30.974101+00:00 0:00:01.692215 13960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T20:11:27.063033+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T19:00:00+00:00 PythonOperator 2021-04-05T20:11:17.314174+00:00 2021-04-05T20:11:20.417702+00:00 0:00:03.103528 13959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:11:15.055397+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T19:00:00+00:00 PythonOperator 2021-04-05T20:11:09.575444+00:00 2021-04-05T20:11:12.271493+00:00 0:00:02.696049 13958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:11:07.042987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T19:00:00+00:00 TriggerDagRunOperator 2021-04-05T20:10:57.349531+00:00 2021-04-05T20:10:57.900544+00:00 0:00:00.551013 13957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:10:55.040026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T19:00:00+00:00 TriggerDagRunOperator 2021-04-05T20:10:57.289060+00:00 2021-04-05T20:10:57.686340+00:00 0:00:00.397280 13956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:10:55.040063+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T19:05:00+00:00 EmrJobFlowSensor 2021-04-05T20:05:50.864866+00:00 2021-04-05T20:14:53.508293+00:00 0:09:02.643427 13955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:05:48.571938+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:05:28.776015+00:00 2021-04-05T20:05:30.404617+00:00 0:00:01.628602 13954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T20:05:26.485859+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T19:05:00+00:00 PythonOperator 2021-04-05T20:05:08.931906+00:00 2021-04-05T20:05:11.679049+00:00 0:00:02.747143 13953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:05:06.468081+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T19:00:00+00:00 EmrJobFlowSensor 2021-04-05T20:00:50.258773+00:00 2021-04-05T20:10:53.033973+00:00 0:10:02.775200 13952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:00:48.002910+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:00:28.509566+00:00 2021-04-05T20:00:30.202239+00:00 0:00:01.692673 13951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T20:00:26.055817+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T19:00:00+00:00 PythonOperator 2021-04-05T20:00:08.785981+00:00 2021-04-05T20:00:11.548716+00:00 0:00:02.762735 13950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T20:00:05.957785+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T18:00:00+00:00 EmrJobFlowSensor 2021-04-05T19:11:21.179184+00:00 2021-04-05T19:21:23.950267+00:00 0:10:02.771083 13948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:11:18.961821+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T18:00:00+00:00 EmrJobFlowSensor 2021-04-05T19:11:19.426148+00:00 2021-04-05T19:21:22.360874+00:00 0:10:02.934726 13947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:11:16.962265+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T19:11:01.589555+00:00 2021-04-05T19:11:03.318430+00:00 0:00:01.728875 13946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T19:10:59.047266+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T19:10:59.102486+00:00 2021-04-05T19:11:00.841006+00:00 0:00:01.738520 13945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T19:10:56.896558+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T18:00:00+00:00 PythonOperator 2021-04-05T19:10:38.972415+00:00 2021-04-05T19:10:41.660211+00:00 0:00:02.687796 13944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T19:10:36.812432+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T18:00:00+00:00 PythonOperator 2021-04-05T19:10:37.085200+00:00 2021-04-05T19:10:40.169659+00:00 0:00:03.084459 13943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T19:10:34.812050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T18:00:00+00:00 TriggerDagRunOperator 2021-04-05T19:10:17.415191+00:00 2021-04-05T19:10:17.966860+00:00 0:00:00.551669 13942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:10:14.860299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T18:00:00+00:00 TriggerDagRunOperator 2021-04-05T19:10:17.258713+00:00 2021-04-05T19:10:17.688555+00:00 0:00:00.429842 13941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:10:14.860348+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T18:05:00+00:00 EmrJobFlowSensor 2021-04-05T19:06:04.609336+00:00 2021-04-05T19:15:07.226477+00:00 0:09:02.617141 13940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:06:02.400049+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T19:05:40.676055+00:00 2021-04-05T19:05:42.390383+00:00 0:00:01.714328 13939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T19:05:38.382458+00:00 2 default_pool