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_emr_steps 2021-04-21T17:05:00+00:00 PythonOperator 2021-04-21T18:05:17.692059+00:00 2021-04-21T18:05:20.571456+00:00 0:00:02.879397 19727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T18:05:15.400457+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T17:00:00+00:00 EmrJobFlowSensor 2021-04-21T18:00:57.196980+00:00 2021-04-21T18:11:00.115714+00:00 0:10:02.918734 19726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T18:00:54.989185+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T18:00:37.204688+00:00 2021-04-21T18:00:39.085666+00:00 0:00:01.880978 19725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T18:00:34.948365+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T17:00:00+00:00 PythonOperator 2021-04-21T18:00:07.855580+00:00 2021-04-21T18:00:11.219637+00:00 0:00:03.364057 19724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T18:00:04.927465+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T16:00:00+00:00 EmrJobFlowSensor 2021-04-21T17:11:13.860934+00:00 2021-04-21T17:23:17.060474+00:00 0:12:03.199540 19722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T17:11:11.603168+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T16:00:00+00:00 EmrJobFlowSensor 2021-04-21T17:11:02.239300+00:00 2021-04-21T17:20:04.850819+00:00 0:09:02.611519 19721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T17:10:59.668764+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T17:10:51.880832+00:00 2021-04-21T17:10:53.684348+00:00 0:00:01.803516 19720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T17:10:49.592258+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T17:10:40.123302+00:00 2021-04-21T17:10:41.930223+00:00 0:00:01.806921 19719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T17:10:37.579716+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T16:00:00+00:00 PythonOperator 2021-04-21T17:10:29.885416+00:00 2021-04-21T17:10:33.225684+00:00 0:00:03.340268 19718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T17:10:27.543302+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T16:00:00+00:00 PythonOperator 2021-04-21T17:10:19.796104+00:00 2021-04-21T17:10:22.836035+00:00 0:00:03.039931 19717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T17:10:17.513750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T16:00:00+00:00 TriggerDagRunOperator 2021-04-21T17:10:06.409774+00:00 2021-04-21T17:10:06.814142+00:00 0:00:00.404368 19716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T17:10:03.500901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T16:00:00+00:00 TriggerDagRunOperator 2021-04-21T17:10:05.754106+00:00 2021-04-21T17:10:06.241379+00:00 0:00:00.487273 19715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T17:10:03.500935+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T16:05:00+00:00 EmrJobFlowSensor 2021-04-21T17:06:05.467117+00:00 2021-04-21T17:14:07.991314+00:00 0:08:02.524197 19714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T17:06:03.070553+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T17:05:39.160644+00:00 2021-04-21T17:05:40.867505+00:00 0:00:01.706861 19713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T17:05:36.936913+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T16:05:00+00:00 PythonOperator 2021-04-21T17:05:09.124467+00:00 2021-04-21T17:05:12.686309+00:00 0:00:03.561842 19712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T17:05:06.896223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T16:00:00+00:00 EmrJobFlowSensor 2021-04-21T17:00:56.499085+00:00 2021-04-21T17:09:59.179085+00:00 0:09:02.680000 19711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T17:00:54.337709+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T17:00:36.507220+00:00 2021-04-21T17:00:38.232014+00:00 0:00:01.724794 19710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T17:00:34.317475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T16:00:00+00:00 PythonOperator 2021-04-21T17:00:14.838068+00:00 2021-04-21T17:00:17.858806+00:00 0:00:03.020738 19709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T17:00:12.201592+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T15:00:00+00:00 EmrJobFlowSensor 2021-04-21T16:35:46.526322+00:00 2021-04-21T16:35:48.117869+00:00 0:00:01.591547 19708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T16:35:43.673809+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T15:00:00+00:00 EmrJobFlowSensor 2021-04-21T16:13:25.699943+00:00 2021-04-21T16:22:28.378685+00:00 0:09:02.678742 19706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T16:13:23.311423+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T16:13:21.530617+00:00 2021-04-21T16:13:23.236986+00:00 0:00:01.706369 19705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T16:13:19.359033+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T16:13:03.463702+00:00 2021-04-21T16:13:05.189345+00:00 0:00:01.725643 19704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T16:13:01.288652+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T15:00:00+00:00 PythonOperator 2021-04-21T16:12:55.679377+00:00 2021-04-21T16:12:58.925933+00:00 0:00:03.246556 19703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T16:12:53.285989+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T15:00:00+00:00 PythonOperator 2021-04-21T16:12:35.509914+00:00 2021-04-21T16:12:38.592768+00:00 0:00:03.082854 19702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T16:12:33.267882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T15:00:00+00:00 TriggerDagRunOperator 2021-04-21T16:12:29.703118+00:00 2021-04-21T16:12:30.221454+00:00 0:00:00.518336 19701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T16:12:27.264643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T15:00:00+00:00 TriggerDagRunOperator 2021-04-21T16:12:29.466801+00:00 2021-04-21T16:12:29.890966+00:00 0:00:00.424165 19700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T16:12:27.264609+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T15:05:00+00:00 EmrJobFlowSensor 2021-04-21T16:05:50.683368+00:00 2021-04-21T16:14:53.308787+00:00 0:09:02.625419 19699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T16:05:48.499833+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T16:05:30.876110+00:00 2021-04-21T16:05:32.507102+00:00 0:00:01.630992 19698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T16:05:28.557465+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T15:05:00+00:00 PythonOperator 2021-04-21T16:05:08.838831+00:00 2021-04-21T16:05:11.852621+00:00 0:00:03.013790 19697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T16:05:06.466886+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T15:00:00+00:00 EmrJobFlowSensor 2021-04-21T16:00:54.185901+00:00 2021-04-21T16:11:57.159568+00:00 0:11:02.973667 19696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T16:00:51.940135+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T16:00:34.362440+00:00 2021-04-21T16:00:36.047602+00:00 0:00:01.685162 19695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T16:00:31.924307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T15:00:00+00:00 PythonOperator 2021-04-21T16:00:10.331075+00:00 2021-04-21T16:00:13.342715+00:00 0:00:03.011640 19694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T16:00:07.902684+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T14:00:00+00:00 EmrJobFlowSensor 2021-04-21T15:25:06.753019+00:00 2021-04-21T15:36:09.682722+00:00 0:11:02.929703 19693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T15:25:04.332813+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T14:00:00+00:00 EmrJobFlowSensor 2021-04-21T15:24:50.487439+00:00 2021-04-21T15:34:53.205352+00:00 0:10:02.717913 19692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T15:24:48.320160+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T15:24:44.945772+00:00 2021-04-21T15:24:46.775505+00:00 0:00:01.829733 19691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T15:24:42.314865+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T15:24:28.753810+00:00 2021-04-21T15:24:30.411850+00:00 0:00:01.658040 19690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T15:24:26.371173+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T14:00:00+00:00 PythonOperator 2021-04-21T15:24:22.512695+00:00 2021-04-21T15:24:25.696061+00:00 0:00:03.183366 19689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T15:24:20.297905+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T14:00:00+00:00 PythonOperator 2021-04-21T15:24:08.889997+00:00 2021-04-21T15:24:11.823258+00:00 0:00:02.933261 19688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T15:24:06.291528+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T14:00:00+00:00 TriggerDagRunOperator 2021-04-21T15:24:00.910794+00:00 2021-04-21T15:24:01.467040+00:00 0:00:00.556246 19687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T15:23:58.172119+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T14:00:00+00:00 TriggerDagRunOperator 2021-04-21T15:24:00.897963+00:00 2021-04-21T15:24:01.325862+00:00 0:00:00.427899 19686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T15:23:58.172171+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T14:00:00+00:00 EmrJobFlowSensor 2021-04-21T15:14:35.322650+00:00 2021-04-21T15:23:38.024290+00:00 0:09:02.701640 19685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T15:14:33.078598+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T14:05:00+00:00 EmrJobFlowSensor 2021-04-21T15:14:27.184917+00:00 2021-04-21T15:24:29.886610+00:00 0:10:02.701693 19684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T15:14:24.999553+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T15:14:13.362635+00:00 2021-04-21T15:14:15.250469+00:00 0:00:01.887834 19683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T15:14:10.990979+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T15:14:07.186531+00:00 2021-04-21T15:14:08.898701+00:00 0:00:01.712170 19682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T15:14:04.993331+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T14:00:00+00:00 PythonOperator 2021-04-21T15:13:51.436618+00:00 2021-04-21T15:13:54.416625+00:00 0:00:02.980007 19681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T15:13:48.913026+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T14:05:00+00:00 PythonOperator 2021-04-21T15:13:45.125276+00:00 2021-04-21T15:13:48.081726+00:00 0:00:02.956450 19680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T15:13:42.690276+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T14:25:09.656485+00:00 EmrJobFlowSensor 2021-04-21T14:26:02.128265+00:00 2021-04-21T14:37:05.008960+00:00 0:11:02.880695 19678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T14:25:59.954263+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T14:25:09.656485+00:00 EmrCreateJobFlowOperator 2021-04-21T14:25:40.184778+00:00 2021-04-21T14:25:42.245763+00:00 0:00:02.060985 19677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T14:25:37.874926+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T14:25:09.656485+00:00 PythonOperator 2021-04-21T14:25:18.363046+00:00 2021-04-21T14:25:21.561726+00:00 0:00:03.198680 19676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T14:25:15.845556+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T13:00:00+00:00 EmrJobFlowSensor 2021-04-21T14:12:02.974619+00:00 2021-04-21T14:22:05.660178+00:00 0:10:02.685559 19675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T14:12:00.650264+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T13:00:00+00:00 EmrJobFlowSensor 2021-04-21T14:12:00.927562+00:00 2021-04-21T14:21:03.704125+00:00 0:09:02.776563 19674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T14:11:58.585368+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T14:11:41.309195+00:00 2021-04-21T14:11:43.020512+00:00 0:00:01.711317 19673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T14:11:38.514927+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T14:11:39.059548+00:00 2021-04-21T14:11:41.074637+00:00 0:00:02.015089 19672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T14:11:36.514034+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T13:00:00+00:00 PythonOperator 2021-04-21T14:11:19.531113+00:00 2021-04-21T14:11:22.945729+00:00 0:00:03.414616 19671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T14:11:16.497810+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T13:00:00+00:00 PythonOperator 2021-04-21T14:11:19.415247+00:00 2021-04-21T14:11:22.663253+00:00 0:00:03.248006 19670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T14:11:16.497777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T13:00:00+00:00 TriggerDagRunOperator 2021-04-21T14:11:08.905925+00:00 2021-04-21T14:11:09.418655+00:00 0:00:00.512730 19669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T14:11:06.489055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T13:00:00+00:00 TriggerDagRunOperator 2021-04-21T14:11:08.782447+00:00 2021-04-21T14:11:09.218710+00:00 0:00:00.436263 19668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T14:11:06.489092+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T13:05:00+00:00 EmrJobFlowSensor 2021-04-21T14:06:00.339853+00:00 2021-04-21T14:15:03.173908+00:00 0:09:02.834055 19667 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T14:05:58.073536+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T14:05:38.270582+00:00 2021-04-21T14:05:39.934636+00:00 0:00:01.664054 19666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T14:05:36.080559+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T13:05:00+00:00 PythonOperator 2021-04-21T14:05:14.389944+00:00 2021-04-21T14:05:17.344755+00:00 0:00:02.954811 19665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T14:05:12.007045+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T13:00:00+00:00 EmrJobFlowSensor 2021-04-21T14:00:49.885997+00:00 2021-04-21T14:10:52.665191+00:00 0:10:02.779194 19664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T14:00:47.586690+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T14:00:29.944091+00:00 2021-04-21T14:00:31.735103+00:00 0:00:01.791012 19663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T14:00:27.553005+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T13:00:00+00:00 PythonOperator 2021-04-21T14:00:07.768940+00:00 2021-04-21T14:00:11.010427+00:00 0:00:03.241487 19662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T14:00:05.464592+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T12:00:00+00:00 EmrJobFlowSensor 2021-04-21T13:12:11.959783+00:00 2021-04-21T13:22:14.857211+00:00 0:10:02.897428 19660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T13:12:09.559938+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T12:00:00+00:00 EmrJobFlowSensor 2021-04-21T13:12:01.766351+00:00 2021-04-21T13:21:04.441716+00:00 0:09:02.675365 19659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T13:11:59.498437+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T13:11:49.892264+00:00 2021-04-21T13:11:51.627058+00:00 0:00:01.734794 19658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T13:11:47.549233+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T13:11:39.941365+00:00 2021-04-21T13:11:41.747723+00:00 0:00:01.806358 19657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T13:11:37.465687+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T12:00:00+00:00 PythonOperator 2021-04-21T13:11:21.641255+00:00 2021-04-21T13:11:24.796254+00:00 0:00:03.154999 19656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T13:11:19.443669+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T12:00:00+00:00 PythonOperator 2021-04-21T13:11:05.827140+00:00 2021-04-21T13:11:08.822166+00:00 0:00:02.995026 19655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T13:11:03.432459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T12:00:00+00:00 TriggerDagRunOperator 2021-04-21T13:10:56.002051+00:00 2021-04-21T13:10:56.428201+00:00 0:00:00.426150 19654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T13:10:53.422744+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T12:00:00+00:00 TriggerDagRunOperator 2021-04-21T13:10:55.832246+00:00 2021-04-21T13:10:56.407894+00:00 0:00:00.575648 19653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T13:10:53.422713+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T12:05:00+00:00 EmrJobFlowSensor 2021-04-21T13:06:06.878041+00:00 2021-04-21T13:15:09.493810+00:00 0:09:02.615769 19652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T13:06:04.799245+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T13:05:47.105397+00:00 2021-04-21T13:05:48.771200+00:00 0:00:01.665803 19651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T13:05:44.851865+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T12:05:00+00:00 PythonOperator 2021-04-21T13:05:25.099019+00:00 2021-04-21T13:05:28.523776+00:00 0:00:03.424757 19650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T13:05:22.688508+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T12:00:00+00:00 EmrJobFlowSensor 2021-04-21T13:00:48.399601+00:00 2021-04-21T13:10:51.210252+00:00 0:10:02.810651 19649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T13:00:46.253296+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T13:00:26.459266+00:00 2021-04-21T13:00:28.299356+00:00 0:00:01.840090 19648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T13:00:24.230491+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T12:00:00+00:00 PythonOperator 2021-04-21T13:00:04.952256+00:00 2021-04-21T13:00:08.123228+00:00 0:00:03.170972 19647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T13:00:02.262478+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 check_cluster_status 2021-04-21T12:36:10.582420+00:00 EmrJobFlowSensor 2021-04-21T12:37:18.170058+00:00 2021-04-21T12:38:19.703547+00:00 0:01:01.533489 19646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T12:37:16.002815+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_cluster_and_add_emr_steps 2021-04-21T12:36:10.582420+00:00 EmrCreateJobFlowOperator 2021-04-21T12:36:58.365760+00:00 2021-04-21T12:37:00.070581+00:00 0:00:01.704821 19645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T12:36:55.983433+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_emr_steps 2021-04-21T12:36:10.582420+00:00 PythonOperator 2021-04-21T12:36:37.214502+00:00 2021-04-21T12:36:40.273340+00:00 0:00:03.058838 19644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T12:36:33.973078+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T11:00:00+00:00 EmrJobFlowSensor 2021-04-21T12:12:08.034337+00:00 2021-04-21T12:22:10.646497+00:00 0:10:02.612160 19642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T12:12:05.840062+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T11:00:00+00:00 EmrJobFlowSensor 2021-04-21T12:11:56.039306+00:00 2021-04-21T12:19:58.546143+00:00 0:08:02.506837 19641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T12:11:53.830257+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T12:11:46.004687+00:00 2021-04-21T12:11:47.697167+00:00 0:00:01.692480 19640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T12:11:43.827432+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T12:11:34.185758+00:00 2021-04-21T12:11:35.850606+00:00 0:00:01.664848 19639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T12:11:31.812803+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T11:00:00+00:00 PythonOperator 2021-04-21T12:11:24.307124+00:00 2021-04-21T12:11:27.560125+00:00 0:00:03.253001 19638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T12:11:21.858107+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T11:00:00+00:00 PythonOperator 2021-04-21T12:11:12.014072+00:00 2021-04-21T12:11:14.989119+00:00 0:00:02.975047 19637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T12:11:09.792900+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T11:00:00+00:00 TriggerDagRunOperator 2021-04-21T12:11:00.448237+00:00 2021-04-21T12:11:00.961392+00:00 0:00:00.513155 19636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T12:10:57.853761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T11:00:00+00:00 TriggerDagRunOperator 2021-04-21T12:11:00.249402+00:00 2021-04-21T12:11:00.671683+00:00 0:00:00.422281 19635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T12:10:57.853714+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T11:05:00+00:00 EmrJobFlowSensor 2021-04-21T12:05:47.289901+00:00 2021-04-21T12:14:49.929378+00:00 0:09:02.639477 19634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T12:05:45.124675+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T12:05:25.380616+00:00 2021-04-21T12:05:27.144729+00:00 0:00:01.764113 19633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T12:05:23.100807+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T11:05:00+00:00 PythonOperator 2021-04-21T12:05:03.858764+00:00 2021-04-21T12:05:06.813112+00:00 0:00:02.954348 19632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T12:05:01.155469+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T11:00:00+00:00 EmrJobFlowSensor 2021-04-21T12:00:46.805633+00:00 2021-04-21T12:10:49.636299+00:00 0:10:02.830666 19631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T12:00:44.661801+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T12:00:26.859788+00:00 2021-04-21T12:00:28.551959+00:00 0:00:01.692171 19630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T12:00:24.634626+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T11:00:00+00:00 PythonOperator 2021-04-21T12:00:05.304021+00:00 2021-04-21T12:00:08.270044+00:00 0:00:02.966023 19629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T12:00:02.622883+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T10:00:00+00:00 EmrJobFlowSensor 2021-04-21T11:13:32.123270+00:00 2021-04-21T11:22:34.682374+00:00 0:09:02.559104 19627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:13:29.917358+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T10:00:00+00:00 EmrJobFlowSensor 2021-04-21T11:13:30.442077+00:00 2021-04-21T11:21:32.962541+00:00 0:08:02.520464 19626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:13:27.961218+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T11:13:12.058885+00:00 2021-04-21T11:13:14.216665+00:00 0:00:02.157780 19625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T11:13:07.889431+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T11:13:08.323214+00:00 2021-04-21T11:13:10.624705+00:00 0:00:02.301491 19624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T11:13:05.955311+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T10:00:00+00:00 PythonOperator 2021-04-21T11:12:50.511224+00:00 2021-04-21T11:12:53.920413+00:00 0:00:03.409189 19623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T11:12:47.809347+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T10:00:00+00:00 PythonOperator 2021-04-21T11:12:46.137330+00:00 2021-04-21T11:12:49.502487+00:00 0:00:03.365157 19622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T11:12:43.868994+00:00 2 default_pool