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 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
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T10:00:00+00:00 TriggerDagRunOperator 2021-04-21T11:12:28.047955+00:00 2021-04-21T11:12:28.654844+00:00 0:00:00.606889 19621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:12:25.791020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T10:00:00+00:00 TriggerDagRunOperator 2021-04-21T11:12:27.997035+00:00 2021-04-21T11:12:28.411079+00:00 0:00:00.414044 19620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:12:25.791052+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T10:05:00+00:00 EmrJobFlowSensor 2021-04-21T11:06:07.487644+00:00 2021-04-21T11:15:10.195523+00:00 0:09:02.707879 19619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:06:05.216255+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T11:05:45.861864+00:00 2021-04-21T11:05:47.768553+00:00 0:00:01.906689 19618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T11:05:43.263246+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T10:05:00+00:00 PythonOperator 2021-04-21T11:05:25.377204+00:00 2021-04-21T11:05:28.315847+00:00 0:00:02.938643 19617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T11:05:23.165640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T10:00:00+00:00 EmrJobFlowSensor 2021-04-21T11:01:09.274689+00:00 2021-04-21T11:12:12.290890+00:00 0:11:03.016201 19616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T11:01:06.687794+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T11:00:44.875212+00:00 2021-04-21T11:00:46.578188+00:00 0:00:01.702976 19615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T11:00:42.664563+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T10:00:00+00:00 PythonOperator 2021-04-21T11:00:13.518431+00:00 2021-04-21T11:00:17.077994+00:00 0:00:03.559563 19614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T11:00:10.635420+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T09:00:00+00:00 EmrJobFlowSensor 2021-04-21T10:13:03.520552+00:00 2021-04-21T10:26:06.817216+00:00 0:13:03.296664 19612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:13:01.290303+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T09:00:00+00:00 EmrJobFlowSensor 2021-04-21T10:12:59.683563+00:00 2021-04-21T10:23:02.605311+00:00 0:10:02.921748 19611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:12:57.358844+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:12:43.502785+00:00 2021-04-21T10:12:45.230565+00:00 0:00:01.727780 19610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T10:12:41.202266+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:12:37.452742+00:00 2021-04-21T10:12:39.128550+00:00 0:00:01.675808 19609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T10:12:35.205971+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T09:00:00+00:00 PythonOperator 2021-04-21T10:12:21.365242+00:00 2021-04-21T10:12:24.590551+00:00 0:00:03.225309 19608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:12:19.152480+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T09:00:00+00:00 PythonOperator 2021-04-21T10:12:17.285318+00:00 2021-04-21T10:12:20.286721+00:00 0:00:03.001403 19607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:12:15.159178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T09:00:00+00:00 TriggerDagRunOperator 2021-04-21T10:12:07.671353+00:00 2021-04-21T10:12:08.194838+00:00 0:00:00.523485 19606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:12:05.167697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T09:00:00+00:00 TriggerDagRunOperator 2021-04-21T10:12:07.561491+00:00 2021-04-21T10:12:07.983420+00:00 0:00:00.421929 19605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:12:05.167658+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T09:05:00+00:00 EmrJobFlowSensor 2021-04-21T10:06:14.616093+00:00 2021-04-21T10:15:17.112615+00:00 0:09:02.496522 19604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:06:12.412024+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:05:54.718405+00:00 2021-04-21T10:05:56.452080+00:00 0:00:01.733675 19603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T10:05:52.379160+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T09:05:00+00:00 PythonOperator 2021-04-21T10:05:24.655035+00:00 2021-04-21T10:05:27.618928+00:00 0:00:02.963893 19602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:05:22.366028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T09:00:00+00:00 EmrJobFlowSensor 2021-04-21T10:00:48.388920+00:00 2021-04-21T10:11:51.333109+00:00 0:11:02.944189 19601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:00:46.058531+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:00:26.335728+00:00 2021-04-21T10:00:28.201150+00:00 0:00:01.865422 19600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T10:00:23.976031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T09:00:00+00:00 PythonOperator 2021-04-21T10:00:06.090291+00:00 2021-04-21T10:00:09.800184+00:00 0:00:03.709893 19599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T10:00:03.912062+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T08:00:00+00:00 EmrJobFlowSensor 2021-04-21T09:29:07.093100+00:00 2021-04-21T09:40:10.044913+00:00 0:11:02.951813 19598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T09:29:04.841269+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T08:00:00+00:00 EmrJobFlowSensor 2021-04-21T09:28:50.825258+00:00 2021-04-21T09:37:53.536418+00:00 0:09:02.711160 19597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T09:28:48.581319+00:00 3 default_pool