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-03-26T01:05:00+00:00 EmrJobFlowSensor 2021-03-26T02:06:09.912780+00:00 2021-03-26T02:14:12.455418+00:00 0:08:02.542638 11740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T02:06:07.743914+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T01:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T02:05:37.915347+00:00 2021-03-26T02:05:39.672407+00:00 0:00:01.757060 11739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T02:05:35.716661+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T01:05:00+00:00 PythonOperator 2021-03-26T02:05:11.826777+00:00 2021-03-26T02:05:14.560215+00:00 0:00:02.733438 11738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T02:05:09.690059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T01:00:00+00:00 EmrJobFlowSensor 2021-03-26T02:00:49.510650+00:00 2021-03-26T02:09:52.359143+00:00 0:09:02.848493 11737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T02:00:47.229423+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T02:00:27.466116+00:00 2021-03-26T02:00:29.202756+00:00 0:00:01.736640 11736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T02:00:25.211645+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T01:00:00+00:00 PythonOperator 2021-03-26T02:00:05.852734+00:00 2021-03-26T02:00:08.735784+00:00 0:00:02.883050 11735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T02:00:03.340862+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T00:00:00+00:00 EmrJobFlowSensor 2021-03-26T01:11:23.951669+00:00 2021-03-26T01:21:26.949380+00:00 0:10:02.997711 11733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:11:21.544368+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T01:11:01.623838+00:00 2021-03-26T01:11:03.343155+00:00 0:00:01.719317 11732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T01:10:59.371603+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T00:00:00+00:00 PythonOperator 2021-03-26T01:10:39.598563+00:00 2021-03-26T01:10:42.587038+00:00 0:00:02.988475 11731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T01:10:37.349265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T00:00:00+00:00 TriggerDagRunOperator 2021-03-26T01:10:15.572392+00:00 2021-03-26T01:10:16.085027+00:00 0:00:00.512635 11730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:10:13.299205+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T00:00:00+00:00 TriggerDagRunOperator 2021-03-26T01:10:15.526748+00:00 2021-03-26T01:10:15.939477+00:00 0:00:00.412729 11729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:10:13.299174+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T00:05:00+00:00 EmrJobFlowSensor 2021-03-26T01:06:10.966555+00:00 2021-03-26T01:15:13.656421+00:00 0:09:02.689866 11728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:06:08.804801+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T00:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T01:05:49.281609+00:00 2021-03-26T01:05:50.906493+00:00 0:00:01.624884 11727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T01:05:46.864093+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T00:05:00+00:00 PythonOperator 2021-03-26T01:05:26.872484+00:00 2021-03-26T01:05:29.596363+00:00 0:00:02.723879 11726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T01:05:24.731550+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T00:00:00+00:00 EmrJobFlowSensor 2021-03-26T01:00:58.815664+00:00 2021-03-26T01:10:01.536248+00:00 0:09:02.720584 11725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T01:00:56.444303+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T01:00:38.595713+00:00 2021-03-26T01:00:40.297282+00:00 0:00:01.701569 11724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T01:00:36.336179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T00:00:00+00:00 PythonOperator 2021-03-26T01:00:16.589277+00:00 2021-03-26T01:00:19.368373+00:00 0:00:02.779096 11723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T01:00:14.230709+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T23:00:00+00:00 EmrJobFlowSensor 2021-03-26T00:10:27.831070+00:00 2021-03-26T00:20:30.654707+00:00 0:10:02.823637 11721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:10:25.544801+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T00:10:07.712104+00:00 2021-03-26T00:10:09.457212+00:00 0:00:01.745108 11720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T00:10:05.528707+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T23:00:00+00:00 PythonOperator 2021-03-26T00:09:43.721045+00:00 2021-03-26T00:09:46.746240+00:00 0:00:03.025195 11719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T00:09:41.509142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T23:00:00+00:00 TriggerDagRunOperator 2021-03-26T00:09:38.067997+00:00 2021-03-26T00:09:38.922637+00:00 0:00:00.854640 11718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:09:35.570990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T23:00:00+00:00 TriggerDagRunOperator 2021-03-26T00:09:37.867604+00:00 2021-03-26T00:09:38.260681+00:00 0:00:00.393077 11717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:09:35.570941+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T23:05:00+00:00 EmrJobFlowSensor 2021-03-26T00:06:07.363182+00:00 2021-03-26T00:15:09.943456+00:00 0:09:02.580274 11716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:06:05.217039+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T23:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T00:05:45.687057+00:00 2021-03-26T00:05:47.326572+00:00 0:00:01.639515 11715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T00:05:43.263762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T23:05:00+00:00 PythonOperator 2021-03-26T00:05:23.778636+00:00 2021-03-26T00:05:26.608828+00:00 0:00:02.830192 11714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T00:05:21.184296+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T23:00:00+00:00 EmrJobFlowSensor 2021-03-26T00:01:15.011372+00:00 2021-03-26T00:09:17.632450+00:00 0:08:02.621078 11713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T00:01:12.783093+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T00:00:53.062891+00:00 2021-03-26T00:00:54.751089+00:00 0:00:01.688198 11712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T00:00:50.784284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T23:00:00+00:00 PythonOperator 2021-03-26T00:00:24.972656+00:00 2021-03-26T00:00:27.697785+00:00 0:00:02.725129 11711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T00:00:22.730375+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T22:00:00+00:00 EmrJobFlowSensor 2021-03-25T23:12:24.407771+00:00 2021-03-25T23:22:27.326995+00:00 0:10:02.919224 11709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T23:12:22.008640+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T23:12:02.614075+00:00 2021-03-25T23:12:04.412776+00:00 0:00:01.798701 11708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T23:12:00.065120+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T22:00:00+00:00 PythonOperator 2021-03-25T23:11:40.089999+00:00 2021-03-25T23:11:43.062897+00:00 0:00:02.972898 11707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T23:11:37.929772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T22:00:00+00:00 TriggerDagRunOperator 2021-03-25T23:11:14.558707+00:00 2021-03-25T23:11:15.061117+00:00 0:00:00.502410 11706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T23:11:11.978212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T22:00:00+00:00 TriggerDagRunOperator 2021-03-25T23:11:14.407952+00:00 2021-03-25T23:11:14.851133+00:00 0:00:00.443181 11705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T23:11:11.978161+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T22:05:00+00:00 EmrJobFlowSensor 2021-03-25T23:05:49.688498+00:00 2021-03-25T23:14:52.299680+00:00 0:09:02.611182 11704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T23:05:47.414970+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T22:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T23:05:27.555514+00:00 2021-03-25T23:05:29.192474+00:00 0:00:01.636960 11703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T23:05:25.388207+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T22:05:00+00:00 PythonOperator 2021-03-25T23:05:05.559001+00:00 2021-03-25T23:05:08.236002+00:00 0:00:02.677001 11702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T23:05:03.353626+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T22:00:00+00:00 EmrJobFlowSensor 2021-03-25T23:00:57.235157+00:00 2021-03-25T23:11:00.089381+00:00 0:10:02.854224 11701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T23:00:55.055805+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T23:00:35.255320+00:00 2021-03-25T23:00:37.074675+00:00 0:00:01.819355 11700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T23:00:33.013325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T22:00:00+00:00 PythonOperator 2021-03-25T23:00:11.305918+00:00 2021-03-25T23:00:14.112830+00:00 0:00:02.806912 11699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T23:00:09.053668+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T21:00:00+00:00 EmrJobFlowSensor 2021-03-25T22:20:15.585778+00:00 2021-03-25T22:30:18.505870+00:00 0:10:02.920092 11698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:20:13.332107+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T22:19:53.601657+00:00 2021-03-25T22:19:55.555291+00:00 0:00:01.953634 11697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T22:19:51.317596+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T21:00:00+00:00 PythonOperator 2021-03-25T22:19:33.611715+00:00 2021-03-25T22:19:36.533589+00:00 0:00:02.921874 11696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T22:19:31.302476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T21:00:00+00:00 TriggerDagRunOperator 2021-03-25T22:19:09.796569+00:00 2021-03-25T22:19:10.265814+00:00 0:00:00.469245 11695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:19:07.244622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T21:00:00+00:00 TriggerDagRunOperator 2021-03-25T22:19:09.783995+00:00 2021-03-25T22:19:10.343123+00:00 0:00:00.559128 11694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:19:07.244593+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T21:05:00+00:00 EmrJobFlowSensor 2021-03-25T22:05:53.774068+00:00 2021-03-25T22:14:56.357707+00:00 0:09:02.583639 11692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:05:51.458177+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T21:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T22:05:33.506726+00:00 2021-03-25T22:05:35.162528+00:00 0:00:01.655802 11691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T22:05:31.363029+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T21:05:00+00:00 PythonOperator 2021-03-25T22:05:11.385215+00:00 2021-03-25T22:05:14.080332+00:00 0:00:02.695117 11690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T22:05:09.240032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T21:00:00+00:00 EmrJobFlowSensor 2021-03-25T22:00:49.119905+00:00 2021-03-25T22:18:53.033800+00:00 0:18:03.913895 11689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T22:00:46.900364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T22:00:29.017348+00:00 2021-03-25T22:00:30.716783+00:00 0:00:01.699435 11688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T22:00:26.823724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T21:00:00+00:00 PythonOperator 2021-03-25T22:00:07.545141+00:00 2021-03-25T22:00:10.401270+00:00 0:00:02.856129 11687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T22:00:04.805247+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T20:00:00+00:00 EmrJobFlowSensor 2021-03-25T21:10:12.803424+00:00 2021-03-25T21:19:15.391654+00:00 0:09:02.588230 11685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:10:10.593506+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T21:09:50.787749+00:00 2021-03-25T21:09:52.583815+00:00 0:00:01.796066 11684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T21:09:48.563710+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T20:00:00+00:00 PythonOperator 2021-03-25T21:09:29.047142+00:00 2021-03-25T21:09:32.153873+00:00 0:00:03.106731 11683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T21:09:26.542600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T20:00:00+00:00 TriggerDagRunOperator 2021-03-25T21:09:23.000653+00:00 2021-03-25T21:09:23.400653+00:00 0:00:00.400000 11682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:09:20.543943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T20:00:00+00:00 TriggerDagRunOperator 2021-03-25T21:09:22.893807+00:00 2021-03-25T21:09:23.422147+00:00 0:00:00.528340 11681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:09:20.543912+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T20:05:00+00:00 EmrJobFlowSensor 2021-03-25T21:05:48.516725+00:00 2021-03-25T21:14:51.197930+00:00 0:09:02.681205 11680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:05:46.281961+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T20:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T21:05:26.481072+00:00 2021-03-25T21:05:28.289362+00:00 0:00:01.808290 11679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T21:05:24.230645+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T20:05:00+00:00 PythonOperator 2021-03-25T21:05:06.387274+00:00 2021-03-25T21:05:09.087536+00:00 0:00:02.700262 11678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T21:05:04.213704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T20:00:00+00:00 EmrJobFlowSensor 2021-03-25T21:01:06.207454+00:00 2021-03-25T21:09:08.899768+00:00 0:08:02.692314 11677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T21:01:03.871482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T21:00:46.106952+00:00 2021-03-25T21:00:47.769313+00:00 0:00:01.662361 11676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T21:00:43.853126+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T20:00:00+00:00 PythonOperator 2021-03-25T21:00:24.664132+00:00 2021-03-25T21:00:27.560047+00:00 0:00:02.895915 11675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T21:00:21.863892+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T19:00:00+00:00 EmrJobFlowSensor 2021-03-25T20:10:21.427875+00:00 2021-03-25T20:20:24.259233+00:00 0:10:02.831358 11673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:10:19.223099+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T20:09:59.536724+00:00 2021-03-25T20:10:01.229214+00:00 0:00:01.692490 11672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T20:09:57.207328+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T19:00:00+00:00 PythonOperator 2021-03-25T20:09:39.417037+00:00 2021-03-25T20:09:42.539708+00:00 0:00:03.122671 11671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T20:09:37.185207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T19:00:00+00:00 TriggerDagRunOperator 2021-03-25T20:09:25.464853+00:00 2021-03-25T20:09:25.885018+00:00 0:00:00.420165 11670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:09:23.156336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T19:00:00+00:00 TriggerDagRunOperator 2021-03-25T20:09:25.380464+00:00 2021-03-25T20:09:25.939048+00:00 0:00:00.558584 11669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:09:23.156370+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T19:05:00+00:00 EmrJobFlowSensor 2021-03-25T20:06:13.050152+00:00 2021-03-25T20:15:15.667201+00:00 0:09:02.617049 11668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:06:10.791908+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T20:05:44.857258+00:00 2021-03-25T20:05:46.562838+00:00 0:00:01.705580 11667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T20:05:42.744608+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T19:05:00+00:00 PythonOperator 2021-03-25T20:05:22.987673+00:00 2021-03-25T20:05:25.754071+00:00 0:00:02.766398 11666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T20:05:20.727954+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T19:00:00+00:00 EmrJobFlowSensor 2021-03-25T20:00:58.721030+00:00 2021-03-25T20:09:01.368499+00:00 0:08:02.647469 11665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T20:00:56.366355+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T20:00:36.804349+00:00 2021-03-25T20:00:38.591950+00:00 0:00:01.787601 11664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T20:00:34.359411+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T19:00:00+00:00 PythonOperator 2021-03-25T20:00:12.661190+00:00 2021-03-25T20:00:15.552390+00:00 0:00:02.891200 11663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T20:00:10.243771+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T18:00:00+00:00 EmrJobFlowSensor 2021-03-25T19:10:12.657581+00:00 2021-03-25T19:20:15.525299+00:00 0:10:02.867718 11661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:10:10.402853+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:09:50.797963+00:00 2021-03-25T19:09:52.575686+00:00 0:00:01.777723 11660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T19:09:48.444102+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T18:00:00+00:00 PythonOperator 2021-03-25T19:09:31.127307+00:00 2021-03-25T19:09:34.033010+00:00 0:00:02.905703 11659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:09:28.357140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T18:00:00+00:00 TriggerDagRunOperator 2021-03-25T19:09:18.449915+00:00 2021-03-25T19:09:18.977263+00:00 0:00:00.527348 11658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:09:16.195283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T18:00:00+00:00 TriggerDagRunOperator 2021-03-25T19:09:18.412976+00:00 2021-03-25T19:09:18.888433+00:00 0:00:00.475457 11657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:09:16.195311+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T18:05:00+00:00 EmrJobFlowSensor 2021-03-25T19:06:04.046495+00:00 2021-03-25T19:15:06.687821+00:00 0:09:02.641326 11656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:06:01.769919+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:05:41.781290+00:00 2021-03-25T19:05:43.434898+00:00 0:00:01.653608 11655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T19:05:39.684900+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T18:05:00+00:00 PythonOperator 2021-03-25T19:05:19.855518+00:00 2021-03-25T19:05:22.649306+00:00 0:00:02.793788 11654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:05:17.661154+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T18:00:00+00:00 EmrJobFlowSensor 2021-03-25T19:00:55.515475+00:00 2021-03-25T19:08:57.921628+00:00 0:08:02.406153 11653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:00:53.333643+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:00:33.885152+00:00 2021-03-25T19:00:35.654976+00:00 0:00:01.769824 11652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T19:00:31.375853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T18:00:00+00:00 PythonOperator 2021-03-25T19:00:11.979176+00:00 2021-03-25T19:00:14.740453+00:00 0:00:02.761277 11651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T19:00:09.366675+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T17:00:00+00:00 EmrJobFlowSensor 2021-03-25T18:11:36.317743+00:00 2021-03-25T18:21:39.064901+00:00 0:10:02.747158 11649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:11:34.066056+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:11:16.248556+00:00 2021-03-25T18:11:18.056998+00:00 0:00:01.808442 11648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T18:11:14.012374+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T17:00:00+00:00 PythonOperator 2021-03-25T18:10:54.497954+00:00 2021-03-25T18:10:57.528105+00:00 0:00:03.030151 11647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:10:51.993055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T17:00:00+00:00 TriggerDagRunOperator 2021-03-25T18:10:32.401679+00:00 2021-03-25T18:10:32.916342+00:00 0:00:00.514663 11646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:10:30.041026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T17:00:00+00:00 TriggerDagRunOperator 2021-03-25T18:10:32.334309+00:00 2021-03-25T18:10:32.813024+00:00 0:00:00.478715 11645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:10:30.041077+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T17:05:00+00:00 EmrJobFlowSensor 2021-03-25T18:05:47.835632+00:00 2021-03-25T18:14:50.415332+00:00 0:09:02.579700 11644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:05:45.659409+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:05:25.850214+00:00 2021-03-25T18:05:27.586663+00:00 0:00:01.736449 11643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T18:05:23.638332+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T17:05:00+00:00 PythonOperator 2021-03-25T18:05:03.855025+00:00 2021-03-25T18:05:06.579467+00:00 0:00:02.724442 11642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:05:01.608507+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T17:00:00+00:00 EmrJobFlowSensor 2021-03-25T18:00:53.667795+00:00 2021-03-25T18:09:56.377907+00:00 0:09:02.710112 11641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:00:51.311837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:00:31.461454+00:00 2021-03-25T18:00:33.191291+00:00 0:00:01.729837 11640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T18:00:29.291717+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T17:00:00+00:00 PythonOperator 2021-03-25T18:00:11.521223+00:00 2021-03-25T18:00:14.350348+00:00 0:00:02.829125 11639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T18:00:09.229702+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T16:00:00+00:00 EmrJobFlowSensor 2021-03-25T17:12:12.638419+00:00 2021-03-25T17:22:15.448299+00:00 0:10:02.809880 11637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:12:10.391905+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T17:11:50.757852+00:00 2021-03-25T17:11:52.524431+00:00 0:00:01.766579 11636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T17:11:48.353797+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T16:00:00+00:00 PythonOperator 2021-03-25T17:11:28.499715+00:00 2021-03-25T17:11:31.455010+00:00 0:00:02.955295 11635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T17:11:26.326621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T16:00:00+00:00 TriggerDagRunOperator 2021-03-25T17:11:14.711556+00:00 2021-03-25T17:11:15.198945+00:00 0:00:00.487389 11634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:11:12.302753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T16:00:00+00:00 TriggerDagRunOperator 2021-03-25T17:11:14.521346+00:00 2021-03-25T17:11:14.898784+00:00 0:00:00.377438 11633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:11:12.302706+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T16:05:00+00:00 EmrJobFlowSensor 2021-03-25T17:06:06.047295+00:00 2021-03-25T17:15:08.594714+00:00 0:09:02.547419 11632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:06:03.927469+00:00 2 default_pool