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 check_cluster_status 2021-05-10T04:05:00+00:00 EmrJobFlowSensor 2021-05-10T05:05:56.687077+00:00 2021-05-10T05:14:59.385090+00:00 0:09:02.698013 26435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T05:05:54.456670+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T05:05:36.911774+00:00 2021-05-10T05:05:38.542001+00:00 0:00:01.630227 26434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T05:05:34.373516+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T04:05:00+00:00 PythonOperator 2021-05-10T05:05:14.708324+00:00 2021-05-10T05:05:17.804452+00:00 0:00:03.096128 26433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T05:05:12.373374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T04:00:00+00:00 EmrJobFlowSensor 2021-05-10T05:01:00.119424+00:00 2021-05-10T05:10:03.110664+00:00 0:09:02.991240 26432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T05:00:57.688511+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T05:00:37.836329+00:00 2021-05-10T05:00:39.582607+00:00 0:00:01.746278 26431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T05:00:35.658790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T04:00:00+00:00 PythonOperator 2021-05-10T05:00:16.251784+00:00 2021-05-10T05:00:19.356960+00:00 0:00:03.105176 26430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T05:00:13.599893+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T03:00:00+00:00 EmrJobFlowSensor 2021-05-10T04:12:12.167717+00:00 2021-05-10T04:21:14.879745+00:00 0:09:02.712028 26428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:12:09.966230+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T03:00:00+00:00 EmrJobFlowSensor 2021-05-10T04:12:06.198574+00:00 2021-05-10T04:22:09.115934+00:00 0:10:02.917360 26427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:12:03.971527+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:11:50.282160+00:00 2021-05-10T04:11:51.973879+00:00 0:00:01.691719 26426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T04:11:47.947940+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:11:42.096652+00:00 2021-05-10T04:11:43.944603+00:00 0:00:01.847951 26425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T04:11:39.890718+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T03:00:00+00:00 PythonOperator 2021-05-10T04:11:27.948859+00:00 2021-05-10T04:11:31.263071+00:00 0:00:03.314212 26424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:11:25.837772+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T03:00:00+00:00 PythonOperator 2021-05-10T04:11:20.265396+00:00 2021-05-10T04:11:23.323927+00:00 0:00:03.058531 26423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:11:17.832075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T03:00:00+00:00 TriggerDagRunOperator 2021-05-10T04:11:08.406021+00:00 2021-05-10T04:11:08.969588+00:00 0:00:00.563567 26422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:11:05.822062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T03:00:00+00:00 TriggerDagRunOperator 2021-05-10T04:11:07.984026+00:00 2021-05-10T04:11:08.414394+00:00 0:00:00.430368 26421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:11:05.822033+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T03:05:00+00:00 EmrJobFlowSensor 2021-05-10T04:05:55.619397+00:00 2021-05-10T04:13:58.318539+00:00 0:08:02.699142 26420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T04:05:53.351562+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:05:33.790165+00:00 2021-05-10T04:05:35.523665+00:00 0:00:01.733500 26419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T04:05:31.363183+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T03:05:00+00:00 PythonOperator 2021-05-10T04:05:11.568873+00:00 2021-05-10T04:05:14.624060+00:00 0:00:03.055187 26418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:05:09.288564+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T03:00:00+00:00 EmrJobFlowSensor 2021-05-10T04:00:46.928584+00:00 2021-05-10T04:10:49.844302+00:00 0:10:02.915718 26417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T04:00:44.655177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T04:00:24.646990+00:00 2021-05-10T04:00:26.398621+00:00 0:00:01.751631 26416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T04:00:22.504248+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T03:00:00+00:00 PythonOperator 2021-05-10T04:00:04.927118+00:00 2021-05-10T04:00:08.096253+00:00 0:00:03.169135 26415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T04:00:02.485324+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T02:00:00+00:00 EmrJobFlowSensor 2021-05-10T03:12:07.842341+00:00 2021-05-10T03:19:10.251333+00:00 0:07:02.408992 26413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:12:05.278532+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T02:00:00+00:00 EmrJobFlowSensor 2021-05-10T03:11:09.602801+00:00 2021-05-10T03:20:12.271774+00:00 0:09:02.668973 26412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:11:07.164827+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:10:49.490174+00:00 2021-05-10T03:10:51.193515+00:00 0:00:01.703341 26411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T03:10:47.176491+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:10:47.474641+00:00 2021-05-10T03:10:49.272494+00:00 0:00:01.797853 26410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T03:10:45.186607+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T02:00:00+00:00 PythonOperator 2021-05-10T03:10:27.454966+00:00 2021-05-10T03:10:30.556815+00:00 0:00:03.101849 26409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:10:25.131015+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T02:00:00+00:00 PythonOperator 2021-05-10T03:10:27.409370+00:00 2021-05-10T03:10:30.770856+00:00 0:00:03.361486 26408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:10:25.131040+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T02:00:00+00:00 TriggerDagRunOperator 2021-05-10T03:10:17.393813+00:00 2021-05-10T03:10:17.931915+00:00 0:00:00.538102 26407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:10:15.124933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T02:00:00+00:00 TriggerDagRunOperator 2021-05-10T03:10:17.178611+00:00 2021-05-10T03:10:17.635028+00:00 0:00:00.456417 26406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:10:15.124999+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T02:05:00+00:00 EmrJobFlowSensor 2021-05-10T03:05:50.974403+00:00 2021-05-10T03:13:53.541444+00:00 0:08:02.567041 26405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T03:05:48.657722+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:05:29.008908+00:00 2021-05-10T03:05:30.659836+00:00 0:00:01.650928 26404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T03:05:26.561398+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T02:05:00+00:00 PythonOperator 2021-05-10T03:05:08.732891+00:00 2021-05-10T03:05:11.812333+00:00 0:00:03.079442 26403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:05:06.455554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T02:00:00+00:00 EmrJobFlowSensor 2021-05-10T03:00:50.342218+00:00 2021-05-10T03:09:53.117066+00:00 0:09:02.774848 26402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T03:00:48.037723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T03:00:28.108485+00:00 2021-05-10T03:00:29.837631+00:00 0:00:01.729146 26401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T03:00:26.021145+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T02:00:00+00:00 PythonOperator 2021-05-10T03:00:08.609987+00:00 2021-05-10T03:00:11.713471+00:00 0:00:03.103484 26400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T03:00:06.003618+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T01:00:00+00:00 EmrJobFlowSensor 2021-05-10T02:12:28.048308+00:00 2021-05-10T02:21:30.701086+00:00 0:09:02.652778 26398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:12:25.860294+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T01:00:00+00:00 EmrJobFlowSensor 2021-05-10T02:12:07.994983+00:00 2021-05-10T02:21:10.607361+00:00 0:09:02.612378 26397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:12:05.814221+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:12:06.444519+00:00 2021-05-10T02:12:08.329780+00:00 0:00:01.885261 26396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T02:12:03.871788+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:11:46.418520+00:00 2021-05-10T02:11:48.192158+00:00 0:00:01.773638 26395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T02:11:43.857254+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T01:00:00+00:00 PythonOperator 2021-05-10T02:11:44.005115+00:00 2021-05-10T02:11:47.290116+00:00 0:00:03.285001 26394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:11:41.799892+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T01:00:00+00:00 PythonOperator 2021-05-10T02:11:23.899995+00:00 2021-05-10T02:11:27.043813+00:00 0:00:03.143818 26393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:11:21.751023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T01:00:00+00:00 TriggerDagRunOperator 2021-05-10T02:11:20.123028+00:00 2021-05-10T02:11:20.708489+00:00 0:00:00.585461 26392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:11:17.749947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T01:00:00+00:00 TriggerDagRunOperator 2021-05-10T02:11:19.933560+00:00 2021-05-10T02:11:20.362223+00:00 0:00:00.428663 26391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:11:17.749917+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T01:05:00+00:00 EmrJobFlowSensor 2021-05-10T02:06:01.339050+00:00 2021-05-10T02:15:03.956194+00:00 0:09:02.617144 26390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T02:05:59.052239+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:05:39.216484+00:00 2021-05-10T02:05:40.991468+00:00 0:00:01.774984 26389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T02:05:36.921748+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T01:05:00+00:00 PythonOperator 2021-05-10T02:05:18.990260+00:00 2021-05-10T02:05:22.060432+00:00 0:00:03.070172 26388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:05:16.901625+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T01:00:00+00:00 EmrJobFlowSensor 2021-05-10T02:00:58.850604+00:00 2021-05-10T02:11:01.685978+00:00 0:10:02.835374 26387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T02:00:56.555660+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T02:00:38.925277+00:00 2021-05-10T02:00:40.749959+00:00 0:00:01.824682 26386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T02:00:36.543740+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T01:00:00+00:00 PythonOperator 2021-05-10T02:00:10.976586+00:00 2021-05-10T02:00:14.216244+00:00 0:00:03.239658 26385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T02:00:08.515786+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T00:00:00+00:00 EmrJobFlowSensor 2021-05-10T01:11:12.939299+00:00 2021-05-10T01:23:16.102817+00:00 0:12:03.163518 26383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:11:10.596741+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T00:00:00+00:00 EmrJobFlowSensor 2021-05-10T01:11:10.889791+00:00 2021-05-10T01:21:13.763559+00:00 0:10:02.873768 26382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:11:08.663530+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:10:52.964560+00:00 2021-05-10T01:10:54.759158+00:00 0:00:01.794598 26381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T01:10:50.543888+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:10:51.008236+00:00 2021-05-10T01:10:52.680041+00:00 0:00:01.671805 26380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T01:10:48.571576+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T00:00:00+00:00 PythonOperator 2021-05-10T01:10:31.340348+00:00 2021-05-10T01:10:34.640066+00:00 0:00:03.299718 26379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:10:28.466350+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T00:00:00+00:00 PythonOperator 2021-05-10T01:10:29.301611+00:00 2021-05-10T01:10:32.827485+00:00 0:00:03.525874 26378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:10:26.417994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T00:00:00+00:00 TriggerDagRunOperator 2021-05-10T01:10:20.990143+00:00 2021-05-10T01:10:21.542498+00:00 0:00:00.552355 26377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:10:18.408589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T00:00:00+00:00 TriggerDagRunOperator 2021-05-10T01:10:20.570236+00:00 2021-05-10T01:10:20.952968+00:00 0:00:00.382732 26376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:10:18.408620+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T00:05:00+00:00 EmrJobFlowSensor 2021-05-10T01:05:47.977798+00:00 2021-05-10T01:14:50.636022+00:00 0:09:02.658224 26375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T01:05:45.919061+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:05:26.233764+00:00 2021-05-10T01:05:27.999380+00:00 0:00:01.765616 26374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T01:05:23.968415+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T00:05:00+00:00 PythonOperator 2021-05-10T01:05:04.056666+00:00 2021-05-10T01:05:07.098713+00:00 0:00:03.042047 26373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:05:01.873252+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T00:00:00+00:00 EmrJobFlowSensor 2021-05-10T01:01:09.927305+00:00 2021-05-10T01:10:12.847360+00:00 0:09:02.920055 26372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T01:01:07.461360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T01:00:43.646287+00:00 2021-05-10T01:00:45.538793+00:00 0:00:01.892506 26371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T01:00:41.381290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T00:00:00+00:00 PythonOperator 2021-05-10T01:00:19.702686+00:00 2021-05-10T01:00:22.797173+00:00 0:00:03.094487 26370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T01:00:17.362838+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T00:12:31.098057+00:00 2021-05-10T00:20:33.569652+00:00 0:08:02.471595 26368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:12:28.841256+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:12:11.144695+00:00 2021-05-10T00:12:12.950107+00:00 0:00:01.805412 26367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T00:12:08.676403+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T00:11:50.839135+00:00 2021-05-10T00:20:53.589002+00:00 0:09:02.749867 26366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:11:48.649729+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:11:22.690821+00:00 2021-05-10T00:11:24.398123+00:00 0:00:01.707302 26365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T00:11:20.528761+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T23:00:00+00:00 PythonOperator 2021-05-10T00:10:55.117316+00:00 2021-05-10T00:10:58.431876+00:00 0:00:03.314560 26364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:10:52.501147+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T23:00:00+00:00 PythonOperator 2021-05-10T00:10:46.574475+00:00 2021-05-10T00:10:49.638569+00:00 0:00:03.064094 26363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:10:44.495996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T23:00:00+00:00 TriggerDagRunOperator 2021-05-10T00:10:31.021342+00:00 2021-05-10T00:10:31.550564+00:00 0:00:00.529222 26362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:10:28.553361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T23:00:00+00:00 TriggerDagRunOperator 2021-05-10T00:10:30.874713+00:00 2021-05-10T00:10:31.301561+00:00 0:00:00.426848 26361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:10:28.553407+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T23:05:00+00:00 EmrJobFlowSensor 2021-05-10T00:05:48.548823+00:00 2021-05-10T00:14:51.085392+00:00 0:09:02.536569 26360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T00:05:46.153323+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:05:28.328382+00:00 2021-05-10T00:05:30.130521+00:00 0:00:01.802139 26359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T00:05:26.028706+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T23:05:00+00:00 PythonOperator 2021-05-10T00:05:06.203523+00:00 2021-05-10T00:05:09.251248+00:00 0:00:03.047725 26358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:05:04.008054+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T00:01:07.931157+00:00 2021-05-10T00:10:10.796315+00:00 0:09:02.865158 26357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T00:01:05.689348+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T00:00:43.911916+00:00 2021-05-10T00:00:45.644069+00:00 0:00:01.732153 26356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T00:00:41.617348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T23:00:00+00:00 PythonOperator 2021-05-10T00:00:11.814823+00:00 2021-05-10T00:00:14.927705+00:00 0:00:03.112882 26355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T00:00:09.603642+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T22:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:11:20.678111+00:00 2021-05-09T23:21:23.519297+00:00 0:10:02.841186 26353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:11:18.599934+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T22:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:11:19.134426+00:00 2021-05-09T23:19:21.646479+00:00 0:08:02.512053 26352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:11:16.658464+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:10:59.199452+00:00 2021-05-09T23:11:00.871156+00:00 0:00:01.671704 26351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T23:10:56.583970+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:10:56.677984+00:00 2021-05-09T23:10:58.739459+00:00 0:00:02.061475 26350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T23:10:54.525322+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T22:00:00+00:00 PythonOperator 2021-05-09T23:10:38.798915+00:00 2021-05-09T23:10:42.120462+00:00 0:00:03.321547 26349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:10:36.510118+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T22:00:00+00:00 PythonOperator 2021-05-09T23:10:36.740768+00:00 2021-05-09T23:10:39.888551+00:00 0:00:03.147783 26348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:10:34.508658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T22:00:00+00:00 TriggerDagRunOperator 2021-05-09T23:10:20.877051+00:00 2021-05-09T23:10:21.401410+00:00 0:00:00.524359 26347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:10:18.493692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T22:00:00+00:00 TriggerDagRunOperator 2021-05-09T23:10:20.553421+00:00 2021-05-09T23:10:20.958767+00:00 0:00:00.405346 26346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:10:18.493719+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T22:05:00+00:00 EmrJobFlowSensor 2021-05-09T23:06:16.485325+00:00 2021-05-09T23:15:19.309140+00:00 0:09:02.823815 26345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:06:14.152670+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:05:50.379729+00:00 2021-05-09T23:05:52.137744+00:00 0:00:01.758015 26344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T23:05:48.053402+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T22:05:00+00:00 PythonOperator 2021-05-09T23:05:20.255534+00:00 2021-05-09T23:05:23.295041+00:00 0:00:03.039507 26343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:05:18.025095+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-08T23:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:01:16.056477+00:00 2021-05-09T23:10:18.745102+00:00 0:09:02.688625 26342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:01:13.700902+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T22:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:01:05.888050+00:00 2021-05-09T23:10:08.613923+00:00 0:09:02.725873 26341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:01:03.690898+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:00:53.761540+00:00 2021-05-09T23:00:55.494509+00:00 0:00:01.732969 26340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T23:00:51.628559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:00:43.943793+00:00 2021-05-09T23:00:45.812265+00:00 0:00:01.868472 26339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T23:00:41.617720+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-08T23:00:00+00:00 PythonOperator 2021-05-09T23:00:22.278061+00:00 2021-05-09T23:00:25.744229+00:00 0:00:03.466168 26338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:00:19.599951+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T22:00:00+00:00 PythonOperator 2021-05-09T23:00:17.885427+00:00 2021-05-09T23:00:21.640312+00:00 0:00:03.754885 26337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T23:00:15.595877+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T21:00:00+00:00 EmrJobFlowSensor 2021-05-09T22:11:34.988362+00:00 2021-05-09T22:20:37.650538+00:00 0:09:02.662176 26335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:11:32.560892+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T21:00:00+00:00 EmrJobFlowSensor 2021-05-09T22:11:29.021484+00:00 2021-05-09T22:31:33.419910+00:00 0:20:04.398426 26334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:11:26.546907+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:11:12.600448+00:00 2021-05-09T22:11:14.291698+00:00 0:00:01.691250 26333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T22:11:10.464429+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:11:08.795567+00:00 2021-05-09T22:11:10.625460+00:00 0:00:01.829893 26332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T22:11:06.459792+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T21:00:00+00:00 PythonOperator 2021-05-09T22:10:48.575488+00:00 2021-05-09T22:10:51.882571+00:00 0:00:03.307083 26331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:10:46.443948+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T21:00:00+00:00 PythonOperator 2021-05-09T22:10:34.647116+00:00 2021-05-09T22:10:37.711570+00:00 0:00:03.064454 26330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:10:32.433117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T21:00:00+00:00 TriggerDagRunOperator 2021-05-09T22:10:24.838309+00:00 2021-05-09T22:10:25.268151+00:00 0:00:00.429842 26329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:10:22.482575+00:00 2 default_pool