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_cluster_and_add_emr_steps 2021-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:00:26.419977+00:00 2021-04-01T13:00:28.147306+00:00 0:00:01.727329 12404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T13:00:24.260821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T12:00:00+00:00 PythonOperator 2021-04-01T13:00:04.704856+00:00 2021-04-01T13:00:07.478682+00:00 0:00:02.773826 12403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T13:00:02.203530+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:12:37.713404+00:00 2021-04-01T12:24:40.978214+00:00 0:12:03.264810 12401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:12:35.068306+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:12:37.410270+00:00 2021-04-01T12:20:39.951397+00:00 0:08:02.541127 12400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:12:35.068255+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:12:15.727088+00:00 2021-04-01T12:12:17.560930+00:00 0:00:01.833842 12399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T12:12:13.058875+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:12:15.596575+00:00 2021-04-01T12:12:17.329539+00:00 0:00:01.732964 12398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T12:12:13.058826+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:11:55.317538+00:00 2021-04-01T12:11:58.191893+00:00 0:00:02.874355 12397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:11:52.944470+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:11:55.225828+00:00 2021-04-01T12:11:58.223425+00:00 0:00:02.997597 12396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:11:52.944505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T11:00:00+00:00 TriggerDagRunOperator 2021-04-01T12:11:37.330750+00:00 2021-04-01T12:11:37.859843+00:00 0:00:00.529093 12395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:11:34.930157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T11:00:00+00:00 TriggerDagRunOperator 2021-04-01T12:11:37.246206+00:00 2021-04-01T12:11:37.660640+00:00 0:00:00.414434 12394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:11:34.930123+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T11:05:00+00:00 EmrJobFlowSensor 2021-04-01T12:06:08.665271+00:00 2021-04-01T12:15:11.244140+00:00 0:09:02.578869 12393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:06:06.433832+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:05:48.714646+00:00 2021-04-01T12:05:50.369670+00:00 0:00:01.655024 12392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T12:05:46.406626+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T11:05:00+00:00 PythonOperator 2021-04-01T12:05:26.760118+00:00 2021-04-01T12:05:29.437793+00:00 0:00:02.677675 12391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:05:24.467848+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:01:10.150317+00:00 2021-04-01T12:11:13.160671+00:00 0:10:03.010354 12390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:01:07.826493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:00:42.134775+00:00 2021-04-01T12:00:43.828609+00:00 0:00:01.693834 12389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T12:00:39.865787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:00:22.099391+00:00 2021-04-01T12:00:24.889601+00:00 0:00:02.790210 12388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T12:00:19.783951+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T10:00:00+00:00 EmrJobFlowSensor 2021-04-01T11:12:34.526329+00:00 2021-04-01T11:21:37.002600+00:00 0:09:02.476271 12386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:12:32.183583+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T10:00:00+00:00 EmrJobFlowSensor 2021-04-01T11:12:28.414493+00:00 2021-04-01T11:22:31.279895+00:00 0:10:02.865402 12385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:12:26.164392+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:12:10.311112+00:00 2021-04-01T11:12:12.056878+00:00 0:00:01.745766 12384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T11:12:08.148315+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:12:06.311702+00:00 2021-04-01T11:12:08.074390+00:00 0:00:01.762688 12383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T11:12:04.142541+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T10:00:00+00:00 PythonOperator 2021-04-01T11:11:50.754538+00:00 2021-04-01T11:11:54.026180+00:00 0:00:03.271642 12382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:11:48.130068+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T10:00:00+00:00 PythonOperator 2021-04-01T11:11:46.756716+00:00 2021-04-01T11:11:50.037448+00:00 0:00:03.280732 12381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:11:44.123560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T10:00:00+00:00 TriggerDagRunOperator 2021-04-01T11:11:34.624196+00:00 2021-04-01T11:11:35.195141+00:00 0:00:00.570945 12380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:11:32.113304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T10:00:00+00:00 TriggerDagRunOperator 2021-04-01T11:11:34.423483+00:00 2021-04-01T11:11:34.870202+00:00 0:00:00.446719 12379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:11:32.113273+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T10:05:00+00:00 EmrJobFlowSensor 2021-04-01T11:06:04.007762+00:00 2021-04-01T11:15:06.635566+00:00 0:09:02.627804 12378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:06:01.701698+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:05:42.000714+00:00 2021-04-01T11:05:43.643395+00:00 0:00:01.642681 12377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T11:05:39.744059+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T10:05:00+00:00 PythonOperator 2021-04-01T11:05:21.820004+00:00 2021-04-01T11:05:24.498884+00:00 0:00:02.678880 12376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:05:19.655118+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T10:00:00+00:00 EmrJobFlowSensor 2021-04-01T11:01:09.888907+00:00 2021-04-01T11:11:12.758761+00:00 0:10:02.869854 12375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:01:07.279039+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:00:47.414007+00:00 2021-04-01T11:00:49.127735+00:00 0:00:01.713728 12374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T11:00:45.189350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T10:00:00+00:00 PythonOperator 2021-04-01T11:00:21.548792+00:00 2021-04-01T11:00:24.257195+00:00 0:00:02.708403 12373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T11:00:19.126588+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:11:28.920231+00:00 2021-04-01T10:21:31.701658+00:00 0:10:02.781427 12371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:11:26.787337+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:11:23.187923+00:00 2021-04-01T10:28:27.013439+00:00 0:17:03.825516 12370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:11:20.855409+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:11:09.293658+00:00 2021-04-01T10:11:11.216683+00:00 0:00:01.923025 12369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:11:06.770426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:11:03.192120+00:00 2021-04-01T10:11:05.047773+00:00 0:00:01.855653 12368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:11:00.759093+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:10:46.888433+00:00 2021-04-01T10:10:49.886665+00:00 0:00:02.998232 12367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:10:44.690199+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:10:40.983317+00:00 2021-04-01T10:10:43.668587+00:00 0:00:02.685270 12366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:10:38.752291+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T09:00:00+00:00 TriggerDagRunOperator 2021-04-01T10:10:23.011850+00:00 2021-04-01T10:10:23.689301+00:00 0:00:00.677451 12365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:10:20.664280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T09:00:00+00:00 TriggerDagRunOperator 2021-04-01T10:10:22.931966+00:00 2021-04-01T10:10:23.379518+00:00 0:00:00.447552 12364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:10:20.664307+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T09:05:00+00:00 EmrJobFlowSensor 2021-04-01T10:05:46.604993+00:00 2021-04-01T10:16:49.649406+00:00 0:11:03.044413 12363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:05:44.225202+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:05:24.399747+00:00 2021-04-01T10:05:26.064773+00:00 0:00:01.665026 12362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:05:22.240855+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T09:05:00+00:00 PythonOperator 2021-04-01T10:05:04.644706+00:00 2021-04-01T10:05:07.530875+00:00 0:00:02.886169 12361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:05:02.186644+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:01:00.458125+00:00 2021-04-01T10:10:03.259011+00:00 0:09:02.800886 12360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:00:57.963177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:00:40.081698+00:00 2021-04-01T10:00:41.781964+00:00 0:00:01.700266 12359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T10:00:37.846007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:00:18.466506+00:00 2021-04-01T10:00:21.302408+00:00 0:00:02.835902 12358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T10:00:15.882955+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:19:04.609106+00:00 2021-04-01T09:29:07.431863+00:00 0:10:02.822757 12357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:19:02.169047+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:18:48.270356+00:00 2021-04-01T09:27:51.008467+00:00 0:09:02.738111 12356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:18:46.022987+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:18:42.374822+00:00 2021-04-01T09:18:44.119288+00:00 0:00:01.744466 12355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:18:40.075282+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:18:28.394708+00:00 2021-04-01T09:18:30.208779+00:00 0:00:01.814071 12354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:18:26.007291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:18:22.230527+00:00 2021-04-01T09:18:25.343353+00:00 0:00:03.112826 12353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:18:20.003139+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:18:06.263009+00:00 2021-04-01T09:18:08.978303+00:00 0:00:02.715294 12352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:18:03.987713+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T08:00:00+00:00 TriggerDagRunOperator 2021-04-01T09:18:00.670337+00:00 2021-04-01T09:18:01.096632+00:00 0:00:00.426295 12351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:17:57.983193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T08:00:00+00:00 TriggerDagRunOperator 2021-04-01T09:18:00.679113+00:00 2021-04-01T09:18:01.203499+00:00 0:00:00.524386 12350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:17:57.983220+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T08:05:00+00:00 EmrJobFlowSensor 2021-04-01T09:05:46.263712+00:00 2021-04-01T09:14:48.944140+00:00 0:09:02.680428 12348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:05:44.056240+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:05:24.457841+00:00 2021-04-01T09:05:26.099384+00:00 0:00:01.641543 12347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:05:21.967059+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T08:05:00+00:00 PythonOperator 2021-04-01T09:05:04.453509+00:00 2021-04-01T09:05:07.249122+00:00 0:00:02.795613 12346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:05:01.948047+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:01:03.918941+00:00 2021-04-01T09:15:07.350870+00:00 0:14:03.431929 12345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:01:01.591451+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:00:41.709460+00:00 2021-04-01T09:00:43.423402+00:00 0:00:01.713942 12344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T09:00:39.549774+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:00:19.673721+00:00 2021-04-01T09:00:22.383540+00:00 0:00:02.709819 12343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T09:00:17.477691+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:18:21.202904+00:00 2021-04-01T08:27:23.733949+00:00 0:09:02.531045 12342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:18:19.007414+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:18:05.346721+00:00 2021-04-01T08:28:08.193912+00:00 0:10:02.847191 12341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:18:02.985876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:17:59.177267+00:00 2021-04-01T08:18:00.903995+00:00 0:00:01.726728 12340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:17:56.915918+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:17:43.301890+00:00 2021-04-01T08:17:45.167285+00:00 0:00:01.865395 12339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:17:40.904496+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:17:37.452178+00:00 2021-04-01T08:17:40.231940+00:00 0:00:02.779762 12338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:17:34.960291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:17:17.515425+00:00 2021-04-01T08:17:20.496481+00:00 0:00:02.981056 12337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:17:14.944413+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T07:00:00+00:00 TriggerDagRunOperator 2021-04-01T08:17:05.620360+00:00 2021-04-01T08:17:06.067764+00:00 0:00:00.447404 12336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:17:02.832208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T07:00:00+00:00 TriggerDagRunOperator 2021-04-01T08:17:05.408787+00:00 2021-04-01T08:17:06.005191+00:00 0:00:00.596404 12335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:17:02.832179+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T07:05:00+00:00 EmrJobFlowSensor 2021-04-01T08:05:54.132880+00:00 2021-04-01T08:14:56.717317+00:00 0:09:02.584437 12333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:05:51.564154+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:05:33.900809+00:00 2021-04-01T08:05:35.568514+00:00 0:00:01.667705 12332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:05:31.555848+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T07:05:00+00:00 PythonOperator 2021-04-01T08:05:11.572698+00:00 2021-04-01T08:05:14.262561+00:00 0:00:02.689863 12331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:05:09.397704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:00:55.241494+00:00 2021-04-01T08:16:58.760596+00:00 0:16:03.519102 12330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:00:52.900154+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:00:33.149024+00:00 2021-04-01T08:00:34.830519+00:00 0:00:01.681495 12329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T08:00:30.866082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:00:11.209819+00:00 2021-04-01T08:00:13.990249+00:00 0:00:02.780430 12328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T08:00:08.863725+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:14:00.337951+00:00 2021-04-01T07:23:03.191587+00:00 0:09:02.853636 12327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:13:57.893347+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:13:58.303041+00:00 2021-04-01T07:24:01.063142+00:00 0:10:02.760101 12326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:13:55.957973+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:13:40.458050+00:00 2021-04-01T07:13:42.127757+00:00 0:00:01.669707 12325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:13:37.848745+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:13:38.128503+00:00 2021-04-01T07:13:40.142673+00:00 0:00:02.014170 12324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:13:35.846295+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:13:18.747837+00:00 2021-04-01T07:13:21.495206+00:00 0:00:02.747369 12323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:13:15.832681+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:13:16.255157+00:00 2021-04-01T07:13:19.527968+00:00 0:00:03.272811 12322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:13:13.829952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T06:00:00+00:00 TriggerDagRunOperator 2021-04-01T07:12:56.263666+00:00 2021-04-01T07:12:56.786369+00:00 0:00:00.522703 12321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:12:53.810978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T06:00:00+00:00 TriggerDagRunOperator 2021-04-01T07:12:56.045751+00:00 2021-04-01T07:12:56.459134+00:00 0:00:00.413383 12320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:12:53.811007+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T06:05:00+00:00 EmrJobFlowSensor 2021-04-01T07:06:12.040054+00:00 2021-04-01T07:15:14.663571+00:00 0:09:02.623517 12318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:06:09.767713+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:05:51.810132+00:00 2021-04-01T07:05:53.464343+00:00 0:00:01.654211 12317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:05:49.638015+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T06:05:00+00:00 PythonOperator 2021-04-01T07:05:15.804078+00:00 2021-04-01T07:05:18.578100+00:00 0:00:02.774022 12316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:05:13.604579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:01:15.576380+00:00 2021-04-01T07:11:18.444671+00:00 0:10:02.868291 12315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:01:13.290033+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:00:51.570536+00:00 2021-04-01T07:00:53.373486+00:00 0:00:01.802950 12314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T07:00:49.269788+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:00:27.548746+00:00 2021-04-01T07:00:30.266755+00:00 0:00:02.718009 12313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T07:00:25.275233+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:11:28.937377+00:00 2021-04-01T06:22:31.825661+00:00 0:11:02.888284 12312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:11:26.459646+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:11:22.804909+00:00 2021-04-01T06:20:25.419204+00:00 0:09:02.614295 12311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:11:20.461582+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:11:06.675035+00:00 2021-04-01T06:11:08.552543+00:00 0:00:01.877508 12310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:11:04.381586+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:11:02.678825+00:00 2021-04-01T06:11:04.508526+00:00 0:00:01.829701 12309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:11:00.378953+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:10:46.685630+00:00 2021-04-01T06:10:49.647037+00:00 0:00:02.961407 12308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:10:44.330377+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:10:41.025456+00:00 2021-04-01T06:10:43.742256+00:00 0:00:02.716800 12307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:10:38.449870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T05:00:00+00:00 TriggerDagRunOperator 2021-04-01T06:10:29.128092+00:00 2021-04-01T06:10:29.675417+00:00 0:00:00.547325 12306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:10:26.310664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T05:00:00+00:00 TriggerDagRunOperator 2021-04-01T06:10:28.925518+00:00 2021-04-01T06:10:29.347993+00:00 0:00:00.422475 12305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:10:26.310637+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T05:05:00+00:00 EmrJobFlowSensor 2021-04-01T06:05:55.275123+00:00 2021-04-01T06:14:57.936372+00:00 0:09:02.661249 12303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:05:52.967156+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:05:33.267128+00:00 2021-04-01T06:05:34.892441+00:00 0:00:01.625313 12302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:05:30.884753+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T05:05:00+00:00 PythonOperator 2021-04-01T06:05:10.889679+00:00 2021-04-01T06:05:13.630980+00:00 0:00:02.741301 12301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:05:08.742623+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:01:02.631103+00:00 2021-04-01T06:10:05.327143+00:00 0:09:02.696040 12300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:01:00.380715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:00:40.565336+00:00 2021-04-01T06:00:42.375533+00:00 0:00:01.810197 12299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T06:00:38.296448+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:00:20.529161+00:00 2021-04-01T06:00:23.249023+00:00 0:00:02.719862 12298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T06:00:18.241804+00:00 2 default_pool