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 check_cluster_status 2021-04-18T03:00:00+00:00 EmrJobFlowSensor 2021-04-18T04:00:56.649434+00:00 2021-04-18T04:09:59.407542+00:00 0:09:02.758108 18414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T04:00:54.252541+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T04:00:36.390417+00:00 2021-04-18T04:00:38.743451+00:00 0:00:02.353034 18413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T04:00:34.190369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T03:00:00+00:00 PythonOperator 2021-04-18T04:00:14.446849+00:00 2021-04-18T04:00:17.350172+00:00 0:00:02.903323 18412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T04:00:12.105924+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T02:00:00+00:00 EmrJobFlowSensor 2021-04-18T03:12:24.401071+00:00 2021-04-18T03:22:27.323582+00:00 0:10:02.922511 18410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T03:12:21.984683+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T02:00:00+00:00 EmrJobFlowSensor 2021-04-18T03:12:10.490610+00:00 2021-04-18T03:22:13.360546+00:00 0:10:02.869936 18409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T03:12:07.890875+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T03:12:02.404236+00:00 2021-04-18T03:12:04.212027+00:00 0:00:01.807791 18408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T03:11:59.960143+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T03:11:48.116869+00:00 2021-04-18T03:11:49.756112+00:00 0:00:01.639243 18407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T03:11:45.825394+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T02:00:00+00:00 PythonOperator 2021-04-18T03:11:40.055716+00:00 2021-04-18T03:11:43.145414+00:00 0:00:03.089698 18406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T03:11:37.814527+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T02:00:00+00:00 PythonOperator 2021-04-18T03:11:26.113399+00:00 2021-04-18T03:11:29.252826+00:00 0:00:03.139427 18405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T03:11:23.805345+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T02:00:00+00:00 TriggerDagRunOperator 2021-04-18T03:11:18.133188+00:00 2021-04-18T03:11:18.699761+00:00 0:00:00.566573 18404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T03:11:15.799296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T02:00:00+00:00 TriggerDagRunOperator 2021-04-18T03:11:17.997222+00:00 2021-04-18T03:11:18.451554+00:00 0:00:00.454332 18403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T03:11:15.799330+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T02:05:00+00:00 EmrJobFlowSensor 2021-04-18T03:05:57.489660+00:00 2021-04-18T03:15:00.296487+00:00 0:09:02.806827 18402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T03:05:55.100365+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T03:05:35.319153+00:00 2021-04-18T03:05:36.976751+00:00 0:00:01.657598 18401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T03:05:33.062079+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T02:05:00+00:00 PythonOperator 2021-04-18T03:05:13.219121+00:00 2021-04-18T03:05:16.114960+00:00 0:00:02.895839 18400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T03:05:11.018113+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T02:00:00+00:00 EmrJobFlowSensor 2021-04-18T03:01:50.803571+00:00 2021-04-18T03:10:53.519462+00:00 0:09:02.715891 18399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T03:01:48.631260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T03:01:28.913359+00:00 2021-04-18T03:01:30.713189+00:00 0:00:01.799830 18398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T03:01:26.614061+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T02:00:00+00:00 PythonOperator 2021-04-18T03:01:09.201110+00:00 2021-04-18T03:01:12.505663+00:00 0:00:03.304553 18397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T03:01:06.659808+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T01:00:00+00:00 EmrJobFlowSensor 2021-04-18T02:10:40.916607+00:00 2021-04-18T02:19:43.623305+00:00 0:09:02.706698 18395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T02:10:38.689556+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T01:00:00+00:00 EmrJobFlowSensor 2021-04-18T02:10:23.081728+00:00 2021-04-18T02:20:25.882203+00:00 0:10:02.800475 18394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T02:10:20.627576+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T02:10:11.096478+00:00 2021-04-18T02:10:12.830867+00:00 0:00:01.734389 18393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T02:10:08.612393+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T02:09:59.105765+00:00 2021-04-18T02:10:00.774663+00:00 0:00:01.668898 18392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T02:09:56.668628+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T01:00:00+00:00 PythonOperator 2021-04-18T02:09:48.871410+00:00 2021-04-18T02:09:52.232074+00:00 0:00:03.360664 18391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T02:09:46.593721+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T01:00:00+00:00 PythonOperator 2021-04-18T02:09:38.911605+00:00 2021-04-18T02:09:41.794864+00:00 0:00:02.883259 18390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T02:09:36.643633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T01:00:00+00:00 TriggerDagRunOperator 2021-04-18T02:09:25.247781+00:00 2021-04-18T02:09:25.753801+00:00 0:00:00.506020 18389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T02:09:22.543673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T01:00:00+00:00 TriggerDagRunOperator 2021-04-18T02:09:24.830967+00:00 2021-04-18T02:09:25.307043+00:00 0:00:00.476076 18388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T02:09:22.543625+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T01:05:00+00:00 EmrJobFlowSensor 2021-04-18T02:05:48.580079+00:00 2021-04-18T02:14:51.124524+00:00 0:09:02.544445 18387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T02:05:46.189720+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T02:05:28.293004+00:00 2021-04-18T02:05:29.958002+00:00 0:00:01.664998 18386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T02:05:26.106878+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T01:05:00+00:00 PythonOperator 2021-04-18T02:05:06.172813+00:00 2021-04-18T02:05:09.275364+00:00 0:00:03.102551 18385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T02:05:04.088895+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T01:00:00+00:00 EmrJobFlowSensor 2021-04-18T02:01:11.954804+00:00 2021-04-18T02:09:14.656836+00:00 0:08:02.702032 18384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T02:01:09.623518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T02:00:49.792247+00:00 2021-04-18T02:00:51.546896+00:00 0:00:01.754649 18383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T02:00:47.603334+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T01:00:00+00:00 PythonOperator 2021-04-18T02:00:25.893612+00:00 2021-04-18T02:00:29.083342+00:00 0:00:03.189730 18382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T02:00:23.578833+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T00:00:00+00:00 EmrJobFlowSensor 2021-04-18T01:12:04.896047+00:00 2021-04-18T01:30:08.655365+00:00 0:18:03.759318 18380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T01:12:02.108031+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T00:00:00+00:00 EmrJobFlowSensor 2021-04-18T01:11:56.287271+00:00 2021-04-18T01:21:59.290456+00:00 0:10:03.003185 18379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T01:11:54.102288+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T01:11:42.556247+00:00 2021-04-18T01:11:44.359113+00:00 0:00:01.802866 18378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T01:11:40.090367+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T01:11:34.542199+00:00 2021-04-18T01:11:36.800788+00:00 0:00:02.258589 18377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T01:11:32.152874+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T00:00:00+00:00 PythonOperator 2021-04-18T01:11:20.735218+00:00 2021-04-18T01:11:23.679924+00:00 0:00:02.944706 18376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T01:11:18.018550+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T00:00:00+00:00 PythonOperator 2021-04-18T01:11:12.445250+00:00 2021-04-18T01:11:15.611255+00:00 0:00:03.166005 18375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T01:11:10.055549+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T00:00:00+00:00 TriggerDagRunOperator 2021-04-18T01:11:08.504444+00:00 2021-04-18T01:11:09.057918+00:00 0:00:00.553474 18374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T01:11:05.983077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T00:00:00+00:00 TriggerDagRunOperator 2021-04-18T01:11:08.235045+00:00 2021-04-18T01:11:08.735223+00:00 0:00:00.500178 18373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T01:11:05.983035+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T00:05:00+00:00 EmrJobFlowSensor 2021-04-18T01:05:49.744674+00:00 2021-04-18T01:14:52.353297+00:00 0:09:02.608623 18372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T01:05:47.377843+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T01:05:29.877350+00:00 2021-04-18T01:05:32.034416+00:00 0:00:02.157066 18371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T01:05:27.279967+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T00:05:00+00:00 PythonOperator 2021-04-18T01:05:07.577370+00:00 2021-04-18T01:05:10.661556+00:00 0:00:03.084186 18370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T01:05:05.260443+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T00:00:00+00:00 EmrJobFlowSensor 2021-04-18T01:01:01.201192+00:00 2021-04-18T01:11:04.086986+00:00 0:10:02.885794 18369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T01:00:58.775260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T01:00:39.135555+00:00 2021-04-18T01:00:40.889550+00:00 0:00:01.753995 18368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T01:00:36.752071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T00:00:00+00:00 PythonOperator 2021-04-18T01:00:16.938013+00:00 2021-04-18T01:00:19.960740+00:00 0:00:03.022727 18367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T01:00:14.600206+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T23:00:00+00:00 EmrJobFlowSensor 2021-04-18T00:10:15.178942+00:00 2021-04-18T00:20:17.906608+00:00 0:10:02.727666 18365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T00:10:12.948110+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T23:00:00+00:00 EmrJobFlowSensor 2021-04-18T00:09:57.140036+00:00 2021-04-18T00:18:59.801283+00:00 0:09:02.661247 18364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T00:09:54.905784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T00:09:55.396431+00:00 2021-04-18T00:09:57.197530+00:00 0:00:01.801099 18363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T00:09:52.965812+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T00:09:37.111222+00:00 2021-04-18T00:09:38.782173+00:00 0:00:01.670951 18362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T00:09:34.885380+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T23:00:00+00:00 PythonOperator 2021-04-18T00:09:33.332714+00:00 2021-04-18T00:09:36.938244+00:00 0:00:03.605530 18361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T00:09:30.951325+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T23:00:00+00:00 PythonOperator 2021-04-18T00:09:14.920449+00:00 2021-04-18T00:09:17.836357+00:00 0:00:02.915908 18360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T00:09:12.752410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T23:00:00+00:00 TriggerDagRunOperator 2021-04-18T00:09:11.092538+00:00 2021-04-18T00:09:11.631004+00:00 0:00:00.538466 18359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T00:09:08.752846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T23:00:00+00:00 TriggerDagRunOperator 2021-04-18T00:09:10.982279+00:00 2021-04-18T00:09:11.433317+00:00 0:00:00.451038 18358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T00:09:08.752880+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T23:05:00+00:00 EmrJobFlowSensor 2021-04-18T00:06:00.740012+00:00 2021-04-18T00:15:03.322561+00:00 0:09:02.582549 18357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T00:05:58.464300+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T00:05:40.460434+00:00 2021-04-18T00:05:42.083155+00:00 0:00:01.622721 18356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T00:05:38.293721+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T23:05:00+00:00 PythonOperator 2021-04-18T00:05:10.475221+00:00 2021-04-18T00:05:13.367877+00:00 0:00:02.892656 18355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T00:05:08.266454+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T23:00:00+00:00 EmrJobFlowSensor 2021-04-18T00:00:48.288325+00:00 2021-04-18T00:08:51.023960+00:00 0:08:02.735635 18354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T00:00:45.905175+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T00:00:26.082452+00:00 2021-04-18T00:00:27.788818+00:00 0:00:01.706366 18353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T00:00:23.887055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T23:00:00+00:00 PythonOperator 2021-04-18T00:00:06.362664+00:00 2021-04-18T00:00:09.605692+00:00 0:00:03.243028 18352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T00:00:03.817564+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T22:00:00+00:00 EmrJobFlowSensor 2021-04-17T23:25:52.984124+00:00 2021-04-17T23:25:54.840997+00:00 0:00:01.856873 18350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T23:25:50.708913+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T22:00:00+00:00 EmrJobFlowSensor 2021-04-17T23:11:15.486552+00:00 2021-04-17T23:19:17.973059+00:00 0:08:02.486507 18348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T23:11:13.097500+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T23:11:07.791153+00:00 2021-04-17T23:11:09.538601+00:00 0:00:01.747448 18347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T23:11:05.096441+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T23:10:53.243257+00:00 2021-04-17T23:10:54.972222+00:00 0:00:01.728965 18346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T23:10:51.003195+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T22:00:00+00:00 PythonOperator 2021-04-17T23:10:43.934627+00:00 2021-04-17T23:10:47.262053+00:00 0:00:03.327426 18345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T23:10:41.062542+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T22:00:00+00:00 PythonOperator 2021-04-17T23:10:33.596476+00:00 2021-04-17T23:10:36.562539+00:00 0:00:02.966063 18344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T23:10:30.984901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T22:00:00+00:00 TriggerDagRunOperator 2021-04-17T23:10:21.633085+00:00 2021-04-17T23:10:22.064064+00:00 0:00:00.430979 18343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T23:10:19.061384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T22:00:00+00:00 TriggerDagRunOperator 2021-04-17T23:10:21.513118+00:00 2021-04-17T23:10:22.080285+00:00 0:00:00.567167 18342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T23:10:19.061416+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T22:05:00+00:00 EmrJobFlowSensor 2021-04-17T23:06:14.819375+00:00 2021-04-17T23:15:17.354052+00:00 0:09:02.534677 18341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T23:06:12.521955+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T23:05:52.781335+00:00 2021-04-17T23:05:54.459647+00:00 0:00:01.678312 18340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T23:05:50.565146+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T22:05:00+00:00 PythonOperator 2021-04-17T23:05:26.743118+00:00 2021-04-17T23:05:29.873556+00:00 0:00:03.130438 18339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T23:05:24.441017+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T22:00:00+00:00 EmrJobFlowSensor 2021-04-17T23:01:14.426352+00:00 2021-04-17T23:10:17.123566+00:00 0:09:02.697214 18338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T23:01:12.057561+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T23:00:44.362971+00:00 2021-04-17T23:00:46.178089+00:00 0:00:01.815118 18337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T23:00:41.947729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T22:00:00+00:00 PythonOperator 2021-04-17T23:00:20.585486+00:00 2021-04-17T23:00:23.501012+00:00 0:00:02.915526 18336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T23:00:17.852012+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T21:00:00+00:00 EmrJobFlowSensor 2021-04-17T22:11:12.039267+00:00 2021-04-17T22:21:14.807039+00:00 0:10:02.767772 18334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:11:09.806053+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T21:00:00+00:00 EmrJobFlowSensor 2021-04-17T22:11:12.074407+00:00 2021-04-17T22:21:15.107040+00:00 0:10:03.032633 18333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:11:09.806087+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T22:10:52.681458+00:00 2021-04-17T22:10:54.312934+00:00 0:00:01.631476 18332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T22:10:49.789086+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T22:10:50.223313+00:00 2021-04-17T22:10:52.627849+00:00 0:00:02.404536 18331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T22:10:47.796520+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T21:00:00+00:00 PythonOperator 2021-04-17T22:10:30.335836+00:00 2021-04-17T22:10:33.274457+00:00 0:00:02.938621 18330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T22:10:27.762261+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T21:00:00+00:00 PythonOperator 2021-04-17T22:10:28.660133+00:00 2021-04-17T22:10:31.938217+00:00 0:00:03.278084 18329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T22:10:25.845622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T21:00:00+00:00 TriggerDagRunOperator 2021-04-17T22:10:20.289612+00:00 2021-04-17T22:10:20.811499+00:00 0:00:00.521887 18328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:10:17.779301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T21:00:00+00:00 TriggerDagRunOperator 2021-04-17T22:10:20.095862+00:00 2021-04-17T22:10:20.509912+00:00 0:00:00.414050 18327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:10:17.779345+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T21:05:00+00:00 EmrJobFlowSensor 2021-04-17T22:05:59.417005+00:00 2021-04-17T22:15:02.012842+00:00 0:09:02.595837 18326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:05:57.293537+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T22:05:39.569055+00:00 2021-04-17T22:05:41.324137+00:00 0:00:01.755082 18325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T22:05:37.267275+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T21:05:00+00:00 PythonOperator 2021-04-17T22:05:17.371768+00:00 2021-04-17T22:05:20.289638+00:00 0:00:02.917870 18324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T22:05:15.237864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T21:00:00+00:00 EmrJobFlowSensor 2021-04-17T22:01:03.123502+00:00 2021-04-17T22:10:05.807264+00:00 0:09:02.683762 18323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T22:01:00.642421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T22:00:40.792746+00:00 2021-04-17T22:00:42.493618+00:00 0:00:01.700872 18322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T22:00:38.622435+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T21:00:00+00:00 PythonOperator 2021-04-17T22:00:21.316220+00:00 2021-04-17T22:00:24.253279+00:00 0:00:02.937059 18321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T22:00:18.598072+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T20:00:00+00:00 EmrJobFlowSensor 2021-04-17T21:10:41.210324+00:00 2021-04-17T21:20:44.720803+00:00 0:10:03.510479 18319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:10:38.961687+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T20:00:00+00:00 EmrJobFlowSensor 2021-04-17T21:10:33.689070+00:00 2021-04-17T21:20:36.432184+00:00 0:10:02.743114 18318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:10:30.968463+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T21:10:17.301626+00:00 2021-04-17T21:10:19.575517+00:00 0:00:02.273891 18317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T21:10:14.966123+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T21:10:11.293572+00:00 2021-04-17T21:10:13.392308+00:00 0:00:02.098736 18316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T21:10:08.966575+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T20:00:00+00:00 PythonOperator 2021-04-17T21:09:57.428639+00:00 2021-04-17T21:10:00.571074+00:00 0:00:03.142435 18315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T21:09:54.890625+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T20:00:00+00:00 PythonOperator 2021-04-17T21:09:51.459691+00:00 2021-04-17T21:09:54.594358+00:00 0:00:03.134667 18314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T21:09:48.952726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T20:00:00+00:00 TriggerDagRunOperator 2021-04-17T21:09:35.313477+00:00 2021-04-17T21:09:35.883553+00:00 0:00:00.570076 18313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:09:32.858916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T20:00:00+00:00 TriggerDagRunOperator 2021-04-17T21:09:35.229538+00:00 2021-04-17T21:09:35.711067+00:00 0:00:00.481529 18312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:09:32.858958+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T20:05:00+00:00 EmrJobFlowSensor 2021-04-17T21:05:52.757903+00:00 2021-04-17T21:13:55.176304+00:00 0:08:02.418401 18311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:05:50.556850+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T21:05:30.873251+00:00 2021-04-17T21:05:32.557238+00:00 0:00:01.683987 18310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T21:05:28.645749+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T20:05:00+00:00 PythonOperator 2021-04-17T21:05:09.041487+00:00 2021-04-17T21:05:12.510199+00:00 0:00:03.468712 18309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T21:05:06.640758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T20:00:00+00:00 EmrJobFlowSensor 2021-04-17T21:01:10.304546+00:00 2021-04-17T21:09:13.211283+00:00 0:08:02.906737 18308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T21:01:08.107003+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T21:00:48.659759+00:00 2021-04-17T21:00:50.464142+00:00 0:00:01.804383 18307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T21:00:46.152348+00:00 2 default_pool