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 vc-asset-import_v002 create_emr_steps 2021-04-25T22:05:00+00:00 PythonOperator 2021-04-25T23:05:18.018928+00:00 2021-04-25T23:05:21.006532+00:00 0:00:02.987604 21260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T23:05:15.578692+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T22:00:00+00:00 EmrJobFlowSensor 2021-04-25T23:00:51.707421+00:00 2021-04-25T23:10:54.433251+00:00 0:10:02.725830 21259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T23:00:48.711865+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-24T23:00:00+00:00 EmrJobFlowSensor 2021-04-25T23:00:49.523626+00:00 2021-04-25T23:09:52.415545+00:00 0:09:02.891919 21258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T23:00:46.773678+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T23:00:29.110261+00:00 2021-04-25T23:00:30.813310+00:00 0:00:01.703049 21257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T23:00:26.657597+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T23:00:29.172913+00:00 2021-04-25T23:00:30.934357+00:00 0:00:01.761444 21256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T23:00:26.657555+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T22:00:00+00:00 PythonOperator 2021-04-25T23:00:08.879114+00:00 2021-04-25T23:00:11.837523+00:00 0:00:02.958409 21255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T23:00:06.615745+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-24T23:00:00+00:00 PythonOperator 2021-04-25T23:00:07.468140+00:00 2021-04-25T23:00:10.519819+00:00 0:00:03.051679 21254 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T23:00:04.733074+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T21:00:00+00:00 EmrJobFlowSensor 2021-04-25T22:10:04.869735+00:00 2021-04-25T22:19:07.663014+00:00 0:09:02.793279 21252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T22:10:02.578394+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T21:00:00+00:00 EmrJobFlowSensor 2021-04-25T22:09:46.763469+00:00 2021-04-25T22:19:49.636640+00:00 0:10:02.873171 21251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T22:09:44.512532+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T22:09:42.842884+00:00 2021-04-25T22:09:44.940450+00:00 0:00:02.097566 21250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T22:09:40.507885+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T22:09:24.689923+00:00 2021-04-25T22:09:26.366760+00:00 0:00:01.676837 21249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T22:09:22.497252+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T21:00:00+00:00 PythonOperator 2021-04-25T22:09:22.855338+00:00 2021-04-25T22:09:26.030342+00:00 0:00:03.175004 21248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T22:09:20.496566+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T21:00:00+00:00 PythonOperator 2021-04-25T22:09:03.420523+00:00 2021-04-25T22:09:06.405809+00:00 0:00:02.985286 21247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T22:09:00.482981+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T21:00:00+00:00 TriggerDagRunOperator 2021-04-25T22:08:57.097678+00:00 2021-04-25T22:08:57.611644+00:00 0:00:00.513966 21246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T22:08:54.448035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T21:00:00+00:00 TriggerDagRunOperator 2021-04-25T22:08:56.992740+00:00 2021-04-25T22:08:57.635749+00:00 0:00:00.643009 21245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T22:08:54.447903+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T21:05:00+00:00 EmrJobFlowSensor 2021-04-25T22:05:50.246953+00:00 2021-04-25T22:13:52.879032+00:00 0:08:02.632079 21244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T22:05:47.994230+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T22:05:28.104037+00:00 2021-04-25T22:05:29.753762+00:00 0:00:01.649725 21243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T22:05:25.968094+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T21:05:00+00:00 PythonOperator 2021-04-25T22:05:08.334714+00:00 2021-04-25T22:05:11.278083+00:00 0:00:02.943369 21242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T22:05:05.950351+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T21:00:00+00:00 EmrJobFlowSensor 2021-04-25T22:00:47.408605+00:00 2021-04-25T22:08:49.928419+00:00 0:08:02.519814 21241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T22:00:45.294568+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T22:00:25.629699+00:00 2021-04-25T22:00:27.464078+00:00 0:00:01.834379 21240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T22:00:23.263420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T21:00:00+00:00 PythonOperator 2021-04-25T22:00:05.806409+00:00 2021-04-25T22:00:08.831794+00:00 0:00:03.025385 21239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T22:00:03.208638+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T20:00:00+00:00 EmrJobFlowSensor 2021-04-25T21:12:02.356811+00:00 2021-04-25T21:21:05.005520+00:00 0:09:02.648709 21237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T21:11:59.952974+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T20:00:00+00:00 EmrJobFlowSensor 2021-04-25T21:11:52.272024+00:00 2021-04-25T21:21:54.920036+00:00 0:10:02.648012 21236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T21:11:49.872370+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T21:11:40.321320+00:00 2021-04-25T21:11:42.109248+00:00 0:00:01.787928 21235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T21:11:37.852610+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T21:11:30.231920+00:00 2021-04-25T21:11:31.897047+00:00 0:00:01.665127 21234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T21:11:27.865558+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T20:00:00+00:00 PythonOperator 2021-04-25T21:11:20.325199+00:00 2021-04-25T21:11:23.347016+00:00 0:00:03.021817 21233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T21:11:17.697150+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T20:00:00+00:00 PythonOperator 2021-04-25T21:11:10.041063+00:00 2021-04-25T21:11:13.262855+00:00 0:00:03.221792 21232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T21:11:07.674962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T20:00:00+00:00 TriggerDagRunOperator 2021-04-25T21:10:57.970238+00:00 2021-04-25T21:10:58.515520+00:00 0:00:00.545282 21231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T21:10:55.668702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T20:00:00+00:00 TriggerDagRunOperator 2021-04-25T21:10:57.883673+00:00 2021-04-25T21:10:58.292389+00:00 0:00:00.408716 21230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T21:10:55.668737+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T20:05:00+00:00 EmrJobFlowSensor 2021-04-25T21:05:47.159501+00:00 2021-04-25T21:13:49.646611+00:00 0:08:02.487110 21229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T21:05:44.879357+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T21:05:25.162402+00:00 2021-04-25T21:05:26.890684+00:00 0:00:01.728282 21228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T21:05:22.801941+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T20:05:00+00:00 PythonOperator 2021-04-25T21:05:03.205734+00:00 2021-04-25T21:05:06.164733+00:00 0:00:02.958999 21227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T21:05:00.844047+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T20:00:00+00:00 EmrJobFlowSensor 2021-04-25T21:00:48.965521+00:00 2021-04-25T21:10:51.749409+00:00 0:10:02.783888 21226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T21:00:46.278863+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T21:00:26.637048+00:00 2021-04-25T21:00:28.380228+00:00 0:00:01.743180 21225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T21:00:24.245579+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T20:00:00+00:00 PythonOperator 2021-04-25T21:00:06.901836+00:00 2021-04-25T21:00:09.902512+00:00 0:00:03.000676 21224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T21:00:04.161908+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T19:00:00+00:00 EmrJobFlowSensor 2021-04-25T20:10:48.284341+00:00 2021-04-25T20:18:50.817810+00:00 0:08:02.533469 21222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T20:10:45.572278+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T19:00:00+00:00 EmrJobFlowSensor 2021-04-25T20:10:48.046639+00:00 2021-04-25T20:20:50.736199+00:00 0:10:02.689560 21221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T20:10:45.572230+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T20:10:27.643667+00:00 2021-04-25T20:10:29.401072+00:00 0:00:01.757405 21220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T20:10:25.481911+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T20:10:26.012560+00:00 2021-04-25T20:10:27.803800+00:00 0:00:01.791240 21219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T20:10:23.554186+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T19:00:00+00:00 PythonOperator 2021-04-25T20:10:06.356726+00:00 2021-04-25T20:10:09.570966+00:00 0:00:03.214240 21218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T20:10:03.420018+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T19:00:00+00:00 PythonOperator 2021-04-25T20:10:06.276297+00:00 2021-04-25T20:10:09.334090+00:00 0:00:03.057793 21217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T20:10:03.420051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T19:00:00+00:00 TriggerDagRunOperator 2021-04-25T20:09:58.178675+00:00 2021-04-25T20:09:58.693732+00:00 0:00:00.515057 21216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T20:09:55.415977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T19:00:00+00:00 TriggerDagRunOperator 2021-04-25T20:09:57.648596+00:00 2021-04-25T20:09:58.038689+00:00 0:00:00.390093 21215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T20:09:55.415934+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T19:05:00+00:00 EmrJobFlowSensor 2021-04-25T20:06:05.114511+00:00 2021-04-25T20:14:07.711704+00:00 0:08:02.597193 21214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T20:06:02.787553+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T20:05:42.868415+00:00 2021-04-25T20:05:44.492192+00:00 0:00:01.623777 21213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T20:05:40.649137+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T19:05:00+00:00 PythonOperator 2021-04-25T20:05:20.763678+00:00 2021-04-25T20:05:23.703672+00:00 0:00:02.939994 21212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T20:05:18.635014+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T19:00:00+00:00 EmrJobFlowSensor 2021-04-25T20:00:50.475593+00:00 2021-04-25T20:09:53.177650+00:00 0:09:02.702057 21211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T20:00:48.147252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T20:00:30.437145+00:00 2021-04-25T20:00:32.118309+00:00 0:00:01.681164 21210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T20:00:28.144884+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T19:00:00+00:00 PythonOperator 2021-04-25T20:00:08.391692+00:00 2021-04-25T20:00:11.416076+00:00 0:00:03.024384 21209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T20:00:06.088935+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T18:00:00+00:00 EmrJobFlowSensor 2021-04-25T19:11:20.999355+00:00 2021-04-25T19:20:23.490702+00:00 0:09:02.491347 21207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T19:11:18.839552+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T18:00:00+00:00 EmrJobFlowSensor 2021-04-25T19:11:15.323452+00:00 2021-04-25T19:20:18.025814+00:00 0:09:02.702362 21206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T19:11:13.049366+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T19:10:59.111694+00:00 2021-04-25T19:11:00.857396+00:00 0:00:01.745702 21205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T19:10:56.817336+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T19:10:55.115051+00:00 2021-04-25T19:10:56.771592+00:00 0:00:01.656541 21204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T19:10:52.843678+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T18:00:00+00:00 PythonOperator 2021-04-25T19:10:39.025113+00:00 2021-04-25T19:10:42.209752+00:00 0:00:03.184639 21203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T19:10:36.789024+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T18:00:00+00:00 PythonOperator 2021-04-25T19:10:33.083651+00:00 2021-04-25T19:10:36.063442+00:00 0:00:02.979791 21202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T19:10:30.787793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T18:00:00+00:00 TriggerDagRunOperator 2021-04-25T19:10:23.241063+00:00 2021-04-25T19:10:23.652161+00:00 0:00:00.411098 21201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T19:10:20.712925+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T18:00:00+00:00 TriggerDagRunOperator 2021-04-25T19:10:22.945803+00:00 2021-04-25T19:10:23.449733+00:00 0:00:00.503930 21200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T19:10:20.712880+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T18:05:00+00:00 EmrJobFlowSensor 2021-04-25T19:06:00.943142+00:00 2021-04-25T19:15:03.585280+00:00 0:09:02.642138 21199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T19:05:58.469130+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T19:05:40.473636+00:00 2021-04-25T19:05:42.120104+00:00 0:00:01.646468 21198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T19:05:38.299084+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T18:05:00+00:00 PythonOperator 2021-04-25T19:05:18.834234+00:00 2021-04-25T19:05:21.766210+00:00 0:00:02.931976 21197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T19:05:16.347943+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T18:00:00+00:00 EmrJobFlowSensor 2021-04-25T19:00:56.276169+00:00 2021-04-25T19:09:58.950643+00:00 0:09:02.674474 21196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T19:00:53.920457+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T19:00:26.156306+00:00 2021-04-25T19:00:27.825682+00:00 0:00:01.669376 21195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T19:00:23.894213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T18:00:00+00:00 PythonOperator 2021-04-25T19:00:04.724311+00:00 2021-04-25T19:00:07.872835+00:00 0:00:03.148524 21194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T19:00:01.811926+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T17:00:00+00:00 EmrJobFlowSensor 2021-04-25T18:11:15.916190+00:00 2021-04-25T18:20:18.494885+00:00 0:09:02.578695 21192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T18:11:13.433090+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T17:00:00+00:00 EmrJobFlowSensor 2021-04-25T18:11:07.898605+00:00 2021-04-25T18:21:10.653022+00:00 0:10:02.754417 21191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T18:11:05.469133+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T18:10:53.750833+00:00 2021-04-25T18:10:55.433024+00:00 0:00:01.682191 21190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T18:10:51.449821+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T18:10:47.706279+00:00 2021-04-25T18:10:49.465755+00:00 0:00:01.759476 21189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T18:10:45.363479+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T17:00:00+00:00 PythonOperator 2021-04-25T18:10:34.194537+00:00 2021-04-25T18:10:37.267138+00:00 0:00:03.072601 21188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T18:10:31.345816+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T17:00:00+00:00 PythonOperator 2021-04-25T18:10:25.930414+00:00 2021-04-25T18:10:29.185367+00:00 0:00:03.254953 21187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T18:10:23.261679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T17:00:00+00:00 TriggerDagRunOperator 2021-04-25T18:10:17.527443+00:00 2021-04-25T18:10:17.955929+00:00 0:00:00.428486 21186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T18:10:15.248948+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T17:00:00+00:00 TriggerDagRunOperator 2021-04-25T18:10:17.511393+00:00 2021-04-25T18:10:18.076751+00:00 0:00:00.565358 21185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T18:10:15.249002+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T17:05:00+00:00 EmrJobFlowSensor 2021-04-25T18:06:06.965411+00:00 2021-04-25T18:14:09.463265+00:00 0:08:02.497854 21184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T18:06:04.817681+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T18:05:46.864855+00:00 2021-04-25T18:05:48.514632+00:00 0:00:01.649777 21183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T18:05:44.796728+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T17:05:00+00:00 PythonOperator 2021-04-25T18:05:25.466826+00:00 2021-04-25T18:05:28.396794+00:00 0:00:02.929968 21182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T18:05:22.858160+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T17:00:00+00:00 EmrJobFlowSensor 2021-04-25T18:00:52.149069+00:00 2021-04-25T18:09:54.885680+00:00 0:09:02.736611 21181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T18:00:50.001569+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T18:00:30.229921+00:00 2021-04-25T18:00:32.919047+00:00 0:00:02.689126 21180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T18:00:27.962127+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T17:00:00+00:00 PythonOperator 2021-04-25T18:00:08.435463+00:00 2021-04-25T18:00:11.440920+00:00 0:00:03.005457 21179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T18:00:05.924131+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T16:00:00+00:00 EmrJobFlowSensor 2021-04-25T17:11:15.885307+00:00 2021-04-25T17:20:18.460579+00:00 0:09:02.575272 21177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T17:11:13.598558+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T16:00:00+00:00 EmrJobFlowSensor 2021-04-25T17:10:58.237937+00:00 2021-04-25T17:20:00.926329+00:00 0:09:02.688392 21176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T17:10:55.521046+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T17:10:49.918616+00:00 2021-04-25T17:10:51.699117+00:00 0:00:01.780501 21175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T17:10:47.522581+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T17:10:28.086203+00:00 2021-04-25T17:10:30.024235+00:00 0:00:01.938032 21174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T17:10:25.549726+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T16:00:00+00:00 PythonOperator 2021-04-25T17:10:21.584033+00:00 2021-04-25T17:10:24.776236+00:00 0:00:03.192203 21173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T17:10:19.407463+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T16:00:00+00:00 PythonOperator 2021-04-25T17:10:07.789245+00:00 2021-04-25T17:10:10.845587+00:00 0:00:03.056342 21172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T17:10:05.460848+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T16:00:00+00:00 TriggerDagRunOperator 2021-04-25T17:10:01.835206+00:00 2021-04-25T17:10:02.414576+00:00 0:00:00.579370 21171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T17:09:59.387323+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T16:00:00+00:00 TriggerDagRunOperator 2021-04-25T17:10:01.759803+00:00 2021-04-25T17:10:02.265464+00:00 0:00:00.505661 21170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T17:09:59.387358+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T16:05:00+00:00 EmrJobFlowSensor 2021-04-25T17:05:57.258836+00:00 2021-04-25T17:13:59.681381+00:00 0:08:02.422545 21169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T17:05:54.954032+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T17:05:35.224659+00:00 2021-04-25T17:05:36.916897+00:00 0:00:01.692238 21168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T17:05:32.891163+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T16:05:00+00:00 PythonOperator 2021-04-25T17:05:13.268747+00:00 2021-04-25T17:05:16.222932+00:00 0:00:02.954185 21167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T17:05:10.874725+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T16:00:00+00:00 EmrJobFlowSensor 2021-04-25T17:00:54.673956+00:00 2021-04-25T17:09:57.318652+00:00 0:09:02.644696 21166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T17:00:52.341609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T17:00:32.648750+00:00 2021-04-25T17:00:34.470951+00:00 0:00:01.822201 21165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T17:00:30.155272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T16:00:00+00:00 PythonOperator 2021-04-25T17:00:10.417526+00:00 2021-04-25T17:00:13.387932+00:00 0:00:02.970406 21164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T17:00:08.054140+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T15:00:00+00:00 EmrJobFlowSensor 2021-04-25T16:11:23.665366+00:00 2021-04-25T16:21:26.476944+00:00 0:10:02.811578 21162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T16:11:20.762660+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T15:00:00+00:00 EmrJobFlowSensor 2021-04-25T16:11:21.206804+00:00 2021-04-25T16:20:24.153205+00:00 0:09:02.946401 21161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T16:11:18.766203+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T16:11:01.327565+00:00 2021-04-25T16:11:03.166141+00:00 0:00:01.838576 21160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T16:10:58.762601+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T16:11:01.197004+00:00 2021-04-25T16:11:02.914844+00:00 0:00:01.717840 21159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T16:10:58.762634+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T15:00:00+00:00 PythonOperator 2021-04-25T16:10:39.238850+00:00 2021-04-25T16:10:42.324386+00:00 0:00:03.085536 21158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T16:10:36.747799+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T15:00:00+00:00 PythonOperator 2021-04-25T16:10:39.268122+00:00 2021-04-25T16:10:42.500419+00:00 0:00:03.232297 21157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T16:10:36.747771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T15:00:00+00:00 TriggerDagRunOperator 2021-04-25T16:10:17.273514+00:00 2021-04-25T16:10:17.784815+00:00 0:00:00.511301 21156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T16:10:14.663716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T15:00:00+00:00 TriggerDagRunOperator 2021-04-25T16:10:17.124161+00:00 2021-04-25T16:10:17.540800+00:00 0:00:00.416639 21155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T16:10:14.663678+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T15:05:00+00:00 EmrJobFlowSensor 2021-04-25T16:05:56.161157+00:00 2021-04-25T16:14:58.672965+00:00 0:09:02.511808 21154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T16:05:54.005097+00:00 2 default_pool