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 trigger_dagrun_booking-processing-job_v002 2021-04-17T03:00:00+00:00 TriggerDagRunOperator 2021-04-17T04:10:46.379265+00:00 2021-04-17T04:10:46.893144+00:00 0:00:00.513879 18060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:10:43.992123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T03:00:00+00:00 TriggerDagRunOperator 2021-04-17T04:10:46.180663+00:00 2021-04-17T04:10:46.590625+00:00 0:00:00.409962 18059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:10:43.992093+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T03:05:00+00:00 EmrJobFlowSensor 2021-04-17T04:06:01.967656+00:00 2021-04-17T04:15:04.714296+00:00 0:09:02.746640 18058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:05:59.648932+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T04:05:39.747979+00:00 2021-04-17T04:05:41.466515+00:00 0:00:01.718536 18057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T04:05:37.554594+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T03:05:00+00:00 PythonOperator 2021-04-17T04:05:19.870477+00:00 2021-04-17T04:05:22.953845+00:00 0:00:03.083368 18056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T04:05:17.538916+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T03:00:00+00:00 EmrJobFlowSensor 2021-04-17T04:00:59.408309+00:00 2021-04-17T04:10:02.131409+00:00 0:09:02.723100 18055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T04:00:57.204879+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T04:00:39.370412+00:00 2021-04-17T04:00:41.075990+00:00 0:00:01.705578 18054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T04:00:37.186459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T03:00:00+00:00 PythonOperator 2021-04-17T04:00:13.544242+00:00 2021-04-17T04:00:16.584886+00:00 0:00:03.040644 18053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T04:00:11.084329+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T02:00:00+00:00 EmrJobFlowSensor 2021-04-17T03:10:23.189512+00:00 2021-04-17T03:20:25.793523+00:00 0:10:02.604011 18051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:10:21.013621+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T02:00:00+00:00 EmrJobFlowSensor 2021-04-17T03:10:11.458306+00:00 2021-04-17T03:19:14.159200+00:00 0:09:02.700894 18050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:10:09.057333+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:10:01.411754+00:00 2021-04-17T03:10:03.188797+00:00 0:00:01.777043 18049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T03:09:59.063720+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:09:51.505340+00:00 2021-04-17T03:09:53.314742+00:00 0:00:01.809402 18048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T03:09:49.052146+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T02:00:00+00:00 PythonOperator 2021-04-17T03:09:39.091214+00:00 2021-04-17T03:09:42.171607+00:00 0:00:03.080393 18047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:09:36.929340+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T02:00:00+00:00 PythonOperator 2021-04-17T03:09:29.305384+00:00 2021-04-17T03:09:32.227964+00:00 0:00:02.922580 18046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:09:26.923142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T02:00:00+00:00 TriggerDagRunOperator 2021-04-17T03:09:19.474683+00:00 2021-04-17T03:09:20.055520+00:00 0:00:00.580837 18045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:09:16.914819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T02:00:00+00:00 TriggerDagRunOperator 2021-04-17T03:09:19.362304+00:00 2021-04-17T03:09:19.784620+00:00 0:00:00.422316 18044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:09:16.914856+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T02:05:00+00:00 EmrJobFlowSensor 2021-04-17T03:06:09.587440+00:00 2021-04-17T03:15:12.184922+00:00 0:09:02.597482 18043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:06:07.175898+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:05:47.237752+00:00 2021-04-17T03:05:48.942411+00:00 0:00:01.704659 18042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T03:05:45.090761+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T02:05:00+00:00 PythonOperator 2021-04-17T03:05:23.177876+00:00 2021-04-17T03:05:26.262606+00:00 0:00:03.084730 18041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:05:21.047872+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T02:00:00+00:00 EmrJobFlowSensor 2021-04-17T03:01:09.660955+00:00 2021-04-17T03:09:12.131203+00:00 0:08:02.470248 18040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:01:06.615207+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:00:44.732258+00:00 2021-04-17T03:00:46.541628+00:00 0:00:01.809370 18039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T03:00:42.591357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T02:00:00+00:00 PythonOperator 2021-04-17T03:00:23.158739+00:00 2021-04-17T03:00:26.048437+00:00 0:00:02.889698 18038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T03:00:20.583776+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T01:00:00+00:00 EmrJobFlowSensor 2021-04-17T02:12:29.340359+00:00 2021-04-17T02:21:31.982742+00:00 0:09:02.642383 18036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:12:27.109150+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T01:00:00+00:00 EmrJobFlowSensor 2021-04-17T02:12:27.839416+00:00 2021-04-17T02:21:30.563877+00:00 0:09:02.724461 18035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:12:25.101930+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:12:07.570538+00:00 2021-04-17T02:12:09.384022+00:00 0:00:01.813484 18034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T02:12:05.153242+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:12:03.587421+00:00 2021-04-17T02:12:05.851196+00:00 0:00:02.263775 18033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T02:12:01.159915+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T01:00:00+00:00 PythonOperator 2021-04-17T02:11:45.891088+00:00 2021-04-17T02:11:48.967553+00:00 0:00:03.076465 18032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:11:43.075152+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T01:00:00+00:00 PythonOperator 2021-04-17T02:11:41.325895+00:00 2021-04-17T02:11:44.666928+00:00 0:00:03.341033 18031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:11:39.066042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T01:00:00+00:00 TriggerDagRunOperator 2021-04-17T02:11:19.469474+00:00 2021-04-17T02:11:19.989096+00:00 0:00:00.519622 18030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:11:17.004247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T01:00:00+00:00 TriggerDagRunOperator 2021-04-17T02:11:19.213969+00:00 2021-04-17T02:11:19.626006+00:00 0:00:00.412037 18029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:11:17.004280+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T01:05:00+00:00 EmrJobFlowSensor 2021-04-17T02:06:04.886250+00:00 2021-04-17T02:15:07.757761+00:00 0:09:02.871511 18028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:06:02.521646+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:05:42.702420+00:00 2021-04-17T02:05:44.341930+00:00 0:00:01.639510 18027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T02:05:40.500668+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T01:05:00+00:00 PythonOperator 2021-04-17T02:05:20.742586+00:00 2021-04-17T02:05:23.667894+00:00 0:00:02.925308 18026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:05:18.446144+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T01:00:00+00:00 EmrJobFlowSensor 2021-04-17T02:01:06.316656+00:00 2021-04-17T02:11:09.251917+00:00 0:10:02.935261 18025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:01:03.970301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:00:46.143793+00:00 2021-04-17T02:00:47.958733+00:00 0:00:01.814940 18024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T02:00:43.896283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T01:00:00+00:00 PythonOperator 2021-04-17T02:00:24.318562+00:00 2021-04-17T02:00:27.472801+00:00 0:00:03.154239 18023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T02:00:21.947599+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:12:08.773799+00:00 2021-04-17T01:21:11.471716+00:00 0:09:02.697917 18021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:12:06.245667+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:12:06.474086+00:00 2021-04-17T01:22:09.121743+00:00 0:10:02.647657 18020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:12:04.271177+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:11:46.470839+00:00 2021-04-17T01:11:48.284660+00:00 0:00:01.813821 18019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:11:44.197949+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:11:46.389276+00:00 2021-04-17T01:11:48.075380+00:00 0:00:01.686104 18018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:11:44.197975+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:11:26.456425+00:00 2021-04-17T01:11:29.628377+00:00 0:00:03.171952 18017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:11:24.164982+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:11:24.514238+00:00 2021-04-17T01:11:27.429718+00:00 0:00:02.915480 18016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:11:22.163157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T00:00:00+00:00 TriggerDagRunOperator 2021-04-17T01:11:07.174848+00:00 2021-04-17T01:11:07.764511+00:00 0:00:00.589663 18015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:11:04.263350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T00:00:00+00:00 TriggerDagRunOperator 2021-04-17T01:11:06.686716+00:00 2021-04-17T01:11:07.095997+00:00 0:00:00.409281 18014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:11:04.263308+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T00:05:00+00:00 EmrJobFlowSensor 2021-04-17T01:05:57.704836+00:00 2021-04-17T01:15:00.303047+00:00 0:09:02.598211 18013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:05:55.567487+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:05:35.800031+00:00 2021-04-17T01:05:37.892268+00:00 0:00:02.092237 18012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:05:33.547898+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T00:05:00+00:00 PythonOperator 2021-04-17T01:05:13.781296+00:00 2021-04-17T01:05:16.741910+00:00 0:00:02.960614 18011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:05:11.530935+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:00:53.306866+00:00 2021-04-17T01:10:56.213570+00:00 0:10:02.906704 18010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:00:51.062426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:00:33.812782+00:00 2021-04-17T01:00:35.582141+00:00 0:00:01.769359 18009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T01:00:31.022968+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:00:10.185269+00:00 2021-04-17T01:00:13.135840+00:00 0:00:02.950571 18008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T01:00:07.064704+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:11:16.099797+00:00 2021-04-17T00:20:18.854816+00:00 0:09:02.755019 18006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:11:13.321607+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:11:13.843688+00:00 2021-04-17T00:21:17.150507+00:00 0:10:03.306819 18005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:11:11.338236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:10:53.477335+00:00 2021-04-17T00:10:55.194031+00:00 0:00:01.716696 18004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:10:51.287544+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:10:51.650109+00:00 2021-04-17T00:10:53.436341+00:00 0:00:01.786232 18003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:10:49.352051+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:10:34.087761+00:00 2021-04-17T00:10:37.012027+00:00 0:00:02.924266 18002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:10:31.232564+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:10:31.562017+00:00 2021-04-17T00:10:35.332555+00:00 0:00:03.770538 18001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:10:29.269427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T23:00:00+00:00 TriggerDagRunOperator 2021-04-17T00:10:17.919690+00:00 2021-04-17T00:10:18.333895+00:00 0:00:00.414205 18000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:10:15.223944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T23:00:00+00:00 TriggerDagRunOperator 2021-04-17T00:10:17.921573+00:00 2021-04-17T00:10:18.493554+00:00 0:00:00.571981 17999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:10:15.223994+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T23:05:00+00:00 EmrJobFlowSensor 2021-04-17T00:06:06.992414+00:00 2021-04-17T00:15:09.782878+00:00 0:09:02.790464 17998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:06:04.814879+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:05:37.007103+00:00 2021-04-17T00:05:38.759101+00:00 0:00:01.751998 17997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:05:34.787677+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T23:05:00+00:00 PythonOperator 2021-04-17T00:05:09.569659+00:00 2021-04-17T00:05:12.486142+00:00 0:00:02.916483 17996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:05:06.691150+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:01:06.497787+00:00 2021-04-17T00:10:09.198966+00:00 0:09:02.701179 17995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:01:04.342935+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:00:42.815077+00:00 2021-04-17T00:00:44.596200+00:00 0:00:01.781123 17994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T00:00:40.320549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:00:22.899299+00:00 2021-04-17T00:00:26.070296+00:00 0:00:03.170997 17993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T00:00:20.307451+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:12:24.835329+00:00 2021-04-16T23:22:27.749601+00:00 0:10:02.914272 17991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:12:22.507209+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:12:16.671029+00:00 2021-04-16T23:21:19.239071+00:00 0:09:02.568042 17990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:12:14.494999+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:12:02.971117+00:00 2021-04-16T23:12:04.811718+00:00 0:00:01.840601 17989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:12:00.543433+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:11:54.902662+00:00 2021-04-16T23:11:57.161442+00:00 0:00:02.258780 17988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:11:52.544163+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:11:36.568765+00:00 2021-04-16T23:11:40.183061+00:00 0:00:03.614296 17987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:11:34.412246+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:11:22.875491+00:00 2021-04-16T23:11:26.693556+00:00 0:00:03.818065 17986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:11:20.399142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T22:00:00+00:00 TriggerDagRunOperator 2021-04-16T23:11:14.863920+00:00 2021-04-16T23:11:15.404395+00:00 0:00:00.540475 17985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:11:12.397547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T22:00:00+00:00 TriggerDagRunOperator 2021-04-16T23:11:14.642413+00:00 2021-04-16T23:11:15.079326+00:00 0:00:00.436913 17984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:11:12.397492+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T22:05:00+00:00 EmrJobFlowSensor 2021-04-16T23:05:47.892119+00:00 2021-04-16T23:14:50.507205+00:00 0:09:02.615086 17983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:05:45.789363+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:05:26.168154+00:00 2021-04-16T23:05:27.786628+00:00 0:00:01.618474 17982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:05:23.853330+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T22:05:00+00:00 PythonOperator 2021-04-16T23:05:06.057774+00:00 2021-04-16T23:05:09.093214+00:00 0:00:03.035440 17981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:05:03.696714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:00:51.518757+00:00 2021-04-16T23:10:54.213462+00:00 0:10:02.694705 17980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:00:49.322403+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:00:29.934696+00:00 2021-04-16T23:00:31.745517+00:00 0:00:01.810821 17979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T23:00:27.374361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:00:10.108217+00:00 2021-04-16T23:00:13.153618+00:00 0:00:03.045401 17978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T23:00:07.347534+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T21:00:00+00:00 EmrJobFlowSensor 2021-04-16T22:10:26.033394+00:00 2021-04-16T22:19:29.064317+00:00 0:09:03.030923 17976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:10:23.640811+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T21:00:00+00:00 EmrJobFlowSensor 2021-04-16T22:10:09.730517+00:00 2021-04-16T22:18:12.266853+00:00 0:08:02.536336 17975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:10:07.506002+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:10:03.820217+00:00 2021-04-16T22:10:05.550268+00:00 0:00:01.730051 17974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T22:10:01.567064+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:09:47.607013+00:00 2021-04-16T22:09:49.266004+00:00 0:00:01.658991 17973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T22:09:45.461795+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T21:00:00+00:00 PythonOperator 2021-04-16T22:09:41.666039+00:00 2021-04-16T22:09:45.428034+00:00 0:00:03.761995 17972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:09:39.437677+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T21:00:00+00:00 PythonOperator 2021-04-16T22:09:27.815943+00:00 2021-04-16T22:09:30.824698+00:00 0:00:03.008755 17971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:09:25.422195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T21:00:00+00:00 TriggerDagRunOperator 2021-04-16T22:09:20.226587+00:00 2021-04-16T22:09:20.775518+00:00 0:00:00.548931 17970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:09:17.551745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T21:00:00+00:00 TriggerDagRunOperator 2021-04-16T22:09:19.941541+00:00 2021-04-16T22:09:20.357993+00:00 0:00:00.416452 17969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:09:17.551708+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T21:05:00+00:00 EmrJobFlowSensor 2021-04-16T22:05:49.401317+00:00 2021-04-16T22:14:52.053600+00:00 0:09:02.652283 17968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:05:46.951461+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:05:27.295756+00:00 2021-04-16T22:05:29.016635+00:00 0:00:01.720879 17967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T22:05:24.953316+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T21:05:00+00:00 PythonOperator 2021-04-16T22:05:06.981648+00:00 2021-04-16T22:05:09.835754+00:00 0:00:02.854106 17966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:05:04.777255+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T21:00:00+00:00 EmrJobFlowSensor 2021-04-16T22:00:58.486177+00:00 2021-04-16T22:09:01.112145+00:00 0:08:02.625968 17965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:00:56.205098+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:00:36.311434+00:00 2021-04-16T22:00:38.041643+00:00 0:00:01.730209 17964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T22:00:34.185893+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T21:00:00+00:00 PythonOperator 2021-04-16T22:00:16.461096+00:00 2021-04-16T22:00:19.370508+00:00 0:00:02.909412 17963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T22:00:14.109327+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T20:00:00+00:00 EmrJobFlowSensor 2021-04-16T21:22:13.911058+00:00 2021-04-16T21:22:15.419023+00:00 0:00:01.507965 17961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:22:11.646484+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T20:00:00+00:00 EmrJobFlowSensor 2021-04-16T21:10:20.938928+00:00 2021-04-16T21:19:23.607838+00:00 0:09:02.668910 17959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:10:18.547884+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:10:02.608355+00:00 2021-04-16T21:10:04.321789+00:00 0:00:01.713434 17958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T21:10:00.391134+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:09:58.687306+00:00 2021-04-16T21:10:00.402976+00:00 0:00:01.715670 17957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T21:09:56.389787+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T20:00:00+00:00 PythonOperator 2021-04-16T21:09:40.895819+00:00 2021-04-16T21:09:44.087606+00:00 0:00:03.191787 17956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:09:38.330889+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T20:00:00+00:00 PythonOperator 2021-04-16T21:09:38.615315+00:00 2021-04-16T21:09:41.576861+00:00 0:00:02.961546 17955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:09:36.328515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T20:00:00+00:00 TriggerDagRunOperator 2021-04-16T21:09:30.825033+00:00 2021-04-16T21:09:31.355985+00:00 0:00:00.530952 17954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:09:27.967631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T20:00:00+00:00 TriggerDagRunOperator 2021-04-16T21:09:30.716780+00:00 2021-04-16T21:09:31.171815+00:00 0:00:00.455035 17953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:09:27.967677+00:00 2 default_pool