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 create_emr_steps 2021-04-28T14:00:00+00:00 PythonOperator 2021-04-28T15:00:05.655287+00:00 2021-04-28T15:00:08.717304+00:00 0:00:03.062017 22227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T15:00:03.051653+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T13:00:00+00:00 EmrJobFlowSensor 2021-04-28T14:17:05.600341+00:00 2021-04-28T14:28:08.604360+00:00 0:11:03.004019 22226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:17:03.162246+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T13:00:00+00:00 EmrJobFlowSensor 2021-04-28T14:16:59.316800+00:00 2021-04-28T14:26:02.150617+00:00 0:09:02.833817 22225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:16:57.116457+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:16:43.435275+00:00 2021-04-28T14:16:45.162564+00:00 0:00:01.727289 22224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T14:16:41.088356+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:16:37.386363+00:00 2021-04-28T14:16:39.076561+00:00 0:00:01.690198 22223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T14:16:35.063182+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T13:00:00+00:00 PythonOperator 2021-04-28T14:16:21.795785+00:00 2021-04-28T14:16:25.035268+00:00 0:00:03.239483 22222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:16:19.060279+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T13:00:00+00:00 PythonOperator 2021-04-28T14:16:13.446169+00:00 2021-04-28T14:16:16.447057+00:00 0:00:03.000888 22221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:16:10.999853+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T13:00:00+00:00 TriggerDagRunOperator 2021-04-28T14:16:05.853321+00:00 2021-04-28T14:16:06.393771+00:00 0:00:00.540450 22220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:16:02.983153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T13:00:00+00:00 TriggerDagRunOperator 2021-04-28T14:16:05.788627+00:00 2021-04-28T14:16:06.191868+00:00 0:00:00.403241 22219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:16:02.983182+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T13:05:00+00:00 EmrJobFlowSensor 2021-04-28T14:05:52.773644+00:00 2021-04-28T14:14:55.347705+00:00 0:09:02.574061 22217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:05:50.515318+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:05:31.019328+00:00 2021-04-28T14:05:32.713644+00:00 0:00:01.694316 22216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T14:05:28.666117+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T13:05:00+00:00 PythonOperator 2021-04-28T14:05:10.686512+00:00 2021-04-28T14:05:13.631486+00:00 0:00:02.944974 22215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:05:08.410207+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T13:00:00+00:00 EmrJobFlowSensor 2021-04-28T14:00:48.354176+00:00 2021-04-28T14:11:51.360066+00:00 0:11:03.005890 22214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:00:45.859933+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:00:28.250411+00:00 2021-04-28T14:00:30.145168+00:00 0:00:01.894757 22213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T14:00:25.768733+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T13:00:00+00:00 PythonOperator 2021-04-28T14:00:05.986651+00:00 2021-04-28T14:00:09.037897+00:00 0:00:03.051246 22212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T14:00:03.666892+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T12:00:00+00:00 EmrJobFlowSensor 2021-04-28T13:12:44.191106+00:00 2021-04-28T13:22:47.086103+00:00 0:10:02.894997 22211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:12:41.669654+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T12:00:00+00:00 EmrJobFlowSensor 2021-04-28T13:12:44.054944+00:00 2021-04-28T13:20:46.652475+00:00 0:08:02.597531 22210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:12:41.669627+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T13:12:22.112893+00:00 2021-04-28T13:12:23.995579+00:00 0:00:01.882686 22209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T13:12:19.663639+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T13:12:22.010267+00:00 2021-04-28T13:12:23.854087+00:00 0:00:01.843820 22208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T13:12:19.663600+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T12:00:00+00:00 PythonOperator 2021-04-28T13:12:00.097146+00:00 2021-04-28T13:12:03.093861+00:00 0:00:02.996715 22207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T13:11:57.617052+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T12:00:00+00:00 PythonOperator 2021-04-28T13:11:59.987725+00:00 2021-04-28T13:12:03.313942+00:00 0:00:03.326217 22206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T13:11:57.617017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T12:00:00+00:00 TriggerDagRunOperator 2021-04-28T13:11:36.254026+00:00 2021-04-28T13:11:36.793119+00:00 0:00:00.539093 22205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:11:33.611911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T12:00:00+00:00 TriggerDagRunOperator 2021-04-28T13:11:36.103133+00:00 2021-04-28T13:11:36.544221+00:00 0:00:00.441088 22204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:11:33.611882+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T12:05:00+00:00 EmrJobFlowSensor 2021-04-28T13:05:53.533549+00:00 2021-04-28T13:15:56.232097+00:00 0:10:02.698548 22202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:05:51.210814+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T13:05:31.504606+00:00 2021-04-28T13:05:33.234131+00:00 0:00:01.729525 22201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T13:05:29.191009+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T12:05:00+00:00 PythonOperator 2021-04-28T13:05:09.395351+00:00 2021-04-28T13:05:12.380641+00:00 0:00:02.985290 22200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T13:05:07.125366+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T12:00:00+00:00 EmrJobFlowSensor 2021-04-28T13:01:08.975028+00:00 2021-04-28T13:11:11.885473+00:00 0:10:02.910445 22199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T13:01:06.655929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T13:00:46.943789+00:00 2021-04-28T13:00:48.765787+00:00 0:00:01.821998 22198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T13:00:44.645953+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T12:00:00+00:00 PythonOperator 2021-04-28T13:00:25.321287+00:00 2021-04-28T13:00:28.389703+00:00 0:00:03.068416 22197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T13:00:22.663116+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T11:00:00+00:00 EmrJobFlowSensor 2021-04-28T12:12:20.768239+00:00 2021-04-28T12:25:24.049296+00:00 0:13:03.281057 22196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:12:18.269039+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T11:00:00+00:00 EmrJobFlowSensor 2021-04-28T12:12:14.480080+00:00 2021-04-28T12:22:17.259510+00:00 0:10:02.779430 22195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:12:12.146503+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:12:00.820534+00:00 2021-04-28T12:12:02.549036+00:00 0:00:01.728502 22194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T12:11:58.176558+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:11:54.216292+00:00 2021-04-28T12:11:55.945920+00:00 0:00:01.729628 22193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T12:11:52.041244+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T11:00:00+00:00 PythonOperator 2021-04-28T12:11:38.181201+00:00 2021-04-28T12:11:41.146343+00:00 0:00:02.965142 22192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:11:35.992102+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T11:00:00+00:00 PythonOperator 2021-04-28T12:11:32.571936+00:00 2021-04-28T12:11:35.794596+00:00 0:00:03.222660 22191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:11:30.066834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T11:00:00+00:00 TriggerDagRunOperator 2021-04-28T12:11:18.683498+00:00 2021-04-28T12:11:19.190407+00:00 0:00:00.506909 22190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:11:15.964626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T11:00:00+00:00 TriggerDagRunOperator 2021-04-28T12:11:18.366581+00:00 2021-04-28T12:11:18.828975+00:00 0:00:00.462394 22189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:11:15.964583+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T11:05:00+00:00 EmrJobFlowSensor 2021-04-28T12:10:54.399985+00:00 2021-04-28T12:19:57.016459+00:00 0:09:02.616474 22188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:10:51.973186+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:10:32.623839+00:00 2021-04-28T12:10:34.359130+00:00 0:00:01.735291 22187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T12:10:29.966715+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T11:05:00+00:00 PythonOperator 2021-04-28T12:10:10.359385+00:00 2021-04-28T12:10:13.324989+00:00 0:00:02.965604 22186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:10:07.825044+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T11:00:00+00:00 EmrJobFlowSensor 2021-04-28T12:00:59.809148+00:00 2021-04-28T12:11:02.766506+00:00 0:10:02.957358 22184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:00:57.409091+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:00:37.687798+00:00 2021-04-28T12:00:39.501295+00:00 0:00:01.813497 22183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T12:00:35.392307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T11:00:00+00:00 PythonOperator 2021-04-28T12:00:15.622933+00:00 2021-04-28T12:00:18.653348+00:00 0:00:03.030415 22182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T12:00:13.287867+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T10:00:00+00:00 EmrJobFlowSensor 2021-04-28T11:11:35.351025+00:00 2021-04-28T11:23:38.299642+00:00 0:12:02.948617 22181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:11:32.881566+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T10:00:00+00:00 EmrJobFlowSensor 2021-04-28T11:11:19.085570+00:00 2021-04-28T11:20:21.787093+00:00 0:09:02.701523 22180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:11:16.709514+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:11:13.124692+00:00 2021-04-28T11:11:14.829599+00:00 0:00:01.704907 22179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T11:11:10.717251+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:10:57.223750+00:00 2021-04-28T11:10:58.996804+00:00 0:00:01.773054 22178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T11:10:54.764826+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T10:00:00+00:00 PythonOperator 2021-04-28T11:10:51.141800+00:00 2021-04-28T11:10:54.405067+00:00 0:00:03.263267 22177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:10:48.753956+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T10:00:00+00:00 PythonOperator 2021-04-28T11:10:35.191615+00:00 2021-04-28T11:10:38.229680+00:00 0:00:03.038065 22176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:10:32.695781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T10:00:00+00:00 TriggerDagRunOperator 2021-04-28T11:10:24.985565+00:00 2021-04-28T11:10:25.433492+00:00 0:00:00.447927 22175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:10:22.557464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T10:00:00+00:00 TriggerDagRunOperator 2021-04-28T11:10:24.919777+00:00 2021-04-28T11:10:25.516247+00:00 0:00:00.596470 22174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:10:22.557505+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T10:05:00+00:00 EmrJobFlowSensor 2021-04-28T11:06:06.345858+00:00 2021-04-28T11:15:08.958272+00:00 0:09:02.612414 22173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:06:04.107561+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:05:42.718334+00:00 2021-04-28T11:05:44.498692+00:00 0:00:01.780358 22172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T11:05:40.158284+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T10:05:00+00:00 PythonOperator 2021-04-28T11:05:22.546616+00:00 2021-04-28T11:05:25.484165+00:00 0:00:02.937549 22171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:05:20.056357+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T10:00:00+00:00 EmrJobFlowSensor 2021-04-28T11:00:58.909148+00:00 2021-04-28T11:10:01.753993+00:00 0:09:02.844845 22169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:00:56.400151+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:00:38.838981+00:00 2021-04-28T11:00:40.651879+00:00 0:00:01.812898 22168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T11:00:36.353055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T10:00:00+00:00 PythonOperator 2021-04-28T11:00:16.492175+00:00 2021-04-28T11:00:19.512344+00:00 0:00:03.020169 22167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T11:00:14.243452+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T09:00:00+00:00 EmrJobFlowSensor 2021-04-28T10:13:21.019827+00:00 2021-04-28T10:26:24.329178+00:00 0:13:03.309351 22166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:13:18.801582+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T09:00:00+00:00 EmrJobFlowSensor 2021-04-28T10:13:15.025845+00:00 2021-04-28T10:23:17.797024+00:00 0:10:02.771179 22165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:13:12.798191+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:12:59.123313+00:00 2021-04-28T10:13:00.891350+00:00 0:00:01.768037 22164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T10:12:56.737662+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:12:53.150421+00:00 2021-04-28T10:12:54.816436+00:00 0:00:01.666015 22163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T10:12:50.728016+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T09:00:00+00:00 PythonOperator 2021-04-28T10:12:37.166152+00:00 2021-04-28T10:12:40.352411+00:00 0:00:03.186259 22162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:12:34.767710+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T09:00:00+00:00 PythonOperator 2021-04-28T10:12:31.533230+00:00 2021-04-28T10:12:34.593946+00:00 0:00:03.060716 22161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:12:28.866285+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T09:00:00+00:00 TriggerDagRunOperator 2021-04-28T10:12:25.080866+00:00 2021-04-28T10:12:25.482760+00:00 0:00:00.401894 22160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:12:22.711190+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T09:00:00+00:00 TriggerDagRunOperator 2021-04-28T10:12:25.099740+00:00 2021-04-28T10:12:25.647378+00:00 0:00:00.547638 22159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:12:22.711161+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T09:05:00+00:00 EmrJobFlowSensor 2021-04-28T10:06:08.197217+00:00 2021-04-28T10:15:10.777546+00:00 0:09:02.580329 22158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:06:06.082134+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:05:48.404090+00:00 2021-04-28T10:05:50.136921+00:00 0:00:01.732831 22157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T10:05:46.061728+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T09:05:00+00:00 PythonOperator 2021-04-28T10:05:18.345412+00:00 2021-04-28T10:05:21.310357+00:00 0:00:02.964945 22156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:05:16.036074+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T09:00:00+00:00 EmrJobFlowSensor 2021-04-28T10:02:12.093000+00:00 2021-04-28T10:12:14.894473+00:00 0:10:02.801473 22155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:02:09.793184+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:01:50.044680+00:00 2021-04-28T10:01:51.730037+00:00 0:00:01.685357 22154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T10:01:47.693834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T09:00:00+00:00 PythonOperator 2021-04-28T10:01:29.946838+00:00 2021-04-28T10:01:32.966914+00:00 0:00:03.020076 22153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T10:01:27.670488+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T08:00:00+00:00 EmrJobFlowSensor 2021-04-28T09:11:06.721970+00:00 2021-04-28T09:20:09.342681+00:00 0:09:02.620711 22151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:11:04.512373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T08:00:00+00:00 EmrJobFlowSensor 2021-04-28T09:10:56.921892+00:00 2021-04-28T09:19:59.485055+00:00 0:09:02.563163 22150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:10:54.573184+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:10:44.868878+00:00 2021-04-28T09:10:46.716059+00:00 0:00:01.847181 22149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T09:10:42.494122+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:10:34.846099+00:00 2021-04-28T09:10:36.678139+00:00 0:00:01.832040 22148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T09:10:32.488873+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T08:00:00+00:00 PythonOperator 2021-04-28T09:10:24.628094+00:00 2021-04-28T09:10:27.588756+00:00 0:00:02.960662 22147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:10:22.432027+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T08:00:00+00:00 PythonOperator 2021-04-28T09:10:12.852732+00:00 2021-04-28T09:10:16.118524+00:00 0:00:03.265792 22146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:10:10.409018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T08:00:00+00:00 TriggerDagRunOperator 2021-04-28T09:10:06.657674+00:00 2021-04-28T09:10:07.195174+00:00 0:00:00.537500 22145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:10:04.406206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T08:00:00+00:00 TriggerDagRunOperator 2021-04-28T09:10:06.589843+00:00 2021-04-28T09:10:07.043971+00:00 0:00:00.454128 22144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:10:04.406240+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T08:05:00+00:00 EmrJobFlowSensor 2021-04-28T09:05:54.266723+00:00 2021-04-28T09:13:56.712922+00:00 0:08:02.446199 22143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:05:51.956007+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:05:34.208243+00:00 2021-04-28T09:05:35.870437+00:00 0:00:01.662194 22142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T09:05:31.938403+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T08:05:00+00:00 PythonOperator 2021-04-28T09:05:10.343238+00:00 2021-04-28T09:05:13.308675+00:00 0:00:02.965437 22141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:05:07.981472+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T08:00:00+00:00 EmrJobFlowSensor 2021-04-28T09:01:00.220467+00:00 2021-04-28T09:10:03.183532+00:00 0:09:02.963065 22140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:00:57.670237+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:00:38.107909+00:00 2021-04-28T09:00:39.991643+00:00 0:00:01.883734 22139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T09:00:35.661230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T08:00:00+00:00 PythonOperator 2021-04-28T09:00:17.813441+00:00 2021-04-28T09:00:20.798743+00:00 0:00:02.985302 22138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T09:00:15.559436+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:11:33.954950+00:00 2021-04-28T08:22:36.934014+00:00 0:11:02.979064 22136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:11:31.658167+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:11:21.821195+00:00 2021-04-28T08:21:24.603280+00:00 0:10:02.782085 22135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:11:19.599191+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:11:11.889849+00:00 2021-04-28T08:11:13.660385+00:00 0:00:01.770536 22134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:11:09.591129+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:11:00.108026+00:00 2021-04-28T08:11:01.794049+00:00 0:00:01.686023 22133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:10:57.561069+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:10:49.801567+00:00 2021-04-28T08:10:53.086889+00:00 0:00:03.285322 22132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:10:47.443138+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:10:40.085211+00:00 2021-04-28T08:10:43.113893+00:00 0:00:03.028682 22131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:10:37.546479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T07:00:00+00:00 TriggerDagRunOperator 2021-04-28T08:10:33.949428+00:00 2021-04-28T08:10:34.506853+00:00 0:00:00.557425 22130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:10:31.481141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T07:00:00+00:00 TriggerDagRunOperator 2021-04-28T08:10:33.928335+00:00 2021-04-28T08:10:34.404895+00:00 0:00:00.476560 22129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:10:31.481107+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T07:05:00+00:00 EmrJobFlowSensor 2021-04-28T08:05:56.952213+00:00 2021-04-28T08:14:59.597642+00:00 0:09:02.645429 22128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:05:54.809478+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:05:35.207784+00:00 2021-04-28T08:05:36.984895+00:00 0:00:01.777111 22127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:05:32.786607+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T07:05:00+00:00 PythonOperator 2021-04-28T08:05:10.880976+00:00 2021-04-28T08:05:13.856895+00:00 0:00:02.975919 22126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:05:08.726465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:01:06.593184+00:00 2021-04-28T08:10:09.423368+00:00 0:09:02.830184 22125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:01:04.246528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:00:44.620082+00:00 2021-04-28T08:00:46.346131+00:00 0:00:01.726049 22124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T08:00:42.280573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:00:25.208881+00:00 2021-04-28T08:00:28.176293+00:00 0:00:02.967412 22123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T08:00:22.263727+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T06:00:00+00:00 EmrJobFlowSensor 2021-04-28T07:12:39.735751+00:00 2021-04-28T07:22:42.405957+00:00 0:10:02.670206 22121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:12:37.562484+00:00 2 default_pool