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 create_emr_steps 2021-05-12T17:00:00+00:00 PythonOperator 2021-05-12T18:11:27.035161+00:00 2021-05-12T18:11:30.284829+00:00 0:00:03.249668 27360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T18:11:24.904246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T17:00:00+00:00 TriggerDagRunOperator 2021-05-12T18:11:11.422296+00:00 2021-05-12T18:11:12.019344+00:00 0:00:00.597048 27359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T18:11:08.894221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T17:00:00+00:00 TriggerDagRunOperator 2021-05-12T18:11:11.386376+00:00 2021-05-12T18:11:11.769903+00:00 0:00:00.383527 27358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T18:11:08.894193+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T17:05:00+00:00 EmrJobFlowSensor 2021-05-12T18:06:06.271225+00:00 2021-05-12T18:14:08.960394+00:00 0:08:02.689169 27356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T18:06:04.019462+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T18:05:44.502730+00:00 2021-05-12T18:05:46.217353+00:00 0:00:01.714623 27355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T18:05:42.004778+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T17:05:00+00:00 PythonOperator 2021-05-12T18:05:22.165020+00:00 2021-05-12T18:05:25.270268+00:00 0:00:03.105248 27354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T18:05:19.988029+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T17:00:00+00:00 EmrJobFlowSensor 2021-05-12T18:01:53.860357+00:00 2021-05-12T18:10:56.548914+00:00 0:09:02.688557 27353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T18:01:51.729106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T18:01:31.878416+00:00 2021-05-12T18:01:33.553525+00:00 0:00:01.675109 27352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T18:01:29.707651+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T17:00:00+00:00 PythonOperator 2021-05-12T18:01:11.893341+00:00 2021-05-12T18:01:15.069304+00:00 0:00:03.175963 27351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T18:01:09.689821+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T16:00:00+00:00 EmrJobFlowSensor 2021-05-12T17:11:56.947358+00:00 2021-05-12T17:21:59.807042+00:00 0:10:02.859684 27350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T17:11:54.391813+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T16:00:00+00:00 EmrJobFlowSensor 2021-05-12T17:11:56.908664+00:00 2021-05-12T17:22:59.832008+00:00 0:11:02.923344 27349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T17:11:54.391857+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T17:11:36.854669+00:00 2021-05-12T17:11:38.533501+00:00 0:00:01.678832 27348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T17:11:34.380593+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T17:11:34.468713+00:00 2021-05-12T17:11:36.430772+00:00 0:00:01.962059 27347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T17:11:32.319441+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T16:00:00+00:00 PythonOperator 2021-05-12T17:11:14.732455+00:00 2021-05-12T17:11:17.812793+00:00 0:00:03.080338 27346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T17:11:12.293478+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T16:00:00+00:00 PythonOperator 2021-05-12T17:11:14.503291+00:00 2021-05-12T17:11:17.884308+00:00 0:00:03.381017 27345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T17:11:12.293510+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T16:00:00+00:00 TriggerDagRunOperator 2021-05-12T17:11:00.937249+00:00 2021-05-12T17:11:01.444622+00:00 0:00:00.507373 27344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T17:10:58.363150+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T16:00:00+00:00 TriggerDagRunOperator 2021-05-12T17:11:00.741627+00:00 2021-05-12T17:11:01.137254+00:00 0:00:00.395627 27343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T17:10:58.363109+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T16:05:00+00:00 EmrJobFlowSensor 2021-05-12T17:06:42.173942+00:00 2021-05-12T17:14:44.828542+00:00 0:08:02.654600 27342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T17:06:39.841949+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T17:05:42.535477+00:00 2021-05-12T17:05:44.261737+00:00 0:00:01.726260 27340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T17:05:40.386045+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T16:05:00+00:00 PythonOperator 2021-05-12T17:05:20.746348+00:00 2021-05-12T17:05:23.793670+00:00 0:00:03.047322 27339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T17:05:18.381577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T16:00:00+00:00 EmrJobFlowSensor 2021-05-12T17:00:46.319187+00:00 2021-05-12T17:10:49.097022+00:00 0:10:02.777835 27338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T17:00:44.060410+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T17:00:26.298733+00:00 2021-05-12T17:00:28.282527+00:00 0:00:01.983794 27337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T17:00:23.967922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T16:00:00+00:00 PythonOperator 2021-05-12T17:00:04.152572+00:00 2021-05-12T17:00:07.288846+00:00 0:00:03.136274 27336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T17:00:01.945003+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T15:00:00+00:00 EmrJobFlowSensor 2021-05-12T16:11:25.450035+00:00 2021-05-12T16:21:28.316607+00:00 0:10:02.866572 27335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T16:11:22.954559+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T15:00:00+00:00 EmrJobFlowSensor 2021-05-12T16:11:07.909188+00:00 2021-05-12T16:20:10.636540+00:00 0:09:02.727352 27334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T16:11:04.951032+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T16:11:05.206956+00:00 2021-05-12T16:11:07.253055+00:00 0:00:02.046099 27333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T16:11:02.953494+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T16:10:45.226491+00:00 2021-05-12T16:10:47.099408+00:00 0:00:01.872917 27332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T16:10:42.842912+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T15:00:00+00:00 PythonOperator 2021-05-12T16:10:43.020901+00:00 2021-05-12T16:10:46.344924+00:00 0:00:03.324023 27331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T16:10:40.842478+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T15:00:00+00:00 PythonOperator 2021-05-12T16:10:25.196230+00:00 2021-05-12T16:10:28.397072+00:00 0:00:03.200842 27330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T16:10:22.826054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T15:00:00+00:00 TriggerDagRunOperator 2021-05-12T16:10:19.457912+00:00 2021-05-12T16:10:19.986589+00:00 0:00:00.528677 27329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T16:10:16.822109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T15:00:00+00:00 TriggerDagRunOperator 2021-05-12T16:10:19.080892+00:00 2021-05-12T16:10:19.491402+00:00 0:00:00.410510 27328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T16:10:16.822076+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T15:05:00+00:00 EmrJobFlowSensor 2021-05-12T16:06:46.466576+00:00 2021-05-12T16:14:48.842276+00:00 0:08:02.375700 27327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T16:06:44.409334+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T16:06:24.555516+00:00 2021-05-12T16:06:26.190870+00:00 0:00:01.635354 27326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T16:06:22.388655+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T15:05:00+00:00 PythonOperator 2021-05-12T16:06:05.062770+00:00 2021-05-12T16:06:08.289276+00:00 0:00:03.226506 27325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T16:06:02.292082+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T15:00:00+00:00 EmrJobFlowSensor 2021-05-12T16:01:04.298445+00:00 2021-05-12T16:10:07.009121+00:00 0:09:02.710676 27323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T16:01:01.983235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T16:00:42.200968+00:00 2021-05-12T16:00:43.970312+00:00 0:00:01.769344 27322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T16:00:39.951755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T15:00:00+00:00 PythonOperator 2021-05-12T16:00:20.123633+00:00 2021-05-12T16:00:23.291428+00:00 0:00:03.167795 27321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T16:00:17.905427+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T14:00:00+00:00 EmrJobFlowSensor 2021-05-12T15:12:23.530539+00:00 2021-05-12T15:22:26.540404+00:00 0:10:03.009865 27320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T15:12:21.146243+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T14:00:00+00:00 EmrJobFlowSensor 2021-05-12T15:12:19.624447+00:00 2021-05-12T15:22:22.546458+00:00 0:10:02.922011 27319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T15:12:17.177908+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T15:12:02.236655+00:00 2021-05-12T15:12:03.964874+00:00 0:00:01.728219 27318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T15:11:59.262839+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T15:11:59.400560+00:00 2021-05-12T15:12:01.505840+00:00 0:00:02.105280 27317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T15:11:57.146726+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T14:00:00+00:00 PythonOperator 2021-05-12T15:11:39.707715+00:00 2021-05-12T15:11:43.035407+00:00 0:00:03.327692 27316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T15:11:37.158014+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T14:00:00+00:00 PythonOperator 2021-05-12T15:11:37.321909+00:00 2021-05-12T15:11:40.387155+00:00 0:00:03.065246 27315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T15:11:35.153463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T14:00:00+00:00 TriggerDagRunOperator 2021-05-12T15:11:33.546941+00:00 2021-05-12T15:11:34.081983+00:00 0:00:00.535042 27314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T15:11:31.153575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T14:00:00+00:00 TriggerDagRunOperator 2021-05-12T15:11:33.388419+00:00 2021-05-12T15:11:33.818722+00:00 0:00:00.430303 27313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T15:11:31.153523+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T14:05:00+00:00 EmrJobFlowSensor 2021-05-12T15:06:02.822944+00:00 2021-05-12T15:16:05.637775+00:00 0:10:02.814831 27312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T15:06:00.545169+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T15:05:42.600031+00:00 2021-05-12T15:05:44.271501+00:00 0:00:01.671470 27311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T15:05:40.525980+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T14:05:00+00:00 PythonOperator 2021-05-12T15:05:21.161144+00:00 2021-05-12T15:05:24.261463+00:00 0:00:03.100319 27310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T15:05:18.653032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T14:00:00+00:00 EmrJobFlowSensor 2021-05-12T15:01:04.913587+00:00 2021-05-12T15:11:07.875654+00:00 0:10:02.962067 27308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T15:01:02.291747+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T15:00:42.475052+00:00 2021-05-12T15:00:44.217974+00:00 0:00:01.742922 27307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T15:00:40.265495+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T14:00:00+00:00 PythonOperator 2021-05-12T15:00:20.564459+00:00 2021-05-12T15:00:23.684015+00:00 0:00:03.119556 27306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T15:00:18.255263+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T13:00:00+00:00 EmrJobFlowSensor 2021-05-12T14:12:51.404233+00:00 2021-05-12T14:21:54.192997+00:00 0:09:02.788764 27305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T14:12:49.177018+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T14:12:19.335734+00:00 2021-05-12T14:12:21.043888+00:00 0:00:01.708154 27304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T14:12:17.149644+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T13:00:00+00:00 EmrJobFlowSensor 2021-05-12T14:12:01.599009+00:00 2021-05-12T14:21:04.340043+00:00 0:09:02.741034 27303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T14:11:59.250199+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T14:11:29.290358+00:00 2021-05-12T14:11:30.958977+00:00 0:00:01.668619 27302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T14:11:27.103669+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T13:00:00+00:00 PythonOperator 2021-05-12T14:11:05.301227+00:00 2021-05-12T14:11:08.405060+00:00 0:00:03.103833 27301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T14:11:03.038334+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T13:00:00+00:00 PythonOperator 2021-05-12T14:11:01.184260+00:00 2021-05-12T14:11:04.645553+00:00 0:00:03.461293 27300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T14:10:59.053008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T13:00:00+00:00 TriggerDagRunOperator 2021-05-12T14:10:45.379258+00:00 2021-05-12T14:10:45.883357+00:00 0:00:00.504099 27299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T14:10:42.996246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T13:00:00+00:00 TriggerDagRunOperator 2021-05-12T14:10:45.178023+00:00 2021-05-12T14:10:45.595522+00:00 0:00:00.417499 27298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T14:10:42.996280+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T13:05:00+00:00 EmrJobFlowSensor 2021-05-12T14:06:05.122981+00:00 2021-05-12T14:13:07.607571+00:00 0:07:02.484590 27297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T14:06:02.666623+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T14:05:38.760692+00:00 2021-05-12T14:05:40.368732+00:00 0:00:01.608040 27296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T14:05:36.657924+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T13:05:00+00:00 PythonOperator 2021-05-12T14:05:17.125915+00:00 2021-05-12T14:05:20.244476+00:00 0:00:03.118561 27295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T14:05:14.674323+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T13:00:00+00:00 EmrJobFlowSensor 2021-05-12T14:02:30.841717+00:00 2021-05-12T14:10:33.380887+00:00 0:08:02.539170 27294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T14:02:28.540914+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T14:02:10.609534+00:00 2021-05-12T14:02:12.427859+00:00 0:00:01.818325 27293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T14:02:08.389692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T13:00:00+00:00 PythonOperator 2021-05-12T14:01:48.701981+00:00 2021-05-12T14:01:51.828921+00:00 0:00:03.126940 27292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T14:01:46.356922+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T12:00:00+00:00 EmrJobFlowSensor 2021-05-12T13:11:15.151974+00:00 2021-05-12T13:20:17.853016+00:00 0:09:02.701042 27290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T13:11:12.867006+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T12:00:00+00:00 EmrJobFlowSensor 2021-05-12T13:11:09.012042+00:00 2021-05-12T13:21:11.822315+00:00 0:10:02.810273 27289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T13:11:06.857553+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T13:10:53.079530+00:00 2021-05-12T13:10:54.812457+00:00 0:00:01.732927 27288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T13:10:50.810363+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T13:10:47.008685+00:00 2021-05-12T13:10:48.710247+00:00 0:00:01.701562 27287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T13:10:44.855607+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T12:00:00+00:00 PythonOperator 2021-05-12T13:10:31.144207+00:00 2021-05-12T13:10:34.464684+00:00 0:00:03.320477 27286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T13:10:28.782799+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T12:00:00+00:00 PythonOperator 2021-05-12T13:10:24.874658+00:00 2021-05-12T13:10:27.968446+00:00 0:00:03.093788 27285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T13:10:22.767196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T12:00:00+00:00 TriggerDagRunOperator 2021-05-12T13:10:09.284318+00:00 2021-05-12T13:10:09.862508+00:00 0:00:00.578190 27284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T13:10:06.749309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T12:00:00+00:00 TriggerDagRunOperator 2021-05-12T13:10:08.969412+00:00 2021-05-12T13:10:09.482908+00:00 0:00:00.513496 27283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T13:10:06.749345+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T12:05:00+00:00 EmrJobFlowSensor 2021-05-12T13:05:56.569584+00:00 2021-05-12T13:13:59.050528+00:00 0:08:02.480944 27282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T13:05:54.433127+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T13:05:30.731978+00:00 2021-05-12T13:05:32.424779+00:00 0:00:01.692801 27281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T13:05:28.480394+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T12:05:00+00:00 PythonOperator 2021-05-12T13:05:06.477383+00:00 2021-05-12T13:05:09.560056+00:00 0:00:03.082673 27280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T13:05:04.387993+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T12:00:00+00:00 EmrJobFlowSensor 2021-05-12T13:01:00.478186+00:00 2021-05-12T13:10:03.345568+00:00 0:09:02.867382 27279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T13:00:57.992414+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T13:00:38.117283+00:00 2021-05-12T13:00:39.834674+00:00 0:00:01.717391 27278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T13:00:35.951542+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T12:00:00+00:00 PythonOperator 2021-05-12T13:00:18.658773+00:00 2021-05-12T13:00:21.789698+00:00 0:00:03.130925 27277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T13:00:15.936934+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T11:00:00+00:00 EmrJobFlowSensor 2021-05-12T12:12:26.805737+00:00 2021-05-12T12:21:29.478651+00:00 0:09:02.672914 27275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T12:12:24.716164+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T11:00:00+00:00 EmrJobFlowSensor 2021-05-12T12:12:22.883090+00:00 2021-05-12T12:21:25.592533+00:00 0:09:02.709443 27274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T12:12:20.712132+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T12:11:57.089617+00:00 2021-05-12T12:11:58.729896+00:00 0:00:01.640279 27273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T12:11:54.691751+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T12:11:54.777460+00:00 2021-05-12T12:11:56.779472+00:00 0:00:02.002012 27272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T12:11:52.689004+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T11:00:00+00:00 PythonOperator 2021-05-12T12:11:36.862197+00:00 2021-05-12T12:11:39.920431+00:00 0:00:03.058234 27271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T12:11:34.633333+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T11:00:00+00:00 PythonOperator 2021-05-12T12:11:32.787874+00:00 2021-05-12T12:11:36.074470+00:00 0:00:03.286596 27270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T12:11:30.634126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T11:00:00+00:00 TriggerDagRunOperator 2021-05-12T12:11:22.982381+00:00 2021-05-12T12:11:23.517724+00:00 0:00:00.535343 27269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T12:11:20.625992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T11:00:00+00:00 TriggerDagRunOperator 2021-05-12T12:11:22.884894+00:00 2021-05-12T12:11:23.322165+00:00 0:00:00.437271 27268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T12:11:20.626022+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T11:05:00+00:00 EmrJobFlowSensor 2021-05-12T12:05:48.473234+00:00 2021-05-12T12:13:50.915481+00:00 0:08:02.442247 27267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T12:05:46.024868+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T12:05:28.296888+00:00 2021-05-12T12:05:30.095361+00:00 0:00:01.798473 27266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T12:05:26.007033+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T11:05:00+00:00 PythonOperator 2021-05-12T12:05:06.146570+00:00 2021-05-12T12:05:09.277275+00:00 0:00:03.130705 27265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T12:05:03.987835+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T11:00:00+00:00 EmrJobFlowSensor 2021-05-12T12:00:54.007584+00:00 2021-05-12T12:10:57.005323+00:00 0:10:02.997739 27264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T12:00:51.402205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T12:00:31.502234+00:00 2021-05-12T12:00:33.221622+00:00 0:00:01.719388 27263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T12:00:29.386865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T11:00:00+00:00 PythonOperator 2021-05-12T12:00:11.565344+00:00 2021-05-12T12:00:14.714562+00:00 0:00:03.149218 27262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T12:00:09.343073+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T10:00:00+00:00 EmrJobFlowSensor 2021-05-12T11:11:28.791242+00:00 2021-05-12T11:20:31.487033+00:00 0:09:02.695791 27260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:11:26.378279+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T10:00:00+00:00 EmrJobFlowSensor 2021-05-12T11:11:12.643744+00:00 2021-05-12T11:21:15.603789+00:00 0:10:02.960045 27259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:11:10.362164+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T11:11:08.497426+00:00 2021-05-12T11:11:10.245575+00:00 0:00:01.748149 27258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T11:11:06.362020+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T11:10:50.463839+00:00 2021-05-12T11:10:52.172179+00:00 0:00:01.708340 27257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T11:10:48.226177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T10:00:00+00:00 PythonOperator 2021-05-12T11:10:38.448951+00:00 2021-05-12T11:10:41.548305+00:00 0:00:03.099354 27256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T11:10:36.214861+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T10:00:00+00:00 PythonOperator 2021-05-12T11:10:28.491140+00:00 2021-05-12T11:10:31.940255+00:00 0:00:03.449115 27255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T11:10:26.221409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T10:00:00+00:00 TriggerDagRunOperator 2021-05-12T11:10:23.287691+00:00 2021-05-12T11:10:23.832518+00:00 0:00:00.544827 27254 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:10:20.266334+00:00 2 default_pool