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 booking-processing-job_v002 check_cluster_status 2021-04-10T16:00:00+00:00 EmrJobFlowSensor 2021-04-10T17:14:22.517817+00:00 2021-04-10T17:23:25.073095+00:00 0:09:02.555278 15720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:14:20.167687+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T16:00:00+00:00 EmrJobFlowSensor 2021-04-10T17:14:16.403936+00:00 2021-04-10T17:23:19.111611+00:00 0:09:02.707675 15719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:14:14.182460+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:14:00.662021+00:00 2021-04-10T17:14:02.433880+00:00 0:00:01.771859 15718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T17:13:58.160359+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:13:56.292572+00:00 2021-04-10T17:13:58.189341+00:00 0:00:01.896769 15717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T17:13:54.145347+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T16:00:00+00:00 PythonOperator 2021-04-10T17:13:40.373197+00:00 2021-04-10T17:13:43.543766+00:00 0:00:03.170569 15716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:13:38.080236+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T16:00:00+00:00 PythonOperator 2021-04-10T17:13:34.329081+00:00 2021-04-10T17:13:37.171778+00:00 0:00:02.842697 15715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:13:32.017134+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T16:00:00+00:00 TriggerDagRunOperator 2021-04-10T17:13:14.853194+00:00 2021-04-10T17:13:15.361525+00:00 0:00:00.508331 15714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:13:12.005688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T16:00:00+00:00 TriggerDagRunOperator 2021-04-10T17:13:14.618183+00:00 2021-04-10T17:13:15.060498+00:00 0:00:00.442315 15713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:13:12.005658+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T16:05:00+00:00 EmrJobFlowSensor 2021-04-10T17:06:17.406416+00:00 2021-04-10T17:14:19.896419+00:00 0:08:02.490003 15711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:06:15.085676+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:05:57.394892+00:00 2021-04-10T17:05:59.183504+00:00 0:00:01.788612 15710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T17:05:55.060255+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T16:05:00+00:00 PythonOperator 2021-04-10T17:05:27.166514+00:00 2021-04-10T17:05:29.829670+00:00 0:00:02.663156 15709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:05:25.035561+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T16:00:00+00:00 EmrJobFlowSensor 2021-04-10T17:00:48.748518+00:00 2021-04-10T17:10:51.491597+00:00 0:10:02.743079 15708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:00:46.503100+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:00:26.928107+00:00 2021-04-10T17:00:28.599832+00:00 0:00:01.671725 15707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T17:00:24.556319+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T16:00:00+00:00 PythonOperator 2021-04-10T17:00:04.643517+00:00 2021-04-10T17:00:07.347628+00:00 0:00:02.704111 15706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T17:00:02.455321+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T15:00:00+00:00 EmrJobFlowSensor 2021-04-10T16:12:16.019095+00:00 2021-04-10T16:21:18.839445+00:00 0:09:02.820350 15705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:12:13.745525+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T15:00:00+00:00 EmrJobFlowSensor 2021-04-10T16:11:56.067264+00:00 2021-04-10T16:21:59.013264+00:00 0:10:02.946000 15704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:11:53.447135+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:11:55.908865+00:00 2021-04-10T16:11:57.591355+00:00 0:00:01.682490 15703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T16:11:53.447164+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:11:35.960786+00:00 2021-04-10T16:11:37.621250+00:00 0:00:01.660464 15702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T16:11:33.334420+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T15:00:00+00:00 PythonOperator 2021-04-10T16:11:33.567847+00:00 2021-04-10T16:11:36.695423+00:00 0:00:03.127576 15701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:11:31.333522+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T15:00:00+00:00 PythonOperator 2021-04-10T16:11:13.595352+00:00 2021-04-10T16:11:16.549464+00:00 0:00:02.954112 15700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:11:11.318219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T15:00:00+00:00 TriggerDagRunOperator 2021-04-10T16:11:08.225174+00:00 2021-04-10T16:11:08.767249+00:00 0:00:00.542075 15699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:11:05.313336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T15:00:00+00:00 TriggerDagRunOperator 2021-04-10T16:11:07.740188+00:00 2021-04-10T16:11:08.189195+00:00 0:00:00.449007 15698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:11:05.313287+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T15:05:00+00:00 EmrJobFlowSensor 2021-04-10T16:07:29.395484+00:00 2021-04-10T16:16:31.986875+00:00 0:09:02.591391 15697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:07:27.101061+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:07:07.210032+00:00 2021-04-10T16:07:08.860389+00:00 0:00:01.650357 15696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T16:07:05.075762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T15:05:00+00:00 PythonOperator 2021-04-10T16:06:47.545830+00:00 2021-04-10T16:06:50.224754+00:00 0:00:02.678924 15695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:06:45.087127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T15:00:00+00:00 EmrJobFlowSensor 2021-04-10T16:00:53.549043+00:00 2021-04-10T16:10:56.870021+00:00 0:10:03.320978 15693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:00:51.099628+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:00:31.651412+00:00 2021-04-10T16:00:33.375290+00:00 0:00:01.723878 15692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T16:00:29.242502+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T15:00:00+00:00 PythonOperator 2021-04-10T16:00:11.164200+00:00 2021-04-10T16:00:13.946956+00:00 0:00:02.782756 15691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T16:00:08.970745+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T14:00:00+00:00 EmrJobFlowSensor 2021-04-10T15:22:10.029534+00:00 2021-04-10T15:32:12.808372+00:00 0:10:02.778838 15690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:22:07.560392+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T14:00:00+00:00 EmrJobFlowSensor 2021-04-10T15:22:08.177196+00:00 2021-04-10T15:31:10.998624+00:00 0:09:02.821428 15689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:22:05.486953+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:21:49.874688+00:00 2021-04-10T15:21:51.548906+00:00 0:00:01.674218 15688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T15:21:47.457340+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:21:45.763291+00:00 2021-04-10T15:21:47.711186+00:00 0:00:01.947895 15687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T15:21:43.377953+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T14:00:00+00:00 PythonOperator 2021-04-10T15:21:27.611149+00:00 2021-04-10T15:21:30.722741+00:00 0:00:03.111592 15686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:21:25.357360+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T14:00:00+00:00 PythonOperator 2021-04-10T15:21:25.792173+00:00 2021-04-10T15:21:28.508205+00:00 0:00:02.716032 15685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:21:23.357411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T14:00:00+00:00 TriggerDagRunOperator 2021-04-10T15:21:07.774786+00:00 2021-04-10T15:21:08.582422+00:00 0:00:00.807636 15684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:21:05.341938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T14:00:00+00:00 TriggerDagRunOperator 2021-04-10T15:21:07.597298+00:00 2021-04-10T15:21:07.998273+00:00 0:00:00.400975 15683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:21:05.341972+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T14:05:00+00:00 EmrJobFlowSensor 2021-04-10T15:06:11.744386+00:00 2021-04-10T15:15:14.352711+00:00 0:09:02.608325 15682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:06:09.572027+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:05:49.784397+00:00 2021-04-10T15:05:51.512642+00:00 0:00:01.728245 15681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T15:05:47.506559+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T14:05:00+00:00 PythonOperator 2021-04-10T15:05:30.094679+00:00 2021-04-10T15:05:32.869126+00:00 0:00:02.774447 15680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:05:27.558382+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T14:00:00+00:00 EmrJobFlowSensor 2021-04-10T15:00:56.134882+00:00 2021-04-10T15:21:00.301778+00:00 0:20:04.166896 15678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:00:53.622001+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:00:34.104440+00:00 2021-04-10T15:00:35.977618+00:00 0:00:01.873178 15677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T15:00:31.672151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T14:00:00+00:00 PythonOperator 2021-04-10T15:00:11.856400+00:00 2021-04-10T15:00:14.588193+00:00 0:00:02.731793 15676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T15:00:09.592707+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T13:00:00+00:00 EmrJobFlowSensor 2021-04-10T14:12:20.804524+00:00 2021-04-10T14:21:23.375986+00:00 0:09:02.571462 15675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:12:18.451533+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T13:00:00+00:00 EmrJobFlowSensor 2021-04-10T14:12:14.672559+00:00 2021-04-10T14:22:17.426650+00:00 0:10:02.754091 15674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:12:12.429866+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:11:54.956509+00:00 2021-04-10T14:11:56.657582+00:00 0:00:01.701073 15673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T14:11:52.479110+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:11:50.712144+00:00 2021-04-10T14:11:52.412562+00:00 0:00:01.700418 15672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T14:11:48.285798+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T13:00:00+00:00 PythonOperator 2021-04-10T14:11:32.995689+00:00 2021-04-10T14:11:36.164323+00:00 0:00:03.168634 15671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:11:30.269909+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T13:00:00+00:00 PythonOperator 2021-04-10T14:11:28.746150+00:00 2021-04-10T14:11:31.608794+00:00 0:00:02.862644 15670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:11:26.206604+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T13:00:00+00:00 TriggerDagRunOperator 2021-04-10T14:11:16.813621+00:00 2021-04-10T14:11:17.207227+00:00 0:00:00.393606 15669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:11:14.195419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T13:00:00+00:00 TriggerDagRunOperator 2021-04-10T14:11:16.481383+00:00 2021-04-10T14:11:17.005036+00:00 0:00:00.523653 15668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:11:14.195384+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T13:05:00+00:00 EmrJobFlowSensor 2021-04-10T14:06:13.789822+00:00 2021-04-10T14:15:16.354352+00:00 0:09:02.564530 15667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:06:11.602733+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:05:47.995970+00:00 2021-04-10T14:05:49.780397+00:00 0:00:01.784427 15666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T14:05:45.655297+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T13:05:00+00:00 PythonOperator 2021-04-10T14:05:25.974225+00:00 2021-04-10T14:05:28.660883+00:00 0:00:02.686658 15665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:05:23.641676+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T13:00:00+00:00 EmrJobFlowSensor 2021-04-10T14:00:55.232116+00:00 2021-04-10T14:10:57.969957+00:00 0:10:02.737841 15663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:00:52.827363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:00:33.210760+00:00 2021-04-10T14:00:35.424645+00:00 0:00:02.213885 15662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T14:00:30.810052+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T13:00:00+00:00 PythonOperator 2021-04-10T14:00:10.957620+00:00 2021-04-10T14:00:13.903831+00:00 0:00:02.946211 15661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T14:00:08.789265+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T12:00:00+00:00 EmrJobFlowSensor 2021-04-10T13:11:52.512739+00:00 2021-04-10T13:20:55.221010+00:00 0:09:02.708271 15660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:11:50.140173+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T12:00:00+00:00 EmrJobFlowSensor 2021-04-10T13:11:52.434557+00:00 2021-04-10T13:21:55.185871+00:00 0:10:02.751314 15659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:11:50.140209+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T13:11:30.749541+00:00 2021-04-10T13:11:32.518761+00:00 0:00:01.769220 15658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T13:11:28.140739+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T13:11:30.585994+00:00 2021-04-10T13:11:32.523340+00:00 0:00:01.937346 15657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T13:11:28.140785+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T12:00:00+00:00 PythonOperator 2021-04-10T13:11:09.001262+00:00 2021-04-10T13:11:11.797223+00:00 0:00:02.795961 15656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T13:11:06.167707+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T12:00:00+00:00 PythonOperator 2021-04-10T13:11:08.598089+00:00 2021-04-10T13:11:11.604169+00:00 0:00:03.006080 15655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T13:11:06.167655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T12:00:00+00:00 TriggerDagRunOperator 2021-04-10T13:10:46.692824+00:00 2021-04-10T13:10:47.193515+00:00 0:00:00.500691 15654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:10:44.163629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T12:00:00+00:00 TriggerDagRunOperator 2021-04-10T13:10:46.536448+00:00 2021-04-10T13:10:46.963731+00:00 0:00:00.427283 15653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:10:44.163594+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T12:05:00+00:00 EmrJobFlowSensor 2021-04-10T13:05:51.678974+00:00 2021-04-10T13:14:54.333131+00:00 0:09:02.654157 15652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:05:49.527181+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T13:05:29.850093+00:00 2021-04-10T13:05:31.584958+00:00 0:00:01.734865 15651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T13:05:27.506328+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T12:05:00+00:00 PythonOperator 2021-04-10T13:05:07.586956+00:00 2021-04-10T13:05:10.274959+00:00 0:00:02.688003 15650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T13:05:05.493851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T12:00:00+00:00 EmrJobFlowSensor 2021-04-10T13:02:25.862806+00:00 2021-04-10T13:10:28.405756+00:00 0:08:02.542950 15649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T13:02:23.259416+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T13:00:44.934079+00:00 2021-04-10T13:00:46.674296+00:00 0:00:01.740217 15647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T13:00:42.694469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T12:00:00+00:00 PythonOperator 2021-04-10T13:00:25.030808+00:00 2021-04-10T13:00:27.738911+00:00 0:00:02.708103 15646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T13:00:22.628841+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T11:00:00+00:00 EmrJobFlowSensor 2021-04-10T12:12:50.250862+00:00 2021-04-10T12:22:53.075131+00:00 0:10:02.824269 15645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T12:12:47.808151+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T11:00:00+00:00 EmrJobFlowSensor 2021-04-10T12:12:50.031480+00:00 2021-04-10T12:22:52.770675+00:00 0:10:02.739195 15644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T12:12:47.808119+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T12:12:30.601840+00:00 2021-04-10T12:12:32.303207+00:00 0:00:01.701367 15643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T12:12:27.855392+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T12:12:28.064820+00:00 2021-04-10T12:12:30.221392+00:00 0:00:02.156572 15642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T12:12:25.846214+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T11:00:00+00:00 PythonOperator 2021-04-10T12:12:08.651163+00:00 2021-04-10T12:12:11.615564+00:00 0:00:02.964401 15641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T12:12:05.742322+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T11:00:00+00:00 PythonOperator 2021-04-10T12:12:06.105699+00:00 2021-04-10T12:12:09.315693+00:00 0:00:03.209994 15640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T12:12:03.746177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T11:00:00+00:00 TriggerDagRunOperator 2021-04-10T12:12:00.235252+00:00 2021-04-10T12:12:00.829518+00:00 0:00:00.594266 15639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T12:11:57.751379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T11:00:00+00:00 TriggerDagRunOperator 2021-04-10T12:12:00.105737+00:00 2021-04-10T12:12:00.550969+00:00 0:00:00.445232 15638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T12:11:57.751348+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T11:05:00+00:00 EmrJobFlowSensor 2021-04-10T12:06:03.456515+00:00 2021-04-10T12:14:05.961905+00:00 0:08:02.505390 15637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T12:06:01.222156+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T12:05:39.764469+00:00 2021-04-10T12:05:41.505587+00:00 0:00:01.741118 15636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T12:05:37.265599+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T11:05:00+00:00 PythonOperator 2021-04-10T12:05:19.598372+00:00 2021-04-10T12:05:22.466864+00:00 0:00:02.868492 15635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T12:05:17.246704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T11:00:00+00:00 EmrJobFlowSensor 2021-04-10T12:01:39.028002+00:00 2021-04-10T12:11:41.744218+00:00 0:10:02.716216 15634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T12:01:36.886327+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T12:01:19.304098+00:00 2021-04-10T12:01:21.113667+00:00 0:00:01.809569 15633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T12:01:16.868671+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T11:00:00+00:00 PythonOperator 2021-04-10T12:00:19.825667+00:00 2021-04-10T12:00:22.697488+00:00 0:00:02.871821 15631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T12:00:17.359888+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T10:00:00+00:00 EmrJobFlowSensor 2021-04-10T11:12:56.738214+00:00 2021-04-10T11:20:59.364594+00:00 0:08:02.626380 15630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:12:54.443571+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T10:00:00+00:00 EmrJobFlowSensor 2021-04-10T11:12:38.727054+00:00 2021-04-10T11:21:41.328078+00:00 0:09:02.601024 15629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:12:36.335958+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:12:36.717019+00:00 2021-04-10T11:12:38.574020+00:00 0:00:01.857001 15628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T11:12:34.335008+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:12:16.621393+00:00 2021-04-10T11:12:18.352016+00:00 0:00:01.730623 15627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T11:12:14.319934+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T10:00:00+00:00 PythonOperator 2021-04-10T11:12:12.542738+00:00 2021-04-10T11:12:15.406618+00:00 0:00:02.863880 15626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:12:10.316617+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T10:00:00+00:00 PythonOperator 2021-04-10T11:11:56.684735+00:00 2021-04-10T11:12:00.089132+00:00 0:00:03.404397 15625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:11:54.305451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T10:00:00+00:00 TriggerDagRunOperator 2021-04-10T11:11:51.006556+00:00 2021-04-10T11:11:51.446509+00:00 0:00:00.439953 15624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:11:48.366693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T10:00:00+00:00 TriggerDagRunOperator 2021-04-10T11:11:50.860654+00:00 2021-04-10T11:11:51.388044+00:00 0:00:00.527390 15623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:11:48.366743+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T10:05:00+00:00 EmrJobFlowSensor 2021-04-10T11:05:50.016223+00:00 2021-04-10T11:14:52.700799+00:00 0:09:02.684576 15622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:05:47.643356+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:05:29.861410+00:00 2021-04-10T11:05:31.507067+00:00 0:00:01.645657 15621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T11:05:27.643495+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T10:05:00+00:00 PythonOperator 2021-04-10T11:05:07.828220+00:00 2021-04-10T11:05:10.594232+00:00 0:00:02.766012 15620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:05:05.605834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T10:00:00+00:00 EmrJobFlowSensor 2021-04-10T11:01:27.597398+00:00 2021-04-10T11:11:30.365183+00:00 0:10:02.767785 15619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:01:25.313672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:01:07.539030+00:00 2021-04-10T11:01:09.380376+00:00 0:00:01.841346 15618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T11:01:05.296172+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T10:00:00+00:00 PythonOperator 2021-04-10T11:00:45.956974+00:00 2021-04-10T11:00:48.838144+00:00 0:00:02.881170 15617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T11:00:43.284350+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T09:00:00+00:00 EmrJobFlowSensor 2021-04-10T10:12:20.305671+00:00 2021-04-10T10:22:23.231446+00:00 0:10:02.925775 15615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:12:18.059749+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T09:00:00+00:00 EmrJobFlowSensor 2021-04-10T10:12:18.255132+00:00 2021-04-10T10:23:21.203357+00:00 0:11:02.948225 15614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:12:16.058384+00:00 2 default_pool