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-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:00:39.331224+00:00 2021-04-09T21:00:41.137568+00:00 0:00:01.806344 15406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T21:00:36.896786+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T20:00:00+00:00 PythonOperator 2021-04-09T21:00:17.214445+00:00 2021-04-09T21:00:20.085058+00:00 0:00:02.870613 15405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T21:00:14.823645+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T19:00:00+00:00 EmrJobFlowSensor 2021-04-09T20:11:23.837449+00:00 2021-04-09T20:20:26.558908+00:00 0:09:02.721459 15403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:11:21.633377+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T19:00:00+00:00 EmrJobFlowSensor 2021-04-09T20:11:08.010059+00:00 2021-04-09T20:20:10.580377+00:00 0:09:02.570318 15402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:11:05.621673+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:11:03.937539+00:00 2021-04-09T20:11:05.661514+00:00 0:00:01.723975 15401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T20:11:01.615237+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:10:45.920739+00:00 2021-04-09T20:10:47.586092+00:00 0:00:01.665353 15400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T20:10:43.605440+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T19:00:00+00:00 PythonOperator 2021-04-09T20:10:40.084699+00:00 2021-04-09T20:10:42.789985+00:00 0:00:02.705286 15399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:10:37.592701+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T19:00:00+00:00 PythonOperator 2021-04-09T20:10:26.229431+00:00 2021-04-09T20:10:29.555564+00:00 0:00:03.326133 15398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:10:23.670820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T19:00:00+00:00 TriggerDagRunOperator 2021-04-09T20:10:15.997848+00:00 2021-04-09T20:10:16.562789+00:00 0:00:00.564941 15397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:10:13.528505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T19:00:00+00:00 TriggerDagRunOperator 2021-04-09T20:10:15.789502+00:00 2021-04-09T20:10:16.191416+00:00 0:00:00.401914 15396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:10:13.528535+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T19:05:00+00:00 EmrJobFlowSensor 2021-04-09T20:05:53.274586+00:00 2021-04-09T20:14:55.856263+00:00 0:09:02.581677 15395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:05:51.082871+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:05:33.374863+00:00 2021-04-09T20:05:35.136372+00:00 0:00:01.761509 15394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T20:05:31.074762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T19:05:00+00:00 PythonOperator 2021-04-09T20:05:11.190246+00:00 2021-04-09T20:05:13.977712+00:00 0:00:02.787466 15393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:05:09.004192+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T19:00:00+00:00 EmrJobFlowSensor 2021-04-09T20:00:58.827933+00:00 2021-04-09T20:10:02.050418+00:00 0:09:03.222485 15392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:00:56.430716+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:00:32.585021+00:00 2021-04-09T20:00:34.330855+00:00 0:00:01.745834 15391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T20:00:30.407010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T19:00:00+00:00 PythonOperator 2021-04-09T20:00:10.831616+00:00 2021-04-09T20:00:13.707212+00:00 0:00:02.875596 15390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T20:00:08.456712+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T18:00:00+00:00 EmrJobFlowSensor 2021-04-09T19:15:32.019733+00:00 2021-04-09T19:25:34.802230+00:00 0:10:02.782497 15389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:15:29.709188+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:15:11.863057+00:00 2021-04-09T19:15:13.771949+00:00 0:00:01.908892 15388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T19:15:09.690128+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T18:00:00+00:00 EmrJobFlowSensor 2021-04-09T19:14:18.168842+00:00 2021-04-09T19:21:20.636534+00:00 0:07:02.467692 15387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:14:15.629177+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:11:39.757321+00:00 2021-04-09T19:11:41.456235+00:00 0:00:01.698914 15385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T19:11:37.210195+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T18:00:00+00:00 PythonOperator 2021-04-09T19:11:27.915046+00:00 2021-04-09T19:11:30.870669+00:00 0:00:02.955623 15384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:11:25.266813+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T18:00:00+00:00 PythonOperator 2021-04-09T19:11:15.652999+00:00 2021-04-09T19:11:18.344453+00:00 0:00:02.691454 15383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:11:13.256100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T18:00:00+00:00 TriggerDagRunOperator 2021-04-09T19:11:08.043985+00:00 2021-04-09T19:11:08.595848+00:00 0:00:00.551863 15382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:11:05.252131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T18:00:00+00:00 TriggerDagRunOperator 2021-04-09T19:11:07.592814+00:00 2021-04-09T19:11:08.005447+00:00 0:00:00.412633 15381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:11:05.252084+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T18:05:00+00:00 EmrJobFlowSensor 2021-04-09T19:05:53.232455+00:00 2021-04-09T19:14:55.804022+00:00 0:09:02.571567 15380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:05:50.716749+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:05:32.937522+00:00 2021-04-09T19:05:34.621756+00:00 0:00:01.684234 15379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T19:05:30.700081+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T18:05:00+00:00 PythonOperator 2021-04-09T19:05:10.870313+00:00 2021-04-09T19:05:13.707187+00:00 0:00:02.836874 15378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:05:08.678808+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T18:00:00+00:00 EmrJobFlowSensor 2021-04-09T19:00:54.569111+00:00 2021-04-09T19:10:57.723971+00:00 0:10:03.154860 15377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:00:52.129415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:00:32.338728+00:00 2021-04-09T19:00:34.250695+00:00 0:00:01.911967 15376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T19:00:30.113397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T18:00:00+00:00 PythonOperator 2021-04-09T19:00:10.345114+00:00 2021-04-09T19:00:13.711243+00:00 0:00:03.366129 15375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T19:00:08.096281+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T17:00:00+00:00 EmrJobFlowSensor 2021-04-09T18:12:53.397390+00:00 2021-04-09T18:22:56.305507+00:00 0:10:02.908117 15374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:12:50.753844+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T17:00:00+00:00 EmrJobFlowSensor 2021-04-09T18:12:53.202087+00:00 2021-04-09T18:22:55.938121+00:00 0:10:02.736034 15373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:12:50.753805+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:12:31.013445+00:00 2021-04-09T18:12:32.833130+00:00 0:00:01.819685 15372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T18:12:28.670113+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:12:30.948704+00:00 2021-04-09T18:12:32.705512+00:00 0:00:01.756808 15371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T18:12:28.670141+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T17:00:00+00:00 PythonOperator 2021-04-09T18:12:10.948158+00:00 2021-04-09T18:12:13.929513+00:00 0:00:02.981355 15370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:12:08.613346+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T17:00:00+00:00 PythonOperator 2021-04-09T18:12:10.831697+00:00 2021-04-09T18:12:13.778611+00:00 0:00:02.946914 15369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:12:08.613315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T17:00:00+00:00 TriggerDagRunOperator 2021-04-09T18:11:57.290499+00:00 2021-04-09T18:11:57.844824+00:00 0:00:00.554325 15368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:11:54.601827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T17:00:00+00:00 TriggerDagRunOperator 2021-04-09T18:11:57.242479+00:00 2021-04-09T18:11:57.662614+00:00 0:00:00.420135 15367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:11:54.601855+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T17:05:00+00:00 EmrJobFlowSensor 2021-04-09T18:05:46.603038+00:00 2021-04-09T18:14:49.249422+00:00 0:09:02.646384 15365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:05:44.260903+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:05:26.422141+00:00 2021-04-09T18:05:28.185607+00:00 0:00:01.763466 15364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T18:05:24.182520+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T17:05:00+00:00 PythonOperator 2021-04-09T18:05:04.435661+00:00 2021-04-09T18:05:07.177507+00:00 0:00:02.741846 15363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:05:02.152707+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T17:00:00+00:00 EmrJobFlowSensor 2021-04-09T18:01:06.141053+00:00 2021-04-09T18:10:08.874939+00:00 0:09:02.733886 15362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:01:03.793984+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:00:44.143045+00:00 2021-04-09T18:00:46.049083+00:00 0:00:01.906038 15361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T18:00:41.721607+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T17:00:00+00:00 PythonOperator 2021-04-09T18:00:22.053726+00:00 2021-04-09T18:00:24.947225+00:00 0:00:02.893499 15360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T18:00:19.743650+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T16:00:00+00:00 EmrJobFlowSensor 2021-04-09T17:11:27.161522+00:00 2021-04-09T17:19:29.573090+00:00 0:08:02.411568 15359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:11:24.867793+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T16:00:00+00:00 EmrJobFlowSensor 2021-04-09T17:11:13.259751+00:00 2021-04-09T17:20:16.107347+00:00 0:09:02.847596 15358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:11:10.857615+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:11:07.164291+00:00 2021-04-09T17:11:09.034797+00:00 0:00:01.870506 15357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T17:11:04.844161+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:10:47.196037+00:00 2021-04-09T17:10:49.284982+00:00 0:00:02.088945 15356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T17:10:44.744359+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T16:00:00+00:00 PythonOperator 2021-04-09T17:10:35.091058+00:00 2021-04-09T17:10:37.791585+00:00 0:00:02.700527 15355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:10:32.747065+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T16:00:00+00:00 PythonOperator 2021-04-09T17:10:25.042776+00:00 2021-04-09T17:10:27.937639+00:00 0:00:02.894863 15354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:10:22.769938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T16:00:00+00:00 TriggerDagRunOperator 2021-04-09T17:10:15.733924+00:00 2021-04-09T17:10:16.259805+00:00 0:00:00.525881 15353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:10:12.641007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T16:00:00+00:00 TriggerDagRunOperator 2021-04-09T17:10:15.626847+00:00 2021-04-09T17:10:16.036759+00:00 0:00:00.409912 15352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:10:12.641053+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T16:05:00+00:00 EmrJobFlowSensor 2021-04-09T17:06:13.362651+00:00 2021-04-09T17:15:15.916828+00:00 0:09:02.554177 15350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:06:11.157710+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:05:51.290189+00:00 2021-04-09T17:05:52.963208+00:00 0:00:01.673019 15349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T17:05:49.139268+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T16:05:00+00:00 PythonOperator 2021-04-09T17:05:21.259316+00:00 2021-04-09T17:05:24.043209+00:00 0:00:02.783893 15348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:05:19.113563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T16:00:00+00:00 EmrJobFlowSensor 2021-04-09T17:00:49.443467+00:00 2021-04-09T17:09:52.167398+00:00 0:09:02.723931 15347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:00:46.461496+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:00:28.824629+00:00 2021-04-09T17:00:30.636945+00:00 0:00:01.812316 15346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T17:00:26.415990+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T16:00:00+00:00 PythonOperator 2021-04-09T17:00:06.663325+00:00 2021-04-09T17:00:09.802737+00:00 0:00:03.139412 15345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T17:00:04.386875+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T15:00:00+00:00 EmrJobFlowSensor 2021-04-09T16:19:44.841386+00:00 2021-04-09T16:27:47.465240+00:00 0:08:02.623854 15344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:19:42.348947+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T15:00:00+00:00 EmrJobFlowSensor 2021-04-09T16:19:42.508742+00:00 2021-04-09T16:28:45.223226+00:00 0:09:02.714484 15343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:19:40.346524+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:19:16.588234+00:00 2021-04-09T16:19:18.457426+00:00 0:00:01.869192 15342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T16:19:14.301919+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:19:12.575577+00:00 2021-04-09T16:19:14.394525+00:00 0:00:01.818948 15341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T16:19:10.296006+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T15:00:00+00:00 PythonOperator 2021-04-09T16:18:54.787673+00:00 2021-04-09T16:18:57.513110+00:00 0:00:02.725437 15340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:18:52.236779+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T15:00:00+00:00 PythonOperator 2021-04-09T16:18:50.445718+00:00 2021-04-09T16:18:53.718512+00:00 0:00:03.272794 15339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:18:48.232378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T15:00:00+00:00 TriggerDagRunOperator 2021-04-09T16:18:31.167631+00:00 2021-04-09T16:18:31.890748+00:00 0:00:00.723117 15338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:18:28.218466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T15:00:00+00:00 TriggerDagRunOperator 2021-04-09T16:18:30.664329+00:00 2021-04-09T16:18:31.108684+00:00 0:00:00.444355 15337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:18:28.218430+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T15:05:00+00:00 EmrJobFlowSensor 2021-04-09T16:09:19.820900+00:00 2021-04-09T16:18:22.426534+00:00 0:09:02.605634 15336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:09:17.506234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T15:00:00+00:00 EmrJobFlowSensor 2021-04-09T16:09:15.767339+00:00 2021-04-09T16:18:18.437947+00:00 0:09:02.670608 15335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:09:13.498999+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:08:59.596515+00:00 2021-04-09T16:09:01.257160+00:00 0:00:01.660645 15334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T16:08:57.461240+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:08:55.644023+00:00 2021-04-09T16:08:57.318368+00:00 0:00:01.674345 15333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T16:08:53.457321+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T15:05:00+00:00 PythonOperator 2021-04-09T16:08:37.662402+00:00 2021-04-09T16:08:40.315365+00:00 0:00:02.652963 15332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:08:35.438215+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T15:00:00+00:00 PythonOperator 2021-04-09T16:08:34.524150+00:00 2021-04-09T16:08:37.331113+00:00 0:00:02.806963 15331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T16:08:31.439296+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T14:00:00+00:00 EmrJobFlowSensor 2021-04-09T15:12:16.107437+00:00 2021-04-09T15:22:18.857237+00:00 0:10:02.749800 15329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:12:13.844247+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T14:00:00+00:00 EmrJobFlowSensor 2021-04-09T15:12:12.376021+00:00 2021-04-09T15:21:15.259545+00:00 0:09:02.883524 15328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:12:09.840663+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:11:54.395390+00:00 2021-04-09T15:11:56.084119+00:00 0:00:01.688729 15327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T15:11:51.875390+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:11:50.454319+00:00 2021-04-09T15:11:52.197166+00:00 0:00:01.742847 15326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T15:11:47.875194+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T14:00:00+00:00 PythonOperator 2021-04-09T15:11:30.216236+00:00 2021-04-09T15:11:33.185564+00:00 0:00:02.969328 15325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:11:27.869876+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T14:00:00+00:00 PythonOperator 2021-04-09T15:11:16.460130+00:00 2021-04-09T15:11:19.296608+00:00 0:00:02.836478 15324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:11:13.807433+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T14:00:00+00:00 TriggerDagRunOperator 2021-04-09T15:11:06.106027+00:00 2021-04-09T15:11:06.667743+00:00 0:00:00.561716 15323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:11:03.800947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T14:00:00+00:00 TriggerDagRunOperator 2021-04-09T15:11:06.085162+00:00 2021-04-09T15:11:06.572734+00:00 0:00:00.487572 15322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:11:03.800893+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T14:05:00+00:00 EmrJobFlowSensor 2021-04-09T15:05:55.831606+00:00 2021-04-09T15:13:58.328861+00:00 0:08:02.497255 15321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T15:05:53.462871+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:05:35.698012+00:00 2021-04-09T15:05:37.423232+00:00 0:00:01.725220 15320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T15:05:33.393652+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T14:05:00+00:00 PythonOperator 2021-04-09T15:05:13.466757+00:00 2021-04-09T15:05:16.383430+00:00 0:00:02.916673 15319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:05:11.284733+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T14:00:00+00:00 EmrJobFlowSensor 2021-04-09T15:00:49.214916+00:00 2021-04-09T15:10:52.081135+00:00 0:10:02.866219 15318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T15:00:46.784833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T15:00:29.053646+00:00 2021-04-09T15:00:30.888915+00:00 0:00:01.835269 15317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T15:00:26.734790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T14:00:00+00:00 PythonOperator 2021-04-09T15:00:07.535390+00:00 2021-04-09T15:00:10.586560+00:00 0:00:03.051170 15316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T15:00:04.712384+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T13:00:00+00:00 EmrJobFlowSensor 2021-04-09T14:12:06.806313+00:00 2021-04-09T14:22:09.645004+00:00 0:10:02.838691 15314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:12:04.454708+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T13:00:00+00:00 EmrJobFlowSensor 2021-04-09T14:11:52.677255+00:00 2021-04-09T14:21:55.561797+00:00 0:10:02.884542 15313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:11:50.330164+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:11:44.606780+00:00 2021-04-09T14:11:46.275343+00:00 0:00:01.668563 15312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T14:11:42.321739+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:11:30.899135+00:00 2021-04-09T14:11:32.580070+00:00 0:00:01.680935 15311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T14:11:28.468852+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T13:00:00+00:00 PythonOperator 2021-04-09T14:11:24.719629+00:00 2021-04-09T14:11:27.539552+00:00 0:00:02.819923 15310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:11:22.303107+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T13:00:00+00:00 PythonOperator 2021-04-09T14:11:10.605800+00:00 2021-04-09T14:11:13.794960+00:00 0:00:03.189160 15309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:11:08.289964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T13:00:00+00:00 TriggerDagRunOperator 2021-04-09T14:11:04.673178+00:00 2021-04-09T14:11:05.215760+00:00 0:00:00.542582 15308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:11:02.287389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T13:00:00+00:00 TriggerDagRunOperator 2021-04-09T14:11:04.611048+00:00 2021-04-09T14:11:05.031089+00:00 0:00:00.420041 15307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:11:02.287434+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T13:05:00+00:00 EmrJobFlowSensor 2021-04-09T14:05:46.050128+00:00 2021-04-09T14:13:48.563954+00:00 0:08:02.513826 15306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T14:05:43.759850+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:05:26.093652+00:00 2021-04-09T14:05:27.941974+00:00 0:00:01.848322 15305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T14:05:23.750979+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T13:05:00+00:00 PythonOperator 2021-04-09T14:05:03.855362+00:00 2021-04-09T14:05:06.550481+00:00 0:00:02.695119 15304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:05:01.711163+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T13:00:00+00:00 EmrJobFlowSensor 2021-04-09T14:00:57.513969+00:00 2021-04-09T14:11:00.290016+00:00 0:10:02.776047 15303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T14:00:55.299743+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T14:00:35.778543+00:00 2021-04-09T14:00:37.493871+00:00 0:00:01.715328 15302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T14:00:33.288842+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T13:00:00+00:00 PythonOperator 2021-04-09T14:00:13.617261+00:00 2021-04-09T14:00:16.512679+00:00 0:00:02.895418 15301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T14:00:11.220087+00:00 2 default_pool