Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:05:41.393359+00:00 2021-04-05T22:05:43.032426+00:00 0:00:01.639067 13984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T22:05:39.192303+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T21:05:00+00:00 PythonOperator 2021-04-05T22:05:19.588718+00:00 2021-04-05T22:05:22.391574+00:00 0:00:02.802856 13983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:05:17.144032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T21:00:00+00:00 EmrJobFlowSensor 2021-04-05T22:00:46.852529+00:00 2021-04-05T22:10:49.727257+00:00 0:10:02.874728 13982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:00:44.589928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:00:26.715661+00:00 2021-04-05T22:00:28.465412+00:00 0:00:01.749751 13981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T22:00:24.566237+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T21:00:00+00:00 PythonOperator 2021-04-05T22:00:05.096757+00:00 2021-04-05T22:00:07.976803+00:00 0:00:02.880046 13980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T22:00:02.549373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:12:13.894381+00:00 2021-04-05T21:22:16.651932+00:00 0:10:02.757551 13978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:12:11.642775+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:12:09.921104+00:00 2021-04-05T21:20:12.454623+00:00 0:08:02.533519 13977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:12:07.650806+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:11:51.932262+00:00 2021-04-05T21:11:53.725710+00:00 0:00:01.793448 13976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T21:11:49.626905+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:11:48.014154+00:00 2021-04-05T21:11:49.920804+00:00 0:00:01.906650 13975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T21:11:45.624491+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:11:30.393341+00:00 2021-04-05T21:11:33.376621+00:00 0:00:02.983280 13974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:11:27.748142+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:11:26.172653+00:00 2021-04-05T21:11:29.140944+00:00 0:00:02.968291 13973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:11:23.674470+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T20:00:00+00:00 TriggerDagRunOperator 2021-04-05T21:11:18.233904+00:00 2021-04-05T21:11:18.776973+00:00 0:00:00.543069 13972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:11:15.598674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T20:00:00+00:00 TriggerDagRunOperator 2021-04-05T21:11:17.907121+00:00 2021-04-05T21:11:18.336125+00:00 0:00:00.429004 13971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:11:15.598721+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T20:05:00+00:00 EmrJobFlowSensor 2021-04-05T21:06:01.494531+00:00 2021-04-05T21:15:04.171022+00:00 0:09:02.676491 13970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:05:59.167999+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:05:39.598994+00:00 2021-04-05T21:05:41.303180+00:00 0:00:01.704186 13969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T21:05:37.153549+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T20:05:00+00:00 PythonOperator 2021-04-05T21:05:19.548415+00:00 2021-04-05T21:05:22.288796+00:00 0:00:02.740381 13968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:05:17.149403+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:01:07.135290+00:00 2021-04-05T21:11:10.043234+00:00 0:10:02.907944 13967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:01:04.740837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:00:44.987431+00:00 2021-04-05T21:00:46.761780+00:00 0:00:01.774349 13966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T21:00:42.655616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:00:24.927404+00:00 2021-04-05T21:00:27.694804+00:00 0:00:02.767400 13965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T21:00:22.549956+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T19:00:00+00:00 EmrJobFlowSensor 2021-04-05T20:11:59.387146+00:00 2021-04-05T20:21:02.139979+00:00 0:09:02.752833 13963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:11:57.166326+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T19:00:00+00:00 EmrJobFlowSensor 2021-04-05T20:11:51.355666+00:00 2021-04-05T20:19:54.017763+00:00 0:08:02.662097 13962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:11:49.154218+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:11:37.383414+00:00 2021-04-05T20:11:39.097500+00:00 0:00:01.714086 13961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T20:11:35.143207+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:11:29.281886+00:00 2021-04-05T20:11:30.974101+00:00 0:00:01.692215 13960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T20:11:27.063033+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T19:00:00+00:00 PythonOperator 2021-04-05T20:11:17.314174+00:00 2021-04-05T20:11:20.417702+00:00 0:00:03.103528 13959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:11:15.055397+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T19:00:00+00:00 PythonOperator 2021-04-05T20:11:09.575444+00:00 2021-04-05T20:11:12.271493+00:00 0:00:02.696049 13958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:11:07.042987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T19:00:00+00:00 TriggerDagRunOperator 2021-04-05T20:10:57.349531+00:00 2021-04-05T20:10:57.900544+00:00 0:00:00.551013 13957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:10:55.040026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T19:00:00+00:00 TriggerDagRunOperator 2021-04-05T20:10:57.289060+00:00 2021-04-05T20:10:57.686340+00:00 0:00:00.397280 13956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:10:55.040063+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T19:05:00+00:00 EmrJobFlowSensor 2021-04-05T20:05:50.864866+00:00 2021-04-05T20:14:53.508293+00:00 0:09:02.643427 13955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:05:48.571938+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:05:28.776015+00:00 2021-04-05T20:05:30.404617+00:00 0:00:01.628602 13954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T20:05:26.485859+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T19:05:00+00:00 PythonOperator 2021-04-05T20:05:08.931906+00:00 2021-04-05T20:05:11.679049+00:00 0:00:02.747143 13953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:05:06.468081+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T19:00:00+00:00 EmrJobFlowSensor 2021-04-05T20:00:50.258773+00:00 2021-04-05T20:10:53.033973+00:00 0:10:02.775200 13952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:00:48.002910+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:00:28.509566+00:00 2021-04-05T20:00:30.202239+00:00 0:00:01.692673 13951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T20:00:26.055817+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T19:00:00+00:00 PythonOperator 2021-04-05T20:00:08.785981+00:00 2021-04-05T20:00:11.548716+00:00 0:00:02.762735 13950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T20:00:05.957785+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T18:00:00+00:00 EmrJobFlowSensor 2021-04-05T19:11:21.179184+00:00 2021-04-05T19:21:23.950267+00:00 0:10:02.771083 13948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:11:18.961821+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T18:00:00+00:00 EmrJobFlowSensor 2021-04-05T19:11:19.426148+00:00 2021-04-05T19:21:22.360874+00:00 0:10:02.934726 13947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:11:16.962265+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T19:11:01.589555+00:00 2021-04-05T19:11:03.318430+00:00 0:00:01.728875 13946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T19:10:59.047266+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T19:10:59.102486+00:00 2021-04-05T19:11:00.841006+00:00 0:00:01.738520 13945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T19:10:56.896558+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T18:00:00+00:00 PythonOperator 2021-04-05T19:10:38.972415+00:00 2021-04-05T19:10:41.660211+00:00 0:00:02.687796 13944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T19:10:36.812432+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T18:00:00+00:00 PythonOperator 2021-04-05T19:10:37.085200+00:00 2021-04-05T19:10:40.169659+00:00 0:00:03.084459 13943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T19:10:34.812050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T18:00:00+00:00 TriggerDagRunOperator 2021-04-05T19:10:17.415191+00:00 2021-04-05T19:10:17.966860+00:00 0:00:00.551669 13942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:10:14.860299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T18:00:00+00:00 TriggerDagRunOperator 2021-04-05T19:10:17.258713+00:00 2021-04-05T19:10:17.688555+00:00 0:00:00.429842 13941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:10:14.860348+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T18:05:00+00:00 EmrJobFlowSensor 2021-04-05T19:06:04.609336+00:00 2021-04-05T19:15:07.226477+00:00 0:09:02.617141 13940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:06:02.400049+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T19:05:40.676055+00:00 2021-04-05T19:05:42.390383+00:00 0:00:01.714328 13939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T19:05:38.382458+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T18:05:00+00:00 PythonOperator 2021-04-05T19:05:20.590102+00:00 2021-04-05T19:05:23.332769+00:00 0:00:02.742667 13938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T19:05:18.358215+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T18:00:00+00:00 EmrJobFlowSensor 2021-04-05T19:01:00.549092+00:00 2021-04-05T19:10:03.156210+00:00 0:09:02.607118 13937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T19:00:58.045632+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T19:00:38.257507+00:00 2021-04-05T19:00:40.050675+00:00 0:00:01.793168 13936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T19:00:35.840074+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T18:00:00+00:00 PythonOperator 2021-04-05T19:00:14.614765+00:00 2021-04-05T19:00:17.494714+00:00 0:00:02.879949 13935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T19:00:11.818210+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T17:00:00+00:00 EmrJobFlowSensor 2021-04-05T18:14:08.595542+00:00 2021-04-05T18:24:11.482603+00:00 0:10:02.887061 13933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T18:14:05.880646+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T17:00:00+00:00 EmrJobFlowSensor 2021-04-05T18:14:06.097933+00:00 2021-04-05T18:28:09.907787+00:00 0:14:03.809854 13932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T18:14:03.837461+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T18:13:48.095844+00:00 2021-04-05T18:13:49.817742+00:00 0:00:01.721898 13931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T18:13:45.817454+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T18:13:42.173204+00:00 2021-04-05T18:13:43.884559+00:00 0:00:01.711355 13930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T18:13:39.877833+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T17:00:00+00:00 PythonOperator 2021-04-05T18:13:26.829577+00:00 2021-04-05T18:13:29.741069+00:00 0:00:02.911492 13929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T18:13:23.853309+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T17:00:00+00:00 PythonOperator 2021-04-05T18:13:22.470209+00:00 2021-04-05T18:13:25.469175+00:00 0:00:02.998966 13928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T18:13:19.797236+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T17:00:00+00:00 TriggerDagRunOperator 2021-04-05T18:13:14.243251+00:00 2021-04-05T18:13:14.783111+00:00 0:00:00.539860 13927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T18:13:11.789895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T17:00:00+00:00 TriggerDagRunOperator 2021-04-05T18:13:14.089797+00:00 2021-04-05T18:13:14.509916+00:00 0:00:00.420119 13926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T18:13:11.789926+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T17:05:00+00:00 EmrJobFlowSensor 2021-04-05T18:05:57.278312+00:00 2021-04-05T18:15:00.081544+00:00 0:09:02.803232 13925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T18:05:54.951102+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T18:05:29.199519+00:00 2021-04-05T18:05:30.881783+00:00 0:00:01.682264 13924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T18:05:26.925019+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T17:05:00+00:00 PythonOperator 2021-04-05T18:05:05.220586+00:00 2021-04-05T18:05:07.934805+00:00 0:00:02.714219 13923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T18:05:02.906349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T17:00:00+00:00 EmrJobFlowSensor 2021-04-05T18:00:54.760231+00:00 2021-04-05T18:12:57.632677+00:00 0:12:02.872446 13922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T18:00:52.352189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T18:00:34.567320+00:00 2021-04-05T18:00:36.280121+00:00 0:00:01.712801 13921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T18:00:32.210231+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T17:00:00+00:00 PythonOperator 2021-04-05T18:00:12.606964+00:00 2021-04-05T18:00:15.440019+00:00 0:00:02.833055 13920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T18:00:10.191741+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T16:00:00+00:00 EmrJobFlowSensor 2021-04-05T17:11:34.130103+00:00 2021-04-05T17:20:36.894308+00:00 0:09:02.764205 13918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T17:11:31.836060+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T16:00:00+00:00 EmrJobFlowSensor 2021-04-05T17:11:20.018769+00:00 2021-04-05T17:20:22.690447+00:00 0:09:02.671678 13917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T17:11:17.826277+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T17:11:12.006830+00:00 2021-04-05T17:11:13.805595+00:00 0:00:01.798765 13916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T17:11:09.818334+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T17:11:00.154455+00:00 2021-04-05T17:11:01.886741+00:00 0:00:01.732286 13915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T17:10:57.811783+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T16:00:00+00:00 PythonOperator 2021-04-05T17:10:50.268469+00:00 2021-04-05T17:10:53.233166+00:00 0:00:02.964697 13914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T17:10:47.877586+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T16:00:00+00:00 PythonOperator 2021-04-05T17:10:38.246854+00:00 2021-04-05T17:10:41.060496+00:00 0:00:02.813642 13913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T17:10:35.788006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T16:00:00+00:00 TriggerDagRunOperator 2021-04-05T17:10:28.098317+00:00 2021-04-05T17:10:28.633232+00:00 0:00:00.534915 13912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T17:10:25.760495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T16:00:00+00:00 TriggerDagRunOperator 2021-04-05T17:10:27.989254+00:00 2021-04-05T17:10:28.389420+00:00 0:00:00.400166 13911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T17:10:25.760534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T16:05:00+00:00 EmrJobFlowSensor 2021-04-05T17:06:07.782535+00:00 2021-04-05T17:15:10.365244+00:00 0:09:02.582709 13910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T17:06:05.503399+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T17:05:45.896198+00:00 2021-04-05T17:05:47.638178+00:00 0:00:01.741980 13909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T17:05:43.552802+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T16:05:00+00:00 PythonOperator 2021-04-05T17:05:26.019351+00:00 2021-04-05T17:05:28.774700+00:00 0:00:02.755349 13908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T17:05:23.429332+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T16:00:00+00:00 EmrJobFlowSensor 2021-04-05T17:00:59.039661+00:00 2021-04-05T17:10:01.848426+00:00 0:09:02.808765 13907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T17:00:56.844450+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T17:00:37.095106+00:00 2021-04-05T17:00:38.909042+00:00 0:00:01.813936 13906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T17:00:34.814141+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T16:00:00+00:00 PythonOperator 2021-04-05T17:00:15.740370+00:00 2021-04-05T17:00:18.599201+00:00 0:00:02.858831 13905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T17:00:12.871667+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T15:00:00+00:00 EmrJobFlowSensor 2021-04-05T16:11:09.774985+00:00 2021-04-05T16:20:12.528749+00:00 0:09:02.753764 13903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T16:11:07.348559+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T15:00:00+00:00 EmrJobFlowSensor 2021-04-05T16:10:51.578084+00:00 2021-04-05T16:19:54.127976+00:00 0:09:02.549892 13902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T16:10:49.285297+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T16:10:47.670927+00:00 2021-04-05T16:10:49.381606+00:00 0:00:01.710679 13901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T16:10:45.343432+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T16:10:29.813662+00:00 2021-04-05T16:10:31.583630+00:00 0:00:01.769968 13900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T16:10:27.340870+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T15:00:00+00:00 PythonOperator 2021-04-05T16:10:27.622202+00:00 2021-04-05T16:10:30.570379+00:00 0:00:02.948177 13899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T16:10:25.274328+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T15:00:00+00:00 PythonOperator 2021-04-05T16:10:09.612831+00:00 2021-04-05T16:10:12.424416+00:00 0:00:02.811585 13898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T16:10:07.195813+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T15:00:00+00:00 TriggerDagRunOperator 2021-04-05T16:10:03.595780+00:00 2021-04-05T16:10:04.044801+00:00 0:00:00.449021 13897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T16:10:01.189277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T15:00:00+00:00 TriggerDagRunOperator 2021-04-05T16:10:03.545695+00:00 2021-04-05T16:10:04.106206+00:00 0:00:00.560511 13896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T16:10:01.189248+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T15:05:00+00:00 EmrJobFlowSensor 2021-04-05T16:05:46.642585+00:00 2021-04-05T16:14:49.197681+00:00 0:09:02.555096 13895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T16:05:44.495609+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T16:05:26.720745+00:00 2021-04-05T16:05:28.470983+00:00 0:00:01.750238 13894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T16:05:24.472226+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T15:05:00+00:00 PythonOperator 2021-04-05T16:05:04.600675+00:00 2021-04-05T16:05:07.364166+00:00 0:00:02.763491 13893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T16:05:02.388270+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T15:00:00+00:00 EmrJobFlowSensor 2021-04-05T16:00:48.132391+00:00 2021-04-05T16:09:50.838588+00:00 0:09:02.706197 13892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T16:00:45.924116+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T16:00:26.317564+00:00 2021-04-05T16:00:28.146521+00:00 0:00:01.828957 13891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T16:00:23.973632+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T15:00:00+00:00 PythonOperator 2021-04-05T16:00:04.833064+00:00 2021-04-05T16:00:07.731371+00:00 0:00:02.898307 13890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T16:00:01.890059+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T14:00:00+00:00 EmrJobFlowSensor 2021-04-05T15:11:25.269610+00:00 2021-04-05T15:20:27.954860+00:00 0:09:02.685250 13888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T15:11:23.083512+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T14:00:00+00:00 EmrJobFlowSensor 2021-04-05T15:11:23.345230+00:00 2021-04-05T15:20:26.372411+00:00 0:09:03.027181 13887 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T15:11:21.030987+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T15:11:01.213630+00:00 2021-04-05T15:11:02.988240+00:00 0:00:01.774610 13886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T15:10:59.012054+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T15:10:59.410936+00:00 2021-04-05T15:11:01.243905+00:00 0:00:01.832969 13885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T15:10:57.009085+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T14:00:00+00:00 PythonOperator 2021-04-05T15:10:35.831347+00:00 2021-04-05T15:10:38.757317+00:00 0:00:02.925970 13884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T15:10:32.985156+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T14:00:00+00:00 PythonOperator 2021-04-05T15:10:33.543831+00:00 2021-04-05T15:10:36.680985+00:00 0:00:03.137154 13883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T15:10:30.988260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T14:00:00+00:00 TriggerDagRunOperator 2021-04-05T15:10:13.201655+00:00 2021-04-05T15:10:13.626276+00:00 0:00:00.424621 13882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T15:10:10.890015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T14:00:00+00:00 TriggerDagRunOperator 2021-04-05T15:10:13.195437+00:00 2021-04-05T15:10:13.739094+00:00 0:00:00.543657 13881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T15:10:10.889983+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T14:05:00+00:00 EmrJobFlowSensor 2021-04-05T15:05:54.762793+00:00 2021-04-05T15:15:57.449517+00:00 0:10:02.686724 13880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T15:05:52.473287+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T15:05:32.619475+00:00 2021-04-05T15:05:34.359872+00:00 0:00:01.740397 13879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T15:05:30.389720+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T14:05:00+00:00 PythonOperator 2021-04-05T15:05:10.472921+00:00 2021-04-05T15:05:13.138946+00:00 0:00:02.666025 13878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T15:05:08.349246+00:00 2 default_pool