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-history-job_v002 check_cluster_status 2021-03-31T23:00:00+00:00 EmrJobFlowSensor 2021-04-01T00:12:08.633243+00:00 2021-04-01T00:30:12.495665+00:00 0:18:03.862422 12222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:12:06.163687+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T23:00:00+00:00 EmrJobFlowSensor 2021-04-01T00:11:54.376581+00:00 2021-04-01T00:21:57.182132+00:00 0:10:02.805551 12221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:11:52.090276+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:11:48.535624+00:00 2021-04-01T00:11:50.231053+00:00 0:00:01.695429 12220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T00:11:46.155418+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:11:34.531244+00:00 2021-04-01T00:11:36.343108+00:00 0:00:01.811864 12219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T00:11:32.048544+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T23:00:00+00:00 PythonOperator 2021-04-01T00:11:26.199669+00:00 2021-04-01T00:11:28.895572+00:00 0:00:02.695903 12218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:11:24.058255+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T23:00:00+00:00 PythonOperator 2021-04-01T00:11:12.270425+00:00 2021-04-01T00:11:15.333006+00:00 0:00:03.062581 12217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:11:10.036288+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T23:00:00+00:00 TriggerDagRunOperator 2021-04-01T00:11:06.735676+00:00 2021-04-01T00:11:07.234167+00:00 0:00:00.498491 12216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:11:04.030959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T23:00:00+00:00 TriggerDagRunOperator 2021-04-01T00:11:06.223634+00:00 2021-04-01T00:11:06.632401+00:00 0:00:00.408767 12215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:11:04.030992+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T23:05:00+00:00 EmrJobFlowSensor 2021-04-01T00:06:02.299061+00:00 2021-04-01T00:15:05.046866+00:00 0:09:02.747805 12214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:05:59.840697+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:05:40.065320+00:00 2021-04-01T00:05:41.725124+00:00 0:00:01.659804 12213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T00:05:37.687603+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T23:05:00+00:00 PythonOperator 2021-04-01T00:05:19.978566+00:00 2021-04-01T00:05:22.789336+00:00 0:00:02.810770 12212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:05:17.621895+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T23:00:00+00:00 EmrJobFlowSensor 2021-04-01T00:00:57.606862+00:00 2021-04-01T00:11:00.406859+00:00 0:10:02.799997 12211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:00:55.332367+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:00:37.637197+00:00 2021-04-01T00:00:39.454693+00:00 0:00:01.817496 12210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T00:00:35.315027+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T23:00:00+00:00 PythonOperator 2021-04-01T00:00:03.633240+00:00 2021-04-01T00:00:06.477073+00:00 0:00:02.843833 12209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T00:00:01.284056+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T22:00:00+00:00 EmrJobFlowSensor 2021-03-31T23:12:06.614245+00:00 2021-03-31T23:21:09.227682+00:00 0:09:02.613437 12207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:12:04.260325+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T22:00:00+00:00 EmrJobFlowSensor 2021-03-31T23:11:52.322077+00:00 2021-03-31T23:20:55.029324+00:00 0:09:02.707247 12206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:11:50.122946+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:11:44.438517+00:00 2021-03-31T23:11:46.261181+00:00 0:00:01.822664 12205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T23:11:42.117596+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:11:30.789364+00:00 2021-03-31T23:11:32.509985+00:00 0:00:01.720621 12204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T23:11:28.109958+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T22:00:00+00:00 PythonOperator 2021-03-31T23:11:22.496732+00:00 2021-03-31T23:11:25.454778+00:00 0:00:02.958046 12203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:11:20.153261+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T22:00:00+00:00 PythonOperator 2021-03-31T23:11:08.564891+00:00 2021-03-31T23:11:11.427203+00:00 0:00:02.862312 12202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:11:06.089903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T22:00:00+00:00 TriggerDagRunOperator 2021-03-31T23:11:02.571136+00:00 2021-03-31T23:11:03.288803+00:00 0:00:00.717667 12201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:11:00.093962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T22:00:00+00:00 TriggerDagRunOperator 2021-03-31T23:11:02.377303+00:00 2021-03-31T23:11:02.835053+00:00 0:00:00.457750 12200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:11:00.093928+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T22:05:00+00:00 EmrJobFlowSensor 2021-03-31T23:05:53.786735+00:00 2021-03-31T23:13:56.346977+00:00 0:08:02.560242 12199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:05:51.625268+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T22:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:05:31.779865+00:00 2021-03-31T23:05:33.572303+00:00 0:00:01.792438 12198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T23:05:29.607329+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T22:05:00+00:00 PythonOperator 2021-03-31T23:05:09.728476+00:00 2021-03-31T23:05:12.410886+00:00 0:00:02.682410 12197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:05:07.589975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T22:00:00+00:00 EmrJobFlowSensor 2021-03-31T23:00:49.411251+00:00 2021-03-31T23:10:52.390451+00:00 0:10:02.979200 12196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:00:47.030932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:00:27.294368+00:00 2021-03-31T23:00:29.107023+00:00 0:00:01.812655 12195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T23:00:25.006361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T22:00:00+00:00 PythonOperator 2021-03-31T23:00:07.289510+00:00 2021-03-31T23:00:10.040561+00:00 0:00:02.751051 12194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T23:00:04.987123+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T21:00:00+00:00 EmrJobFlowSensor 2021-03-31T22:12:26.890127+00:00 2021-03-31T22:22:29.728471+00:00 0:10:02.838344 12192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:12:24.618659+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T21:00:00+00:00 EmrJobFlowSensor 2021-03-31T22:12:18.794057+00:00 2021-03-31T22:20:21.304353+00:00 0:08:02.510296 12191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:12:16.611004+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:12:05.177284+00:00 2021-03-31T22:12:06.902374+00:00 0:00:01.725090 12190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T22:12:02.672546+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:11:57.097332+00:00 2021-03-31T22:11:58.814923+00:00 0:00:01.717591 12189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T22:11:54.602732+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T21:00:00+00:00 PythonOperator 2021-03-31T22:11:44.970531+00:00 2021-03-31T22:11:48.002864+00:00 0:00:03.032333 12188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:11:42.591265+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T21:00:00+00:00 PythonOperator 2021-03-31T22:11:36.840795+00:00 2021-03-31T22:11:39.842913+00:00 0:00:03.002118 12187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:11:34.538797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T21:00:00+00:00 TriggerDagRunOperator 2021-03-31T22:11:29.025081+00:00 2021-03-31T22:11:29.561027+00:00 0:00:00.535946 12186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:11:26.544800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T21:00:00+00:00 TriggerDagRunOperator 2021-03-31T22:11:28.888016+00:00 2021-03-31T22:11:29.300898+00:00 0:00:00.412882 12185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:11:26.544830+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T21:05:00+00:00 EmrJobFlowSensor 2021-03-31T22:06:02.371712+00:00 2021-03-31T22:15:05.043207+00:00 0:09:02.671495 12184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:06:00.153099+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T21:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:05:40.189423+00:00 2021-03-31T22:05:41.933880+00:00 0:00:01.744457 12183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T22:05:38.006528+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T21:05:00+00:00 PythonOperator 2021-03-31T22:05:20.255398+00:00 2021-03-31T22:05:23.032163+00:00 0:00:02.776765 12182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:05:17.990346+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T21:00:00+00:00 EmrJobFlowSensor 2021-03-31T22:00:53.807986+00:00 2021-03-31T22:10:56.640402+00:00 0:10:02.832416 12181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:00:51.633166+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:00:32.037765+00:00 2021-03-31T22:00:33.719758+00:00 0:00:01.681993 12180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T22:00:29.668714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T21:00:00+00:00 PythonOperator 2021-03-31T22:00:10.102942+00:00 2021-03-31T22:00:12.815788+00:00 0:00:02.712846 12179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T22:00:07.657862+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T20:00:00+00:00 EmrJobFlowSensor 2021-03-31T21:11:19.484060+00:00 2021-03-31T21:21:22.409348+00:00 0:10:02.925288 12177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:11:16.800631+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T20:00:00+00:00 EmrJobFlowSensor 2021-03-31T21:11:19.125314+00:00 2021-03-31T21:20:21.724783+00:00 0:09:02.599469 12176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:11:16.800663+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T21:10:57.355179+00:00 2021-03-31T21:10:59.192042+00:00 0:00:01.836863 12175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T21:10:54.785078+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T21:10:57.290923+00:00 2021-03-31T21:10:59.016920+00:00 0:00:01.725997 12174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T21:10:54.785050+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T20:00:00+00:00 PythonOperator 2021-03-31T21:10:37.456293+00:00 2021-03-31T21:10:40.389542+00:00 0:00:02.933249 12173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T21:10:34.771809+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T20:00:00+00:00 PythonOperator 2021-03-31T21:10:35.040516+00:00 2021-03-31T21:10:38.070384+00:00 0:00:03.029868 12172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T21:10:32.778231+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T20:00:00+00:00 TriggerDagRunOperator 2021-03-31T21:10:19.333237+00:00 2021-03-31T21:10:19.899079+00:00 0:00:00.565842 12171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:10:16.758123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T20:00:00+00:00 TriggerDagRunOperator 2021-03-31T21:10:19.260731+00:00 2021-03-31T21:10:19.681999+00:00 0:00:00.421268 12170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:10:16.758154+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T20:05:00+00:00 EmrJobFlowSensor 2021-03-31T21:06:06.577512+00:00 2021-03-31T21:14:09.051768+00:00 0:08:02.474256 12169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:06:04.367545+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T20:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T21:05:42.549474+00:00 2021-03-31T21:05:44.254900+00:00 0:00:01.705426 12168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T21:05:40.345538+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T20:05:00+00:00 PythonOperator 2021-03-31T21:05:20.567514+00:00 2021-03-31T21:05:23.299564+00:00 0:00:02.732050 12167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T21:05:18.325723+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T20:00:00+00:00 EmrJobFlowSensor 2021-03-31T21:01:08.258728+00:00 2021-03-31T21:10:11.012891+00:00 0:09:02.754163 12166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T21:01:06.042331+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T21:00:44.364334+00:00 2021-03-31T21:00:46.188465+00:00 0:00:01.824131 12165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T21:00:42.022541+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T20:00:00+00:00 PythonOperator 2021-03-31T21:00:20.405470+00:00 2021-03-31T21:00:23.174981+00:00 0:00:02.769511 12164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T21:00:18.008575+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T19:00:00+00:00 EmrJobFlowSensor 2021-03-31T20:11:11.421657+00:00 2021-03-31T20:20:14.160241+00:00 0:09:02.738584 12162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T20:11:09.089303+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T19:00:00+00:00 EmrJobFlowSensor 2021-03-31T20:11:11.437985+00:00 2021-03-31T20:21:14.343137+00:00 0:10:02.905152 12161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T20:11:09.089336+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T20:10:51.669012+00:00 2021-03-31T20:10:53.331266+00:00 0:00:01.662254 12160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T20:10:49.037020+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T20:10:49.302775+00:00 2021-03-31T20:10:51.312069+00:00 0:00:02.009294 12159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T20:10:47.036477+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T19:00:00+00:00 PythonOperator 2021-03-31T20:10:29.854567+00:00 2021-03-31T20:10:32.579130+00:00 0:00:02.724563 12158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T20:10:27.089850+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T19:00:00+00:00 PythonOperator 2021-03-31T20:10:27.411383+00:00 2021-03-31T20:10:30.684779+00:00 0:00:03.273396 12157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T20:10:25.070442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T19:00:00+00:00 TriggerDagRunOperator 2021-03-31T20:10:11.738250+00:00 2021-03-31T20:10:12.150430+00:00 0:00:00.412180 12156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T20:10:09.059219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T19:00:00+00:00 TriggerDagRunOperator 2021-03-31T20:10:11.523202+00:00 2021-03-31T20:10:12.037404+00:00 0:00:00.514202 12155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T20:10:09.059253+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T19:05:00+00:00 EmrJobFlowSensor 2021-03-31T20:06:06.728041+00:00 2021-03-31T20:14:09.230153+00:00 0:08:02.502112 12154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T20:06:04.531107+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T20:05:46.713067+00:00 2021-03-31T20:05:48.438350+00:00 0:00:01.725283 12153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T20:05:44.502133+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T19:05:00+00:00 PythonOperator 2021-03-31T20:05:24.607329+00:00 2021-03-31T20:05:27.297512+00:00 0:00:02.690183 12152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T20:05:22.456175+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T19:00:00+00:00 EmrJobFlowSensor 2021-03-31T20:00:58.387977+00:00 2021-03-31T20:10:01.083064+00:00 0:09:02.695087 12151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T20:00:56.106351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T20:00:36.270580+00:00 2021-03-31T20:00:37.993227+00:00 0:00:01.722647 12150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T20:00:34.085658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T19:00:00+00:00 PythonOperator 2021-03-31T20:00:14.559722+00:00 2021-03-31T20:00:17.276349+00:00 0:00:02.716627 12149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T20:00:12.030174+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T18:00:00+00:00 EmrJobFlowSensor 2021-03-31T19:12:23.249733+00:00 2021-03-31T19:21:25.986833+00:00 0:09:02.737100 12147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:12:20.816487+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T18:00:00+00:00 EmrJobFlowSensor 2021-03-31T19:12:13.023144+00:00 2021-03-31T19:23:15.906274+00:00 0:11:02.883130 12146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:12:10.808321+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:12:01.469986+00:00 2021-03-31T19:12:03.315032+00:00 0:00:01.845046 12145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T19:11:58.954107+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:11:51.015303+00:00 2021-03-31T19:11:52.815613+00:00 0:00:01.800310 12144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T19:11:48.787651+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T18:00:00+00:00 PythonOperator 2021-03-31T19:11:39.282917+00:00 2021-03-31T19:11:42.047124+00:00 0:00:02.764207 12143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:11:36.768202+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T18:00:00+00:00 PythonOperator 2021-03-31T19:11:29.012567+00:00 2021-03-31T19:11:31.961341+00:00 0:00:02.948774 12142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:11:26.729705+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T18:00:00+00:00 TriggerDagRunOperator 2021-03-31T19:11:15.270380+00:00 2021-03-31T19:11:15.817800+00:00 0:00:00.547420 12141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:11:12.779686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T18:00:00+00:00 TriggerDagRunOperator 2021-03-31T19:11:15.099605+00:00 2021-03-31T19:11:15.597340+00:00 0:00:00.497735 12140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:11:12.779653+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T18:05:00+00:00 EmrJobFlowSensor 2021-03-31T19:05:48.546549+00:00 2021-03-31T19:14:51.222462+00:00 0:09:02.675913 12139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:05:46.197262+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:05:28.369558+00:00 2021-03-31T19:05:30.032143+00:00 0:00:01.662585 12138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T19:05:26.170160+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T18:05:00+00:00 PythonOperator 2021-03-31T19:05:06.409059+00:00 2021-03-31T19:05:09.209503+00:00 0:00:02.800444 12137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:05:04.154741+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T18:00:00+00:00 EmrJobFlowSensor 2021-03-31T19:01:08.180643+00:00 2021-03-31T19:11:10.901757+00:00 0:10:02.721114 12136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:01:05.891890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:00:46.097055+00:00 2021-03-31T19:00:47.835019+00:00 0:00:01.737964 12135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T19:00:43.823206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T18:00:00+00:00 PythonOperator 2021-03-31T19:00:12.206489+00:00 2021-03-31T19:00:15.036559+00:00 0:00:02.830070 12134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T19:00:09.792104+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T17:00:00+00:00 EmrJobFlowSensor 2021-03-31T18:11:12.136212+00:00 2021-03-31T18:19:14.804396+00:00 0:08:02.668184 12132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:11:09.908665+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T17:00:00+00:00 EmrJobFlowSensor 2021-03-31T18:11:10.204665+00:00 2021-03-31T18:21:13.060333+00:00 0:10:02.855668 12131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:11:07.968561+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:10:52.107276+00:00 2021-03-31T18:10:54.000523+00:00 0:00:01.893247 12130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T18:10:49.890779+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:10:48.323645+00:00 2021-03-31T18:10:50.138299+00:00 0:00:01.814654 12129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T18:10:45.890534+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T17:00:00+00:00 PythonOperator 2021-03-31T18:10:30.612257+00:00 2021-03-31T18:10:33.295820+00:00 0:00:02.683563 12128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:10:27.874421+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T17:00:00+00:00 PythonOperator 2021-03-31T18:10:28.163135+00:00 2021-03-31T18:10:31.623995+00:00 0:00:03.460860 12127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:10:25.862265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T17:00:00+00:00 TriggerDagRunOperator 2021-03-31T18:10:20.314556+00:00 2021-03-31T18:10:20.830483+00:00 0:00:00.515927 12126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:10:17.854863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T17:00:00+00:00 TriggerDagRunOperator 2021-03-31T18:10:20.090964+00:00 2021-03-31T18:10:20.532889+00:00 0:00:00.441925 12125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:10:17.854891+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T17:05:00+00:00 EmrJobFlowSensor 2021-03-31T18:06:01.729452+00:00 2021-03-31T18:15:04.395545+00:00 0:09:02.666093 12124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:05:59.463964+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:05:39.953482+00:00 2021-03-31T18:05:41.681347+00:00 0:00:01.727865 12123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T18:05:37.473957+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T17:05:00+00:00 PythonOperator 2021-03-31T18:05:19.900015+00:00 2021-03-31T18:05:22.681908+00:00 0:00:02.781893 12122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:05:17.367530+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T17:00:00+00:00 EmrJobFlowSensor 2021-03-31T18:01:03.308097+00:00 2021-03-31T18:10:06.205754+00:00 0:09:02.897657 12121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:01:00.943961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:00:43.267585+00:00 2021-03-31T18:00:45.161177+00:00 0:00:01.893592 12120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T18:00:40.882981+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T17:00:00+00:00 PythonOperator 2021-03-31T18:00:21.123111+00:00 2021-03-31T18:00:23.923941+00:00 0:00:02.800830 12119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T18:00:18.855348+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T16:00:00+00:00 EmrJobFlowSensor 2021-03-31T17:28:28.186702+00:00 2021-03-31T17:49:32.578958+00:00 0:21:04.392256 12117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:28:25.754993+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T16:00:00+00:00 EmrJobFlowSensor 2021-03-31T17:28:14.027377+00:00 2021-03-31T17:38:16.800182+00:00 0:10:02.772805 12116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:28:11.688356+00:00 2 default_pool