Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success booking-processing-job_v002 create_emr_steps 2021-04-12T21:00:00+00:00 PythonOperator 2021-04-12T22:09:06.232118+00:00 2021-04-12T22:09:09.141234+00:00 0:00:02.909116 16510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:09:03.891404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T21:00:00+00:00 TriggerDagRunOperator 2021-04-12T22:09:00.750747+00:00 2021-04-12T22:09:01.156860+00:00 0:00:00.406113 16509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:08:57.956906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T21:00:00+00:00 TriggerDagRunOperator 2021-04-12T22:09:00.537255+00:00 2021-04-12T22:09:01.085051+00:00 0:00:00.547796 16508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:08:57.956874+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T21:05:00+00:00 EmrJobFlowSensor 2021-04-12T22:05:51.807427+00:00 2021-04-12T22:14:54.468575+00:00 0:09:02.661148 16507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:05:49.679066+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:05:28.002313+00:00 2021-04-12T22:05:29.632210+00:00 0:00:01.629897 16506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T22:05:25.669069+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T21:05:00+00:00 PythonOperator 2021-04-12T22:05:08.084915+00:00 2021-04-12T22:05:10.753289+00:00 0:00:02.668374 16505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:05:05.644638+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T21:00:00+00:00 EmrJobFlowSensor 2021-04-12T22:00:51.392173+00:00 2021-04-12T22:08:53.937850+00:00 0:08:02.545677 16504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:00:49.089689+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:00:29.563004+00:00 2021-04-12T22:00:31.236769+00:00 0:00:01.673765 16503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T22:00:27.063621+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T21:00:00+00:00 PythonOperator 2021-04-12T22:00:07.635171+00:00 2021-04-12T22:00:10.357472+00:00 0:00:02.722301 16502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T22:00:05.052891+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T20:00:00+00:00 EmrJobFlowSensor 2021-04-12T21:23:56.731778+00:00 2021-04-12T21:23:58.211610+00:00 0:00:01.479832 16500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:23:54.476141+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T20:00:00+00:00 EmrJobFlowSensor 2021-04-12T21:11:21.730181+00:00 2021-04-12T21:20:24.421133+00:00 0:09:02.690952 16498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:11:19.425036+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:11:11.608100+00:00 2021-04-12T21:11:13.392344+00:00 0:00:01.784244 16497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T21:11:09.414255+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:11:00.181612+00:00 2021-04-12T21:11:02.232976+00:00 0:00:02.051364 16496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T21:10:57.405023+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T20:00:00+00:00 PythonOperator 2021-04-12T21:10:49.949247+00:00 2021-04-12T21:10:53.023753+00:00 0:00:03.074506 16495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T21:10:47.481348+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T20:00:00+00:00 PythonOperator 2021-04-12T21:10:37.616173+00:00 2021-04-12T21:10:40.300792+00:00 0:00:02.684619 16494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T21:10:35.394170+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T20:00:00+00:00 TriggerDagRunOperator 2021-04-12T21:10:33.744260+00:00 2021-04-12T21:10:34.261327+00:00 0:00:00.517067 16493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:10:31.376472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T20:00:00+00:00 TriggerDagRunOperator 2021-04-12T21:10:33.607237+00:00 2021-04-12T21:10:34.079154+00:00 0:00:00.471917 16492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:10:31.376442+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T20:05:00+00:00 EmrJobFlowSensor 2021-04-12T21:05:59.098128+00:00 2021-04-12T21:15:01.689806+00:00 0:09:02.591678 16491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:05:56.895955+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:05:38.985156+00:00 2021-04-12T21:05:40.627780+00:00 0:00:01.642624 16490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T21:05:36.875721+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T20:05:00+00:00 PythonOperator 2021-04-12T21:05:15.345281+00:00 2021-04-12T21:05:18.132213+00:00 0:00:02.786932 16489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T21:05:12.814802+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T20:00:00+00:00 EmrJobFlowSensor 2021-04-12T21:01:12.628871+00:00 2021-04-12T21:10:15.274810+00:00 0:09:02.645939 16488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T21:01:10.468765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:00:48.822920+00:00 2021-04-12T21:00:50.667810+00:00 0:00:01.844890 16487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T21:00:46.445458+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T20:00:00+00:00 PythonOperator 2021-04-12T21:00:22.793469+00:00 2021-04-12T21:00:25.524938+00:00 0:00:02.731469 16486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T21:00:20.422386+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T19:00:00+00:00 EmrJobFlowSensor 2021-04-12T20:10:21.004685+00:00 2021-04-12T20:31:25.264417+00:00 0:21:04.259732 16484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:10:18.785964+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T19:00:00+00:00 EmrJobFlowSensor 2021-04-12T20:10:19.304986+00:00 2021-04-12T20:19:22.028598+00:00 0:09:02.723612 16483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:10:16.786080+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T20:09:59.253105+00:00 2021-04-12T20:10:01.053538+00:00 0:00:01.800433 16482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T20:09:56.732326+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T20:09:59.160638+00:00 2021-04-12T20:10:00.880559+00:00 0:00:01.719921 16481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T20:09:56.732258+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T19:00:00+00:00 PythonOperator 2021-04-12T20:09:37.230458+00:00 2021-04-12T20:09:40.056543+00:00 0:00:02.826085 16480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T20:09:34.764369+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T19:00:00+00:00 PythonOperator 2021-04-12T20:09:37.134413+00:00 2021-04-12T20:09:40.138425+00:00 0:00:03.004012 16479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T20:09:34.764402+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T19:00:00+00:00 TriggerDagRunOperator 2021-04-12T20:09:23.112709+00:00 2021-04-12T20:09:23.865689+00:00 0:00:00.752980 16478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:09:20.702496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T19:00:00+00:00 TriggerDagRunOperator 2021-04-12T20:09:23.021050+00:00 2021-04-12T20:09:23.648746+00:00 0:00:00.627696 16477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:09:20.702545+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T19:05:00+00:00 EmrJobFlowSensor 2021-04-12T20:06:52.826884+00:00 2021-04-12T20:15:55.294312+00:00 0:09:02.467428 16476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:06:50.521481+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T20:06:30.720542+00:00 2021-04-12T20:06:32.823673+00:00 0:00:02.103131 16475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T20:06:28.498509+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T19:05:00+00:00 PythonOperator 2021-04-12T20:05:14.625555+00:00 2021-04-12T20:05:17.508717+00:00 0:00:02.883162 16474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T20:05:12.378554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T19:00:00+00:00 EmrJobFlowSensor 2021-04-12T20:01:06.895732+00:00 2021-04-12T20:09:09.463808+00:00 0:08:02.568076 16473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T20:01:04.090727+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T20:00:44.300213+00:00 2021-04-12T20:00:45.972368+00:00 0:00:01.672155 16472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T20:00:42.076440+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T19:00:00+00:00 PythonOperator 2021-04-12T20:00:24.424648+00:00 2021-04-12T20:00:27.133286+00:00 0:00:02.708638 16471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T20:00:22.049627+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T18:00:00+00:00 EmrJobFlowSensor 2021-04-12T19:12:18.227555+00:00 2021-04-12T19:22:21.135961+00:00 0:10:02.908406 16469 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:12:15.894174+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T18:00:00+00:00 EmrJobFlowSensor 2021-04-12T19:12:14.293630+00:00 2021-04-12T19:20:16.949716+00:00 0:08:02.656086 16468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:12:11.886863+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T19:11:56.657340+00:00 2021-04-12T19:11:58.348744+00:00 0:00:01.691404 16467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T19:11:53.866031+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T19:11:54.342453+00:00 2021-04-12T19:11:56.431066+00:00 0:00:02.088613 16466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T19:11:51.853458+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T18:00:00+00:00 PythonOperator 2021-04-12T19:11:36.284975+00:00 2021-04-12T19:11:39.247741+00:00 0:00:02.962766 16465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T19:11:33.813633+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T18:00:00+00:00 PythonOperator 2021-04-12T19:11:32.180505+00:00 2021-04-12T19:11:35.246540+00:00 0:00:03.066035 16464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T19:11:29.858096+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T18:00:00+00:00 TriggerDagRunOperator 2021-04-12T19:11:10.494080+00:00 2021-04-12T19:11:11.064266+00:00 0:00:00.570186 16463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:11:07.856902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T18:00:00+00:00 TriggerDagRunOperator 2021-04-12T19:11:10.288449+00:00 2021-04-12T19:11:10.759796+00:00 0:00:00.471347 16462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:11:07.856874+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T18:05:00+00:00 EmrJobFlowSensor 2021-04-12T19:06:09.616746+00:00 2021-04-12T19:15:12.276652+00:00 0:09:02.659906 16461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:06:07.344403+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T19:05:47.586459+00:00 2021-04-12T19:05:49.212924+00:00 0:00:01.626465 16460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T19:05:45.380443+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T18:05:00+00:00 PythonOperator 2021-04-12T19:05:21.400126+00:00 2021-04-12T19:05:24.170180+00:00 0:00:02.770054 16459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T19:05:19.304583+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T18:00:00+00:00 EmrJobFlowSensor 2021-04-12T19:01:03.409285+00:00 2021-04-12T19:11:06.232103+00:00 0:10:02.822818 16458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T19:01:00.952429+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T19:00:40.993083+00:00 2021-04-12T19:00:42.813902+00:00 0:00:01.820819 16457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T19:00:38.815363+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T18:00:00+00:00 PythonOperator 2021-04-12T19:00:21.225610+00:00 2021-04-12T19:00:24.078920+00:00 0:00:02.853310 16456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T19:00:18.851958+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T17:00:00+00:00 EmrJobFlowSensor 2021-04-12T18:09:55.510601+00:00 2021-04-12T18:18:58.063226+00:00 0:09:02.552625 16454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:09:53.209650+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T17:00:00+00:00 EmrJobFlowSensor 2021-04-12T18:09:51.532680+00:00 2021-04-12T18:18:54.175897+00:00 0:09:02.643217 16453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:09:49.271350+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:09:35.722190+00:00 2021-04-12T18:09:37.530695+00:00 0:00:01.808505 16452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T18:09:33.248312+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:09:29.628854+00:00 2021-04-12T18:09:31.304738+00:00 0:00:01.675884 16451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T18:09:27.189556+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T17:00:00+00:00 PythonOperator 2021-04-12T18:09:13.484327+00:00 2021-04-12T18:09:16.215944+00:00 0:00:02.731617 16450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:09:11.145968+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T17:00:00+00:00 PythonOperator 2021-04-12T18:09:09.860897+00:00 2021-04-12T18:09:13.152141+00:00 0:00:03.291244 16449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:09:07.142869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T17:00:00+00:00 TriggerDagRunOperator 2021-04-12T18:08:59.565343+00:00 2021-04-12T18:09:00.087049+00:00 0:00:00.521706 16448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:08:57.135727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T17:00:00+00:00 TriggerDagRunOperator 2021-04-12T18:08:59.435741+00:00 2021-04-12T18:08:59.867141+00:00 0:00:00.431400 16447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:08:57.135695+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T17:05:00+00:00 EmrJobFlowSensor 2021-04-12T18:06:14.981657+00:00 2021-04-12T18:15:17.678700+00:00 0:09:02.697043 16446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:06:12.813017+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:05:55.059239+00:00 2021-04-12T18:05:56.681283+00:00 0:00:01.622044 16445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T18:05:52.794975+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T17:05:00+00:00 PythonOperator 2021-04-12T18:05:24.976025+00:00 2021-04-12T18:05:27.746994+00:00 0:00:02.770969 16444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:05:22.769133+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T17:00:00+00:00 EmrJobFlowSensor 2021-04-12T18:00:46.664462+00:00 2021-04-12T18:08:49.295853+00:00 0:08:02.631391 16443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:00:44.367538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:00:26.515590+00:00 2021-04-12T18:00:28.301798+00:00 0:00:01.786208 16442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T18:00:24.295528+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T17:00:00+00:00 PythonOperator 2021-04-12T18:00:04.564059+00:00 2021-04-12T18:00:07.339899+00:00 0:00:02.775840 16441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T18:00:02.214194+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:12:11.049197+00:00 2021-04-12T17:21:13.699946+00:00 0:09:02.650749 16439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:12:08.891513+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:12:07.037750+00:00 2021-04-12T17:21:09.725126+00:00 0:09:02.687376 16438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:12:04.887170+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:11:48.999866+00:00 2021-04-12T17:11:50.639283+00:00 0:00:01.639417 16437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:11:46.796360+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:11:45.317904+00:00 2021-04-12T17:11:47.014783+00:00 0:00:01.696879 16436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:11:42.851041+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:11:27.034139+00:00 2021-04-12T17:11:29.729697+00:00 0:00:02.695558 16435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:11:24.767290+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:11:25.194661+00:00 2021-04-12T17:11:28.349244+00:00 0:00:03.154583 16434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:11:22.767775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T16:00:00+00:00 TriggerDagRunOperator 2021-04-12T17:11:10.910959+00:00 2021-04-12T17:11:11.316629+00:00 0:00:00.405670 16433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:11:08.690641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T16:00:00+00:00 TriggerDagRunOperator 2021-04-12T17:11:10.919404+00:00 2021-04-12T17:11:11.464392+00:00 0:00:00.544988 16432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:11:08.690678+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T16:05:00+00:00 EmrJobFlowSensor 2021-04-12T17:05:58.502918+00:00 2021-04-12T17:15:01.179260+00:00 0:09:02.676342 16431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:05:56.104040+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:05:36.845938+00:00 2021-04-12T17:05:38.633370+00:00 0:00:01.787432 16430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:05:34.090414+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T16:05:00+00:00 PythonOperator 2021-04-12T17:05:08.335149+00:00 2021-04-12T17:05:11.006528+00:00 0:00:02.671379 16429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:05:06.048902+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:00:55.755059+00:00 2021-04-12T17:10:58.469341+00:00 0:10:02.714282 16428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:00:53.583213+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:00:33.858864+00:00 2021-04-12T17:00:35.773891+00:00 0:00:01.915027 16427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T17:00:31.553256+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:00:11.819539+00:00 2021-04-12T17:00:14.522780+00:00 0:00:02.703241 16426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T17:00:09.537740+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T15:00:00+00:00 EmrJobFlowSensor 2021-04-12T16:13:21.942842+00:00 2021-04-12T16:22:24.650414+00:00 0:09:02.707572 16424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:13:19.694097+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:12:59.907991+00:00 2021-04-12T16:13:01.684788+00:00 0:00:01.776797 16423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T16:12:57.651085+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T15:00:00+00:00 EmrJobFlowSensor 2021-04-12T16:12:27.798713+00:00 2021-04-12T16:22:30.534895+00:00 0:10:02.736182 16422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:12:25.608544+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:12:04.155539+00:00 2021-04-12T16:12:05.995424+00:00 0:00:01.839885 16421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T16:12:01.652379+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T15:00:00+00:00 PythonOperator 2021-04-12T16:11:45.891762+00:00 2021-04-12T16:11:48.724647+00:00 0:00:02.832885 16420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:11:43.563539+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T15:00:00+00:00 PythonOperator 2021-04-12T16:11:41.714242+00:00 2021-04-12T16:11:44.919444+00:00 0:00:03.205202 16419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:11:39.562567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T15:00:00+00:00 TriggerDagRunOperator 2021-04-12T16:11:18.086995+00:00 2021-04-12T16:11:18.656028+00:00 0:00:00.569033 16418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:11:15.544380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T15:00:00+00:00 TriggerDagRunOperator 2021-04-12T16:11:17.887732+00:00 2021-04-12T16:11:18.286858+00:00 0:00:00.399126 16417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:11:15.544349+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T15:05:00+00:00 EmrJobFlowSensor 2021-04-12T16:07:03.563706+00:00 2021-04-12T16:16:06.314162+00:00 0:09:02.750456 16416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:07:01.275427+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:06:43.375072+00:00 2021-04-12T16:06:45.751509+00:00 0:00:02.376437 16415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T16:06:41.212131+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T15:05:00+00:00 PythonOperator 2021-04-12T16:06:21.365778+00:00 2021-04-12T16:06:24.199466+00:00 0:00:02.833688 16414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:06:19.194186+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T15:00:00+00:00 EmrJobFlowSensor 2021-04-12T16:00:59.128922+00:00 2021-04-12T16:11:01.989928+00:00 0:10:02.861006 16413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:00:56.632061+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:00:36.822035+00:00 2021-04-12T16:00:38.532956+00:00 0:00:01.710921 16412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T16:00:34.614781+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T15:00:00+00:00 PythonOperator 2021-04-12T16:00:15.010129+00:00 2021-04-12T16:00:17.784138+00:00 0:00:02.774009 16411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T16:00:12.598565+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T14:00:00+00:00 EmrJobFlowSensor 2021-04-12T15:11:29.140065+00:00 2021-04-12T15:21:31.993547+00:00 0:10:02.853482 16409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:11:26.773544+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T14:00:00+00:00 EmrJobFlowSensor 2021-04-12T15:11:11.002700+00:00 2021-04-12T15:19:13.581597+00:00 0:08:02.578897 16408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:11:08.704721+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T15:11:07.090736+00:00 2021-04-12T15:11:08.768762+00:00 0:00:01.678026 16407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T15:11:04.745246+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T15:10:50.903701+00:00 2021-04-12T15:10:52.695728+00:00 0:00:01.792027 16406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T15:10:48.683039+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T14:00:00+00:00 PythonOperator 2021-04-12T15:10:44.993477+00:00 2021-04-12T15:10:48.355433+00:00 0:00:03.361956 16405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T15:10:42.673686+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T14:00:00+00:00 PythonOperator 2021-04-12T15:10:28.981387+00:00 2021-04-12T15:10:31.689131+00:00 0:00:02.707744 16404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T15:10:26.660695+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T14:00:00+00:00 TriggerDagRunOperator 2021-04-12T15:10:21.013794+00:00 2021-04-12T15:10:21.540395+00:00 0:00:00.526601 16403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:10:18.656850+00:00 2 default_pool