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-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:10:50.510943+00:00 2021-04-16T14:10:52.297011+00:00 0:00:01.786068 17851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T14:10:47.927205+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:10:36.585602+00:00 2021-04-16T14:10:39.994597+00:00 0:00:03.408995 17850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:10:33.915492+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:10:30.520722+00:00 2021-04-16T14:10:33.434336+00:00 0:00:02.913614 17849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:10:27.963529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T13:00:00+00:00 TriggerDagRunOperator 2021-04-16T14:10:24.270586+00:00 2021-04-16T14:10:24.718593+00:00 0:00:00.448007 17848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:10:21.907563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T13:00:00+00:00 TriggerDagRunOperator 2021-04-16T14:10:24.207679+00:00 2021-04-16T14:10:24.793360+00:00 0:00:00.585681 17847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:10:21.907534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T13:05:00+00:00 EmrJobFlowSensor 2021-04-16T14:05:59.992143+00:00 2021-04-16T14:15:02.759587+00:00 0:09:02.767444 17846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:05:57.285360+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:05:39.559980+00:00 2021-04-16T14:05:41.214531+00:00 0:00:01.654551 17845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T14:05:37.266448+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T13:05:00+00:00 PythonOperator 2021-04-16T14:05:13.513217+00:00 2021-04-16T14:05:16.400919+00:00 0:00:02.887702 17844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:05:11.243322+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T13:00:00+00:00 EmrJobFlowSensor 2021-04-16T14:00:57.633599+00:00 2021-04-16T14:10:00.160289+00:00 0:09:02.526690 17843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:00:54.925540+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:00:35.247585+00:00 2021-04-16T14:00:37.076962+00:00 0:00:01.829377 17842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T14:00:32.906194+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:00:13.230783+00:00 2021-04-16T14:00:16.719074+00:00 0:00:03.488291 17841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T14:00:10.891633+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T12:00:00+00:00 EmrJobFlowSensor 2021-04-16T13:12:20.689071+00:00 2021-04-16T13:21:23.328685+00:00 0:09:02.639614 17839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:12:18.499765+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T12:00:00+00:00 EmrJobFlowSensor 2021-04-16T13:12:18.853768+00:00 2021-04-16T13:20:21.456390+00:00 0:08:02.602622 17838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:12:16.509296+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:11:59.270000+00:00 2021-04-16T13:12:00.957997+00:00 0:00:01.687997 17837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T13:11:56.484580+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:11:58.777207+00:00 2021-04-16T13:12:00.850954+00:00 0:00:02.073747 17836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T13:11:56.484609+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T12:00:00+00:00 PythonOperator 2021-04-16T13:11:38.590713+00:00 2021-04-16T13:11:41.711134+00:00 0:00:03.120421 17835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:11:36.393239+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T12:00:00+00:00 PythonOperator 2021-04-16T13:11:36.665486+00:00 2021-04-16T13:11:39.827838+00:00 0:00:03.162352 17834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:11:34.390385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T12:00:00+00:00 TriggerDagRunOperator 2021-04-16T13:11:14.715883+00:00 2021-04-16T13:11:15.239509+00:00 0:00:00.523626 17833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:11:12.334071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T12:00:00+00:00 TriggerDagRunOperator 2021-04-16T13:11:14.507208+00:00 2021-04-16T13:11:14.922780+00:00 0:00:00.415572 17832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:11:12.334104+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T12:05:00+00:00 EmrJobFlowSensor 2021-04-16T13:05:58.075295+00:00 2021-04-16T13:15:00.537231+00:00 0:09:02.461936 17831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T13:05:55.901867+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:05:32.719587+00:00 2021-04-16T13:05:34.464701+00:00 0:00:01.745114 17830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T13:05:29.883004+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T12:05:00+00:00 PythonOperator 2021-04-16T13:05:10.207712+00:00 2021-04-16T13:05:13.087500+00:00 0:00:02.879788 17829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:05:07.863867+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T12:00:00+00:00 EmrJobFlowSensor 2021-04-16T13:00:55.613299+00:00 2021-04-16T13:10:58.362129+00:00 0:10:02.748830 17828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T13:00:53.446326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T13:00:35.597091+00:00 2021-04-16T13:00:37.558766+00:00 0:00:01.961675 17827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T13:00:33.432263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T12:00:00+00:00 PythonOperator 2021-04-16T13:00:14.490497+00:00 2021-04-16T13:00:17.412732+00:00 0:00:02.922235 17826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T13:00:11.540884+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T11:00:00+00:00 EmrJobFlowSensor 2021-04-16T12:12:26.497168+00:00 2021-04-16T12:21:29.050502+00:00 0:09:02.553334 17824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:12:24.178348+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T11:00:00+00:00 EmrJobFlowSensor 2021-04-16T12:12:16.281445+00:00 2021-04-16T12:22:19.146550+00:00 0:10:02.865105 17823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:12:14.110849+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T12:12:04.448821+00:00 2021-04-16T12:12:06.478819+00:00 0:00:02.029998 17822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T12:12:01.771408+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T12:11:54.035628+00:00 2021-04-16T12:11:55.804787+00:00 0:00:01.769159 17821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T12:11:51.692233+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T11:00:00+00:00 PythonOperator 2021-04-16T12:11:42.662799+00:00 2021-04-16T12:11:45.790120+00:00 0:00:03.127321 17820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T12:11:39.687770+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T11:00:00+00:00 PythonOperator 2021-04-16T12:11:34.046259+00:00 2021-04-16T12:11:36.983227+00:00 0:00:02.936968 17819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T12:11:31.631823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T11:00:00+00:00 TriggerDagRunOperator 2021-04-16T12:11:23.946296+00:00 2021-04-16T12:11:24.470300+00:00 0:00:00.524004 17818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:11:21.621361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T11:00:00+00:00 TriggerDagRunOperator 2021-04-16T12:11:23.793789+00:00 2021-04-16T12:11:24.209842+00:00 0:00:00.416053 17817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:11:21.621390+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T11:05:00+00:00 EmrJobFlowSensor 2021-04-16T12:05:51.266213+00:00 2021-04-16T12:14:53.953090+00:00 0:09:02.686877 17816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T12:05:49.128058+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T12:05:29.279284+00:00 2021-04-16T12:05:31.220913+00:00 0:00:01.941629 17815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T12:05:27.109706+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T11:05:00+00:00 PythonOperator 2021-04-16T12:05:07.194452+00:00 2021-04-16T12:05:10.045995+00:00 0:00:02.851543 17814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T12:05:05.097736+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T11:00:00+00:00 EmrJobFlowSensor 2021-04-16T12:01:04.783376+00:00 2021-04-16T12:11:08.180879+00:00 0:10:03.397503 17813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T12:01:02.476392+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T12:00:42.589650+00:00 2021-04-16T12:00:44.276108+00:00 0:00:01.686458 17812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T12:00:40.456793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T11:00:00+00:00 PythonOperator 2021-04-16T12:00:22.882887+00:00 2021-04-16T12:00:26.383636+00:00 0:00:03.500749 17811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T12:00:20.444042+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T10:00:00+00:00 EmrJobFlowSensor 2021-04-16T11:11:29.796299+00:00 2021-04-16T11:19:32.339912+00:00 0:08:02.543613 17809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T11:11:27.264716+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T10:00:00+00:00 EmrJobFlowSensor 2021-04-16T11:11:25.692345+00:00 2021-04-16T11:21:28.526966+00:00 0:10:02.834621 17808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T11:11:23.267001+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T11:11:09.514555+00:00 2021-04-16T11:11:11.208924+00:00 0:00:01.694369 17807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T11:11:07.187464+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T11:11:05.728515+00:00 2021-04-16T11:11:07.543772+00:00 0:00:01.815257 17806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T11:11:03.190074+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T10:00:00+00:00 PythonOperator 2021-04-16T11:10:47.436671+00:00 2021-04-16T11:10:50.351554+00:00 0:00:02.914883 17805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T11:10:45.143689+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T10:00:00+00:00 PythonOperator 2021-04-16T11:10:43.275527+00:00 2021-04-16T11:10:46.639932+00:00 0:00:03.364405 17804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T11:10:41.113581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T10:00:00+00:00 TriggerDagRunOperator 2021-04-16T11:10:25.666456+00:00 2021-04-16T11:10:26.171866+00:00 0:00:00.505410 17803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T11:10:23.099029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T10:00:00+00:00 TriggerDagRunOperator 2021-04-16T11:10:25.439031+00:00 2021-04-16T11:10:25.865124+00:00 0:00:00.426093 17802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T11:10:23.098998+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T10:05:00+00:00 EmrJobFlowSensor 2021-04-16T11:05:48.855012+00:00 2021-04-16T11:14:51.572208+00:00 0:09:02.717196 17801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T11:05:46.610632+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T11:05:26.811800+00:00 2021-04-16T11:05:28.525957+00:00 0:00:01.714157 17800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T11:05:24.595429+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T10:05:00+00:00 PythonOperator 2021-04-16T11:05:04.857365+00:00 2021-04-16T11:05:07.802031+00:00 0:00:02.944666 17799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T11:05:02.514988+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T10:00:00+00:00 EmrJobFlowSensor 2021-04-16T11:00:58.310063+00:00 2021-04-16T11:10:01.119405+00:00 0:09:02.809342 17798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T11:00:56.006247+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T11:00:28.384517+00:00 2021-04-16T11:00:30.121106+00:00 0:00:01.736589 17797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T11:00:26.040720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T10:00:00+00:00 PythonOperator 2021-04-16T11:00:08.925075+00:00 2021-04-16T11:00:11.884565+00:00 0:00:02.959490 17796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T11:00:05.854508+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T09:00:00+00:00 EmrJobFlowSensor 2021-04-16T10:12:16.667415+00:00 2021-04-16T10:22:19.418545+00:00 0:10:02.751130 17794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T10:12:14.283135+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T09:00:00+00:00 EmrJobFlowSensor 2021-04-16T10:12:08.407596+00:00 2021-04-16T10:21:11.041582+00:00 0:09:02.633986 17793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T10:12:06.254425+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T10:11:54.544751+00:00 2021-04-16T10:11:56.232818+00:00 0:00:01.688067 17792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T10:11:52.240995+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T10:11:46.758885+00:00 2021-04-16T10:11:48.416579+00:00 0:00:01.657694 17791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T10:11:44.234130+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T09:00:00+00:00 PythonOperator 2021-04-16T10:11:34.533128+00:00 2021-04-16T10:11:37.743412+00:00 0:00:03.210284 17790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T10:11:32.224886+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T09:00:00+00:00 PythonOperator 2021-04-16T10:11:24.671602+00:00 2021-04-16T10:11:27.559283+00:00 0:00:02.887681 17789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T10:11:22.259933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T09:00:00+00:00 TriggerDagRunOperator 2021-04-16T10:11:08.898944+00:00 2021-04-16T10:11:09.431931+00:00 0:00:00.532987 17788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T10:11:06.258999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T09:00:00+00:00 TriggerDagRunOperator 2021-04-16T10:11:08.787331+00:00 2021-04-16T10:11:09.241179+00:00 0:00:00.453848 17787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T10:11:06.259053+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T09:05:00+00:00 EmrJobFlowSensor 2021-04-16T10:05:49.969284+00:00 2021-04-16T10:14:52.422714+00:00 0:09:02.453430 17786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T10:05:47.718105+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T10:05:27.978588+00:00 2021-04-16T10:05:29.616523+00:00 0:00:01.637935 17785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T10:05:25.711728+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T09:05:00+00:00 PythonOperator 2021-04-16T10:05:06.277379+00:00 2021-04-16T10:05:09.213106+00:00 0:00:02.935727 17784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T10:05:03.686786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T09:00:00+00:00 EmrJobFlowSensor 2021-04-16T10:00:57.558462+00:00 2021-04-16T10:11:00.304362+00:00 0:10:02.745900 17783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T10:00:55.411483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T10:00:35.720092+00:00 2021-04-16T10:00:37.586482+00:00 0:00:01.866390 17782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T10:00:33.396085+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T09:00:00+00:00 PythonOperator 2021-04-16T10:00:16.217105+00:00 2021-04-16T10:00:19.827939+00:00 0:00:03.610834 17781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T10:00:13.371996+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T08:00:00+00:00 EmrJobFlowSensor 2021-04-16T09:18:03.471454+00:00 2021-04-16T09:27:06.083496+00:00 0:09:02.612042 17780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:18:01.248460+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T08:00:00+00:00 EmrJobFlowSensor 2021-04-16T09:18:01.407169+00:00 2021-04-16T09:28:04.397564+00:00 0:10:02.990395 17779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:17:59.168019+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:17:39.388065+00:00 2021-04-16T09:17:41.169973+00:00 0:00:01.781908 17778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T09:17:37.088636+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:17:37.685454+00:00 2021-04-16T09:17:39.414000+00:00 0:00:01.728546 17777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T09:17:35.165798+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T08:00:00+00:00 PythonOperator 2021-04-16T09:17:19.338796+00:00 2021-04-16T09:17:22.271420+00:00 0:00:02.932624 17776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:17:17.019002+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T08:00:00+00:00 PythonOperator 2021-04-16T09:17:17.095306+00:00 2021-04-16T09:17:20.402591+00:00 0:00:03.307285 17775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:17:14.936060+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T08:00:00+00:00 TriggerDagRunOperator 2021-04-16T09:16:53.771098+00:00 2021-04-16T09:16:54.265723+00:00 0:00:00.494625 17774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:16:50.752767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T08:00:00+00:00 TriggerDagRunOperator 2021-04-16T09:16:53.533591+00:00 2021-04-16T09:16:53.957447+00:00 0:00:00.423856 17773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:16:50.752810+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T08:05:00+00:00 EmrJobFlowSensor 2021-04-16T09:06:03.765768+00:00 2021-04-16T09:15:06.345124+00:00 0:09:02.579356 17771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:06:01.545347+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:05:41.804447+00:00 2021-04-16T09:05:43.454700+00:00 0:00:01.650253 17770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T09:05:39.551226+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T08:05:00+00:00 PythonOperator 2021-04-16T09:05:19.857587+00:00 2021-04-16T09:05:22.964498+00:00 0:00:03.106911 17769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:05:17.452912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T08:00:00+00:00 EmrJobFlowSensor 2021-04-16T09:00:55.214694+00:00 2021-04-16T09:10:58.582057+00:00 0:10:03.367363 17768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:00:53.002200+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:00:33.266272+00:00 2021-04-16T09:00:35.106705+00:00 0:00:01.840433 17767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T09:00:30.983853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T08:00:00+00:00 PythonOperator 2021-04-16T09:00:11.798761+00:00 2021-04-16T09:00:14.716389+00:00 0:00:02.917628 17766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T09:00:08.918272+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T07:00:00+00:00 EmrJobFlowSensor 2021-04-16T08:12:02.336916+00:00 2021-04-16T08:22:05.291321+00:00 0:10:02.954405 17765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:11:59.997618+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T07:00:00+00:00 EmrJobFlowSensor 2021-04-16T08:12:00.927083+00:00 2021-04-16T08:21:03.499492+00:00 0:09:02.572409 17764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:11:58.000706+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:11:40.562822+00:00 2021-04-16T08:11:42.253730+00:00 0:00:01.690908 17763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T08:11:37.987420+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:11:38.108542+00:00 2021-04-16T08:11:40.125124+00:00 0:00:02.016582 17762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T08:11:35.931195+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T07:00:00+00:00 PythonOperator 2021-04-16T08:11:20.108683+00:00 2021-04-16T08:11:23.751224+00:00 0:00:03.642541 17761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:11:17.916504+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T07:00:00+00:00 PythonOperator 2021-04-16T08:11:18.261870+00:00 2021-04-16T08:11:21.238491+00:00 0:00:02.976621 17760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:11:15.916395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T07:00:00+00:00 TriggerDagRunOperator 2021-04-16T08:10:58.727914+00:00 2021-04-16T08:10:59.223895+00:00 0:00:00.495981 17759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:10:55.901903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T07:00:00+00:00 TriggerDagRunOperator 2021-04-16T08:10:58.474251+00:00 2021-04-16T08:10:58.917755+00:00 0:00:00.443504 17758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:10:55.901932+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T07:05:00+00:00 EmrJobFlowSensor 2021-04-16T08:06:05.469862+00:00 2021-04-16T08:15:08.128674+00:00 0:09:02.658812 17756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:06:03.284320+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:05:43.465209+00:00 2021-04-16T08:05:45.568472+00:00 0:00:02.103263 17755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T08:05:41.240819+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T07:05:00+00:00 PythonOperator 2021-04-16T08:05:23.430799+00:00 2021-04-16T08:05:26.284060+00:00 0:00:02.853261 17754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:05:21.224760+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T07:00:00+00:00 EmrJobFlowSensor 2021-04-16T08:01:07.205950+00:00 2021-04-16T08:10:09.992700+00:00 0:09:02.786750 17753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:01:04.946683+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:00:45.121814+00:00 2021-04-16T08:00:47.026331+00:00 0:00:01.904517 17752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T08:00:42.822107+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T07:00:00+00:00 PythonOperator 2021-04-16T08:00:24.976983+00:00 2021-04-16T08:00:27.924646+00:00 0:00:02.947663 17751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T08:00:22.804288+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T06:00:00+00:00 EmrJobFlowSensor 2021-04-16T07:35:36.476257+00:00 2021-04-16T07:45:39.270153+00:00 0:10:02.793896 17750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:35:34.165048+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T06:00:00+00:00 EmrJobFlowSensor 2021-04-16T07:35:36.407265+00:00 2021-04-16T07:44:38.959304+00:00 0:09:02.552039 17749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:35:34.165075+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T07:35:16.742669+00:00 2021-04-16T07:35:18.588759+00:00 0:00:01.846090 17748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T07:35:14.145316+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T07:35:16.559430+00:00 2021-04-16T07:35:18.460665+00:00 0:00:01.901235 17747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T07:35:14.145289+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T06:00:00+00:00 PythonOperator 2021-04-16T07:34:54.547354+00:00 2021-04-16T07:34:57.472666+00:00 0:00:02.925312 17746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T07:34:52.123779+00:00 2 default_pool