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-06T12:05:00+00:00 EmrJobFlowSensor 2021-04-06T13:06:05.981667+00:00 2021-04-06T13:15:08.664138+00:00 0:09:02.682471 14212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:06:03.751939+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:05:39.994546+00:00 2021-04-06T13:05:41.641734+00:00 0:00:01.647188 14211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T13:05:37.718258+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T12:05:00+00:00 PythonOperator 2021-04-06T13:05:18.077735+00:00 2021-04-06T13:05:20.827535+00:00 0:00:02.749800 14210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:05:15.756289+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T12:00:00+00:00 EmrJobFlowSensor 2021-04-06T13:00:51.353659+00:00 2021-04-06T13:10:54.116046+00:00 0:10:02.762387 14209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:00:49.187214+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:00:31.384569+00:00 2021-04-06T13:00:33.095708+00:00 0:00:01.711139 14208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T13:00:29.173474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T12:00:00+00:00 PythonOperator 2021-04-06T13:00:09.612227+00:00 2021-04-06T13:00:12.404216+00:00 0:00:02.791989 14207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T13:00:07.151790+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:11:14.345184+00:00 2021-04-06T12:20:17.101980+00:00 0:09:02.756796 14205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:11:11.945166+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:11:10.338321+00:00 2021-04-06T12:21:13.302120+00:00 0:10:02.963799 14204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:11:07.947877+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:10:52.421520+00:00 2021-04-06T12:10:54.210692+00:00 0:00:01.789172 14203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:10:49.985506+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:10:48.329957+00:00 2021-04-06T12:10:50.042893+00:00 0:00:01.712936 14202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:10:45.980568+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:10:30.631697+00:00 2021-04-06T12:10:33.552829+00:00 0:00:02.921132 14201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:10:28.048211+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:10:26.253732+00:00 2021-04-06T12:10:29.102298+00:00 0:00:02.848566 14200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:10:24.040798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T11:00:00+00:00 TriggerDagRunOperator 2021-04-06T12:10:12.246389+00:00 2021-04-06T12:10:12.695707+00:00 0:00:00.449318 14199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:10:09.946545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T11:00:00+00:00 TriggerDagRunOperator 2021-04-06T12:10:12.210780+00:00 2021-04-06T12:10:12.785913+00:00 0:00:00.575133 14198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:10:09.946512+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T11:05:00+00:00 EmrJobFlowSensor 2021-04-06T12:06:05.850151+00:00 2021-04-06T12:14:08.323691+00:00 0:08:02.473540 14197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:06:03.492453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:05:45.774009+00:00 2021-04-06T12:05:47.535312+00:00 0:00:01.761303 14196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:05:43.442326+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T11:05:00+00:00 PythonOperator 2021-04-06T12:05:23.754616+00:00 2021-04-06T12:05:26.524567+00:00 0:00:02.769951 14195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:05:21.423891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:00:49.514231+00:00 2021-04-06T12:09:52.177904+00:00 0:09:02.663673 14194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:00:47.051977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:00:29.605969+00:00 2021-04-06T12:00:31.395737+00:00 0:00:01.789768 14193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T12:00:26.954757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:00:05.416338+00:00 2021-04-06T12:00:08.392730+00:00 0:00:02.976392 14192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T12:00:02.868626+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:11:35.309405+00:00 2021-04-06T11:20:37.937591+00:00 0:09:02.628186 14190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:11:32.887352+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:11:21.088376+00:00 2021-04-06T11:21:24.066081+00:00 0:10:02.977705 14189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:11:18.831926+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:11:13.067782+00:00 2021-04-06T11:11:14.866611+00:00 0:00:01.798829 14188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T11:11:10.825177+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:11:01.093203+00:00 2021-04-06T11:11:02.842642+00:00 0:00:01.749439 14187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T11:10:58.843930+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T10:00:00+00:00 PythonOperator 2021-04-06T11:10:53.105118+00:00 2021-04-06T11:10:55.924774+00:00 0:00:02.819656 14186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:10:50.808180+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T10:00:00+00:00 PythonOperator 2021-04-06T11:10:39.119897+00:00 2021-04-06T11:10:42.207514+00:00 0:00:03.087617 14185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:10:36.795568+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T10:00:00+00:00 TriggerDagRunOperator 2021-04-06T11:10:33.352416+00:00 2021-04-06T11:10:33.893248+00:00 0:00:00.540832 14184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:10:30.847204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T10:00:00+00:00 TriggerDagRunOperator 2021-04-06T11:10:33.146857+00:00 2021-04-06T11:10:33.598181+00:00 0:00:00.451324 14183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:10:30.847168+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T10:05:00+00:00 EmrJobFlowSensor 2021-04-06T11:06:01.035078+00:00 2021-04-06T11:14:03.498086+00:00 0:08:02.463008 14182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:05:58.648127+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:05:38.599401+00:00 2021-04-06T11:05:40.302845+00:00 0:00:01.703444 14181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T11:05:36.407466+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T10:05:00+00:00 PythonOperator 2021-04-06T11:05:16.780823+00:00 2021-04-06T11:05:19.428797+00:00 0:00:02.647974 14180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:05:14.444606+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:01:06.163732+00:00 2021-04-06T11:10:08.881531+00:00 0:09:02.717799 14179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:01:03.934967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:00:44.354819+00:00 2021-04-06T11:00:46.106480+00:00 0:00:01.751661 14178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T11:00:41.910941+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T10:00:00+00:00 PythonOperator 2021-04-06T11:00:24.454400+00:00 2021-04-06T11:00:27.285951+00:00 0:00:02.831551 14177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T11:00:21.891723+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T09:00:00+00:00 EmrJobFlowSensor 2021-04-06T10:12:43.306854+00:00 2021-04-06T10:22:46.211789+00:00 0:10:02.904935 14175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:12:41.018169+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T09:00:00+00:00 EmrJobFlowSensor 2021-04-06T10:12:37.246536+00:00 2021-04-06T10:22:39.983493+00:00 0:10:02.736957 14174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:12:35.013659+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:12:21.294203+00:00 2021-04-06T10:12:23.114505+00:00 0:00:01.820302 14173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:12:19.000105+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:12:15.405363+00:00 2021-04-06T10:12:17.178110+00:00 0:00:01.772747 14172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:12:13.062617+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T09:00:00+00:00 PythonOperator 2021-04-06T10:11:59.396298+00:00 2021-04-06T10:12:02.225716+00:00 0:00:02.829418 14171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:11:56.964898+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T09:00:00+00:00 PythonOperator 2021-04-06T10:11:55.137764+00:00 2021-04-06T10:11:58.081131+00:00 0:00:02.943367 14170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:11:52.908637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T09:00:00+00:00 TriggerDagRunOperator 2021-04-06T10:11:35.246121+00:00 2021-04-06T10:11:35.767321+00:00 0:00:00.521200 14169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:11:32.889712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T09:00:00+00:00 TriggerDagRunOperator 2021-04-06T10:11:35.127424+00:00 2021-04-06T10:11:35.569186+00:00 0:00:00.441762 14168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:11:32.889745+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T09:05:00+00:00 EmrJobFlowSensor 2021-04-06T10:05:56.501317+00:00 2021-04-06T10:14:59.099472+00:00 0:09:02.598155 14167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:05:54.302435+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:05:34.542329+00:00 2021-04-06T10:05:36.272255+00:00 0:00:01.729926 14166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:05:32.288684+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T09:05:00+00:00 PythonOperator 2021-04-06T10:05:12.388740+00:00 2021-04-06T10:05:15.107529+00:00 0:00:02.718789 14165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:05:10.194690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T09:00:00+00:00 EmrJobFlowSensor 2021-04-06T10:01:06.339987+00:00 2021-04-06T10:11:09.270902+00:00 0:10:02.930915 14164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:01:03.785518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:00:44.278503+00:00 2021-04-06T10:00:46.063086+00:00 0:00:01.784583 14163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T10:00:41.718736+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T09:00:00+00:00 PythonOperator 2021-04-06T10:00:22.128996+00:00 2021-04-06T10:00:24.975565+00:00 0:00:02.846569 14162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T10:00:19.702303+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T08:00:00+00:00 EmrJobFlowSensor 2021-04-06T09:12:33.279606+00:00 2021-04-06T09:21:35.906214+00:00 0:09:02.626608 14160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:12:30.760272+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T08:00:00+00:00 EmrJobFlowSensor 2021-04-06T09:12:29.034221+00:00 2021-04-06T09:22:31.663914+00:00 0:10:02.629693 14159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:12:26.705759+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:12:11.058762+00:00 2021-04-06T09:12:12.962723+00:00 0:00:01.903961 14158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T09:12:08.751086+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:12:09.035932+00:00 2021-04-06T09:12:10.748342+00:00 0:00:01.712410 14157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T09:12:06.759830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T08:00:00+00:00 PythonOperator 2021-04-06T09:11:50.842101+00:00 2021-04-06T09:11:53.753880+00:00 0:00:02.911779 14156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:11:48.630662+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T08:00:00+00:00 PythonOperator 2021-04-06T09:11:46.839829+00:00 2021-04-06T09:11:49.644227+00:00 0:00:02.804398 14155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:11:44.627272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T08:00:00+00:00 TriggerDagRunOperator 2021-04-06T09:11:29.133206+00:00 2021-04-06T09:11:29.661735+00:00 0:00:00.528529 14154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:11:26.611608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T08:00:00+00:00 TriggerDagRunOperator 2021-04-06T09:11:28.951356+00:00 2021-04-06T09:11:29.353544+00:00 0:00:00.402188 14153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:11:26.611640+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T08:05:00+00:00 EmrJobFlowSensor 2021-04-06T09:05:50.195655+00:00 2021-04-06T09:14:52.840207+00:00 0:09:02.644552 14152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:05:48.005793+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:05:28.427112+00:00 2021-04-06T09:05:30.102472+00:00 0:00:01.675360 14151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T09:05:26.059741+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T08:05:00+00:00 PythonOperator 2021-04-06T09:05:06.286795+00:00 2021-04-06T09:05:08.986640+00:00 0:00:02.699845 14150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:05:03.971949+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T08:00:00+00:00 EmrJobFlowSensor 2021-04-06T09:01:02.152687+00:00 2021-04-06T09:11:05.047568+00:00 0:10:02.894881 14149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:00:59.669830+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:00:39.718753+00:00 2021-04-06T09:00:41.383931+00:00 0:00:01.665178 14148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T09:00:37.525096+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T08:00:00+00:00 PythonOperator 2021-04-06T09:00:19.919745+00:00 2021-04-06T09:00:22.653021+00:00 0:00:02.733276 14147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T09:00:17.519468+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T07:00:00+00:00 EmrJobFlowSensor 2021-04-06T08:15:12.936303+00:00 2021-04-06T08:24:15.650291+00:00 0:09:02.713988 14146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:15:10.663648+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T07:00:00+00:00 EmrJobFlowSensor 2021-04-06T08:14:56.943139+00:00 2021-04-06T08:23:59.687549+00:00 0:09:02.744410 14145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:14:54.651600+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:14:50.901356+00:00 2021-04-06T08:14:52.641790+00:00 0:00:01.740434 14144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T08:14:48.642183+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:14:34.914963+00:00 2021-04-06T08:14:36.610569+00:00 0:00:01.695606 14143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T08:14:32.628484+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T07:00:00+00:00 PythonOperator 2021-04-06T08:14:28.812784+00:00 2021-04-06T08:14:31.706374+00:00 0:00:02.893590 14142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:14:26.623617+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T07:00:00+00:00 PythonOperator 2021-04-06T08:14:15.015858+00:00 2021-04-06T08:14:17.726182+00:00 0:00:02.710324 14141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:14:12.618463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T07:00:00+00:00 TriggerDagRunOperator 2021-04-06T08:14:07.426252+00:00 2021-04-06T08:14:07.865979+00:00 0:00:00.439727 14140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:14:04.478028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T07:00:00+00:00 TriggerDagRunOperator 2021-04-06T08:14:07.415076+00:00 2021-04-06T08:14:08.023331+00:00 0:00:00.608255 14139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:14:04.478059+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T07:05:00+00:00 EmrJobFlowSensor 2021-04-06T08:05:59.521651+00:00 2021-04-06T08:15:02.169115+00:00 0:09:02.647464 14137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:05:57.116073+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:05:37.516978+00:00 2021-04-06T08:05:39.266668+00:00 0:00:01.749690 14136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T08:05:35.146539+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T07:05:00+00:00 PythonOperator 2021-04-06T08:05:15.356884+00:00 2021-04-06T08:05:18.096747+00:00 0:00:02.739863 14135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:05:12.995128+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T07:00:00+00:00 EmrJobFlowSensor 2021-04-06T08:01:01.221326+00:00 2021-04-06T08:10:04.075077+00:00 0:09:02.853751 14134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:00:58.562558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:00:38.827690+00:00 2021-04-06T08:00:40.518117+00:00 0:00:01.690427 14133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T08:00:36.478358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T07:00:00+00:00 PythonOperator 2021-04-06T08:00:18.623042+00:00 2021-04-06T08:00:21.397385+00:00 0:00:02.774343 14132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T08:00:16.384557+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2021-04-06T07:49:41.390893+00:00 PythonOperator 2021-04-06T07:56:16.201997+00:00 2021-04-06T07:56:18.988106+00:00 0:00:02.786109 14131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:56:13.997041+00:00 4 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T06:00:00+00:00 EmrJobFlowSensor 2021-04-06T07:12:21.818497+00:00 2021-04-06T07:20:24.371258+00:00 0:08:02.552761 14128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:12:19.614900+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T06:00:00+00:00 EmrJobFlowSensor 2021-04-06T07:12:16.088089+00:00 2021-04-06T07:22:18.843994+00:00 0:10:02.755905 14127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:12:13.671568+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:12:00.305870+00:00 2021-04-06T07:12:02.178286+00:00 0:00:01.872416 14126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T07:11:57.653461+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:11:54.185960+00:00 2021-04-06T07:11:56.092168+00:00 0:00:01.906208 14125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T07:11:51.566480+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T06:00:00+00:00 PythonOperator 2021-04-06T07:11:38.207424+00:00 2021-04-06T07:11:41.195041+00:00 0:00:02.987617 14124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:11:35.543561+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T06:00:00+00:00 PythonOperator 2021-04-06T07:11:33.817167+00:00 2021-04-06T07:11:37.007650+00:00 0:00:03.190483 14123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:11:31.467974+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T06:00:00+00:00 TriggerDagRunOperator 2021-04-06T07:11:14.028229+00:00 2021-04-06T07:11:14.590339+00:00 0:00:00.562110 14122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:11:11.389479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T06:00:00+00:00 TriggerDagRunOperator 2021-04-06T07:11:13.914082+00:00 2021-04-06T07:11:14.360403+00:00 0:00:00.446321 14121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:11:11.389450+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T06:05:00+00:00 EmrJobFlowSensor 2021-04-06T07:06:07.935874+00:00 2021-04-06T07:14:10.291310+00:00 0:08:02.355436 14119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:06:05.765129+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:05:41.908481+00:00 2021-04-06T07:05:43.592923+00:00 0:00:01.684442 14118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T07:05:39.744010+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T06:05:00+00:00 PythonOperator 2021-04-06T07:05:20.114315+00:00 2021-04-06T07:05:22.816543+00:00 0:00:02.702228 14117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:05:17.688234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T06:00:00+00:00 EmrJobFlowSensor 2021-04-06T07:01:05.694292+00:00 2021-04-06T07:11:08.377350+00:00 0:10:02.683058 14116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:01:03.354177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:00:43.651895+00:00 2021-04-06T07:00:45.349538+00:00 0:00:01.697643 14115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T07:00:41.258329+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T06:00:00+00:00 PythonOperator 2021-04-06T07:00:23.427189+00:00 2021-04-06T07:00:26.416101+00:00 0:00:02.988912 14114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T07:00:21.241621+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T05:00:00+00:00 EmrJobFlowSensor 2021-04-06T06:11:24.380052+00:00 2021-04-06T06:20:27.157875+00:00 0:09:02.777823 14113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:11:22.027257+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T05:00:00+00:00 EmrJobFlowSensor 2021-04-06T06:11:22.269293+00:00 2021-04-06T06:21:25.077775+00:00 0:10:02.808482 14112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:11:20.032739+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:11:04.265147+00:00 2021-04-06T06:11:06.101480+00:00 0:00:01.836333 14111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T06:11:02.011229+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:11:00.473425+00:00 2021-04-06T06:11:02.279240+00:00 0:00:01.805815 14110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T06:10:58.076015+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T05:00:00+00:00 PythonOperator 2021-04-06T06:10:36.372364+00:00 2021-04-06T06:10:39.178692+00:00 0:00:02.806328 14109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:10:34.054191+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T05:00:00+00:00 PythonOperator 2021-04-06T06:10:34.357716+00:00 2021-04-06T06:10:37.325940+00:00 0:00:02.968224 14108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:10:32.057972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T05:00:00+00:00 TriggerDagRunOperator 2021-04-06T06:10:14.480968+00:00 2021-04-06T06:10:14.913886+00:00 0:00:00.432918 14107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:10:11.903065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T05:00:00+00:00 TriggerDagRunOperator 2021-04-06T06:10:14.484765+00:00 2021-04-06T06:10:15.038243+00:00 0:00:00.553478 14106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:10:11.903039+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T05:05:00+00:00 EmrJobFlowSensor 2021-04-06T06:07:36.002633+00:00 2021-04-06T06:15:38.550385+00:00 0:08:02.547752 14105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:07:33.721825+00:00 2 default_pool