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-history-job_v002 create_emr_steps 2021-04-30T03:00:00+00:00 PythonOperator 2021-04-30T04:10:41.056440+00:00 2021-04-30T04:10:44.169010+00:00 0:00:03.112570 22798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T04:10:38.140875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T03:00:00+00:00 TriggerDagRunOperator 2021-04-30T04:10:32.679050+00:00 2021-04-30T04:10:33.084671+00:00 0:00:00.405621 22797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T04:10:30.148801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T03:00:00+00:00 TriggerDagRunOperator 2021-04-30T04:10:32.654789+00:00 2021-04-30T04:10:33.193554+00:00 0:00:00.538765 22796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T04:10:30.148844+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T04:05:43.627608+00:00 2021-04-30T04:05:45.318670+00:00 0:00:01.691062 22794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T04:05:41.311280+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T03:05:00+00:00 PythonOperator 2021-04-30T04:05:22.207772+00:00 2021-04-30T04:05:25.302189+00:00 0:00:03.094417 22793 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T04:05:19.292937+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T03:00:00+00:00 EmrJobFlowSensor 2021-04-30T04:01:05.327805+00:00 2021-04-30T04:10:07.996923+00:00 0:09:02.669118 22792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T04:01:02.885110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T04:00:43.202276+00:00 2021-04-30T04:00:45.072513+00:00 0:00:01.870237 22791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T04:00:40.828742+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T03:00:00+00:00 PythonOperator 2021-04-30T04:00:21.337453+00:00 2021-04-30T04:00:24.479466+00:00 0:00:03.142013 22790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T04:00:18.865979+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T02:00:00+00:00 EmrJobFlowSensor 2021-04-30T03:12:31.970570+00:00 2021-04-30T03:21:34.543787+00:00 0:09:02.573217 22788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T03:12:29.569831+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T02:00:00+00:00 EmrJobFlowSensor 2021-04-30T03:12:28.002697+00:00 2021-04-30T03:21:30.658888+00:00 0:09:02.656191 22787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T03:12:25.557078+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T03:12:09.865724+00:00 2021-04-30T03:12:11.577100+00:00 0:00:01.711376 22786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T03:12:07.549410+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T03:12:06.018542+00:00 2021-04-30T03:12:07.793627+00:00 0:00:01.775085 22785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T03:12:03.657251+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T02:00:00+00:00 PythonOperator 2021-04-30T03:11:49.783632+00:00 2021-04-30T03:11:52.999995+00:00 0:00:03.216363 22784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T03:11:47.519837+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T02:00:00+00:00 PythonOperator 2021-04-30T03:11:43.837358+00:00 2021-04-30T03:11:46.814563+00:00 0:00:02.977205 22783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T03:11:41.507100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T02:00:00+00:00 TriggerDagRunOperator 2021-04-30T03:11:23.920373+00:00 2021-04-30T03:11:24.474315+00:00 0:00:00.553942 22782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T03:11:21.489404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T02:00:00+00:00 TriggerDagRunOperator 2021-04-30T03:11:23.642336+00:00 2021-04-30T03:11:24.065402+00:00 0:00:00.423066 22781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T03:11:21.489368+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T02:05:00+00:00 EmrJobFlowSensor 2021-04-30T03:06:05.281276+00:00 2021-04-30T03:15:07.873669+00:00 0:09:02.592393 22780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T03:06:02.801624+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T03:05:42.902266+00:00 2021-04-30T03:05:44.680800+00:00 0:00:01.778534 22779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T03:05:40.698515+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T02:05:00+00:00 PythonOperator 2021-04-30T03:05:20.930490+00:00 2021-04-30T03:05:23.929358+00:00 0:00:02.998868 22778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T03:05:18.714726+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T02:00:00+00:00 EmrJobFlowSensor 2021-04-30T03:01:00.701749+00:00 2021-04-30T03:11:03.667565+00:00 0:10:02.965816 22777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T03:00:58.119568+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T03:00:38.490477+00:00 2021-04-30T03:00:40.285001+00:00 0:00:01.794524 22776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T03:00:36.103481+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T02:00:00+00:00 PythonOperator 2021-04-30T03:00:16.604953+00:00 2021-04-30T03:00:19.660374+00:00 0:00:03.055421 22775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T03:00:14.100218+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T01:00:00+00:00 EmrJobFlowSensor 2021-04-30T02:10:27.145529+00:00 2021-04-30T02:19:29.889339+00:00 0:09:02.743810 22773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T02:10:24.785828+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T01:00:00+00:00 EmrJobFlowSensor 2021-04-30T02:10:20.979296+00:00 2021-04-30T02:18:23.635803+00:00 0:08:02.656507 22772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T02:10:18.741199+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T02:10:05.105833+00:00 2021-04-30T02:10:06.841134+00:00 0:00:01.735301 22771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T02:10:02.716205+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T02:10:01.018661+00:00 2021-04-30T02:10:02.808648+00:00 0:00:01.789987 22770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T02:09:58.768511+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T01:00:00+00:00 PythonOperator 2021-04-30T02:09:43.733002+00:00 2021-04-30T02:09:47.252321+00:00 0:00:03.519319 22769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T02:09:40.748828+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T01:00:00+00:00 PythonOperator 2021-04-30T02:09:39.023111+00:00 2021-04-30T02:09:42.594156+00:00 0:00:03.571045 22768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T02:09:36.690050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T01:00:00+00:00 TriggerDagRunOperator 2021-04-30T02:09:17.538962+00:00 2021-04-30T02:09:18.143244+00:00 0:00:00.604282 22767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T02:09:14.651655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T01:00:00+00:00 TriggerDagRunOperator 2021-04-30T02:09:17.094445+00:00 2021-04-30T02:09:17.649819+00:00 0:00:00.555374 22766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T02:09:14.651610+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T01:05:00+00:00 EmrJobFlowSensor 2021-04-30T02:06:02.362365+00:00 2021-04-30T02:15:05.062317+00:00 0:09:02.699952 22765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T02:06:00.217617+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T02:05:40.564970+00:00 2021-04-30T02:05:42.243571+00:00 0:00:01.678601 22764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T02:05:38.252746+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T01:05:00+00:00 PythonOperator 2021-04-30T02:05:20.581631+00:00 2021-04-30T02:05:23.557761+00:00 0:00:02.976130 22763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T02:05:18.165738+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T01:00:00+00:00 EmrJobFlowSensor 2021-04-30T02:01:08.404140+00:00 2021-04-30T02:09:11.078609+00:00 0:08:02.674469 22762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T02:01:05.873859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T02:00:46.190378+00:00 2021-04-30T02:00:48.037098+00:00 0:00:01.846720 22761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T02:00:43.797594+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T01:00:00+00:00 PythonOperator 2021-04-30T02:00:24.621557+00:00 2021-04-30T02:00:27.705659+00:00 0:00:03.084102 22760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T02:00:21.763456+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T00:00:00+00:00 EmrJobFlowSensor 2021-04-30T01:12:07.710828+00:00 2021-04-30T01:21:10.351252+00:00 0:09:02.640424 22758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T01:12:05.508262+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T00:00:00+00:00 EmrJobFlowSensor 2021-04-30T01:11:55.789136+00:00 2021-04-30T01:20:58.424747+00:00 0:09:02.635611 22757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T01:11:53.490824+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T01:11:45.699226+00:00 2021-04-30T01:11:47.349307+00:00 0:00:01.650081 22756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T01:11:43.438342+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T01:11:34.132842+00:00 2021-04-30T01:11:35.836785+00:00 0:00:01.703943 22755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T01:11:31.541207+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T00:00:00+00:00 PythonOperator 2021-04-30T01:11:23.581104+00:00 2021-04-30T01:11:26.627788+00:00 0:00:03.046684 22754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T01:11:21.400917+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T00:00:00+00:00 PythonOperator 2021-04-30T01:11:11.600896+00:00 2021-04-30T01:11:14.907300+00:00 0:00:03.306404 22753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T01:11:09.391039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T00:00:00+00:00 TriggerDagRunOperator 2021-04-30T01:10:59.859081+00:00 2021-04-30T01:11:00.398782+00:00 0:00:00.539701 22752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T01:10:57.374770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T00:00:00+00:00 TriggerDagRunOperator 2021-04-30T01:10:59.825132+00:00 2021-04-30T01:11:00.251629+00:00 0:00:00.426497 22751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T01:10:57.374820+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T00:05:00+00:00 EmrJobFlowSensor 2021-04-30T01:06:10.768412+00:00 2021-04-30T01:15:13.455002+00:00 0:09:02.686590 22750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T01:06:08.481801+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T01:05:36.611885+00:00 2021-04-30T01:05:38.269843+00:00 0:00:01.657958 22749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T01:05:34.458833+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T00:05:00+00:00 PythonOperator 2021-04-30T01:05:10.570437+00:00 2021-04-30T01:05:13.560635+00:00 0:00:02.990198 22748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T01:05:08.390186+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T00:00:00+00:00 EmrJobFlowSensor 2021-04-30T01:00:46.124744+00:00 2021-04-30T01:10:49.044548+00:00 0:10:02.919804 22747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T01:00:43.889421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T01:00:26.043905+00:00 2021-04-30T01:00:27.780828+00:00 0:00:01.736923 22746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T01:00:23.834908+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T00:00:00+00:00 PythonOperator 2021-04-30T01:00:04.173551+00:00 2021-04-30T01:00:07.212364+00:00 0:00:03.038813 22745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T01:00:01.815310+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T23:00:00+00:00 EmrJobFlowSensor 2021-04-30T00:12:31.323837+00:00 2021-04-30T00:22:34.140768+00:00 0:10:02.816931 22743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T00:12:28.544755+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T23:00:00+00:00 EmrJobFlowSensor 2021-04-30T00:12:20.693328+00:00 2021-04-30T00:21:23.373864+00:00 0:09:02.680536 22742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T00:12:18.394438+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T00:12:10.717229+00:00 2021-04-30T00:12:12.513194+00:00 0:00:01.795965 22741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T00:12:08.367525+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T00:11:58.544849+00:00 2021-04-30T00:12:00.282076+00:00 0:00:01.737227 22740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T00:11:56.302879+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T23:00:00+00:00 PythonOperator 2021-04-30T00:11:48.553193+00:00 2021-04-30T00:11:51.805450+00:00 0:00:03.252257 22739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T00:11:46.293163+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T23:00:00+00:00 PythonOperator 2021-04-30T00:11:37.040560+00:00 2021-04-30T00:11:40.024006+00:00 0:00:02.983446 22738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T00:11:34.352198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T23:00:00+00:00 TriggerDagRunOperator 2021-04-30T00:11:28.867855+00:00 2021-04-30T00:11:29.367493+00:00 0:00:00.499638 22737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T00:11:26.211639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T23:00:00+00:00 TriggerDagRunOperator 2021-04-30T00:11:28.553000+00:00 2021-04-30T00:11:29.001352+00:00 0:00:00.448352 22736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T00:11:26.211600+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T23:05:00+00:00 EmrJobFlowSensor 2021-04-30T00:05:51.373480+00:00 2021-04-30T00:18:54.507020+00:00 0:13:03.133540 22735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T00:05:49.192771+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T00:05:29.549276+00:00 2021-04-30T00:05:31.212014+00:00 0:00:01.662738 22734 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T00:05:27.178822+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T23:05:00+00:00 PythonOperator 2021-04-30T00:05:09.480587+00:00 2021-04-30T00:05:12.494719+00:00 0:00:03.014132 22733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T00:05:07.140931+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T23:00:00+00:00 EmrJobFlowSensor 2021-04-30T00:01:03.306373+00:00 2021-04-30T00:11:06.083621+00:00 0:10:02.777248 22732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T00:01:00.569373+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T00:00:40.803283+00:00 2021-04-30T00:00:42.612340+00:00 0:00:01.809057 22731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T00:00:38.452922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T23:00:00+00:00 PythonOperator 2021-04-30T00:00:19.138665+00:00 2021-04-30T00:00:22.257728+00:00 0:00:03.119063 22730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T00:00:16.558929+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T22:00:00+00:00 EmrJobFlowSensor 2021-04-29T23:17:17.393111+00:00 2021-04-29T23:27:20.175778+00:00 0:10:02.782667 22729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T23:17:15.044145+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T22:00:00+00:00 EmrJobFlowSensor 2021-04-29T23:17:11.337651+00:00 2021-04-29T23:26:14.010217+00:00 0:09:02.672566 22728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T23:17:09.041100+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T23:16:53.248410+00:00 2021-04-29T23:16:54.952860+00:00 0:00:01.704450 22727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T23:16:51.045485+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T23:16:49.510809+00:00 2021-04-29T23:16:51.305602+00:00 0:00:01.794793 22726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T23:16:47.061094+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T22:00:00+00:00 PythonOperator 2021-04-29T23:16:31.800507+00:00 2021-04-29T23:16:35.288496+00:00 0:00:03.487989 22725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T23:16:29.053007+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T22:00:00+00:00 PythonOperator 2021-04-29T23:16:29.218094+00:00 2021-04-29T23:16:32.568589+00:00 0:00:03.350495 22724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T23:16:26.925701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T22:00:00+00:00 TriggerDagRunOperator 2021-04-29T23:16:15.713163+00:00 2021-04-29T23:16:16.117708+00:00 0:00:00.404545 22723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T23:16:12.880146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T22:00:00+00:00 TriggerDagRunOperator 2021-04-29T23:16:15.581056+00:00 2021-04-29T23:16:16.153133+00:00 0:00:00.572077 22722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T23:16:12.880516+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T22:05:00+00:00 EmrJobFlowSensor 2021-04-29T23:05:51.789263+00:00 2021-04-29T23:14:54.357340+00:00 0:09:02.568077 22720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T23:05:49.631291+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T23:05:30.102068+00:00 2021-04-29T23:05:31.736509+00:00 0:00:01.634441 22719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T23:05:27.674235+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T22:05:00+00:00 PythonOperator 2021-04-29T23:05:08.924048+00:00 2021-04-29T23:05:11.921096+00:00 0:00:02.997048 22718 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T23:05:05.645747+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T22:00:00+00:00 EmrJobFlowSensor 2021-04-29T23:01:15.583333+00:00 2021-04-29T23:11:18.332655+00:00 0:10:02.749322 22717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T23:01:13.068351+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-28T23:00:00+00:00 EmrJobFlowSensor 2021-04-29T23:01:09.496657+00:00 2021-04-29T23:11:12.276202+00:00 0:10:02.779545 22716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T23:01:07.082984+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T23:00:53.237980+00:00 2021-04-29T23:00:55.042317+00:00 0:00:01.804337 22715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T23:00:50.993493+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-28T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T23:00:49.535950+00:00 2021-04-29T23:00:51.222719+00:00 0:00:01.686769 22714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T23:00:47.053110+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T22:00:00+00:00 PythonOperator 2021-04-29T23:00:33.201037+00:00 2021-04-29T23:00:36.183685+00:00 0:00:02.982648 22713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T23:00:30.982240+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-28T23:00:00+00:00 PythonOperator 2021-04-29T23:00:27.195068+00:00 2021-04-29T23:00:30.325349+00:00 0:00:03.130281 22712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T23:00:24.928693+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T21:00:00+00:00 EmrJobFlowSensor 2021-04-29T22:12:27.421690+00:00 2021-04-29T22:22:30.381214+00:00 0:10:02.959524 22711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T22:12:25.192362+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T21:00:00+00:00 EmrJobFlowSensor 2021-04-29T22:12:19.489380+00:00 2021-04-29T22:22:22.260124+00:00 0:10:02.770744 22710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T22:12:17.188605+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T22:12:01.380868+00:00 2021-04-29T22:12:03.134697+00:00 0:00:01.753829 22709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T22:11:59.119457+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T22:11:55.494621+00:00 2021-04-29T22:11:57.156811+00:00 0:00:01.662190 22708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T22:11:53.124516+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T21:00:00+00:00 PythonOperator 2021-04-29T22:11:38.112078+00:00 2021-04-29T22:11:41.540768+00:00 0:00:03.428690 22707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T22:11:35.109262+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T21:00:00+00:00 PythonOperator 2021-04-29T22:11:33.599234+00:00 2021-04-29T22:11:37.431017+00:00 0:00:03.831783 22706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T22:11:31.167035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T21:00:00+00:00 TriggerDagRunOperator 2021-04-29T22:11:27.755168+00:00 2021-04-29T22:11:28.307680+00:00 0:00:00.552512 22705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T22:11:24.821326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T21:00:00+00:00 TriggerDagRunOperator 2021-04-29T22:11:27.681383+00:00 2021-04-29T22:11:28.103417+00:00 0:00:00.422034 22704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T22:11:24.821356+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T21:05:00+00:00 EmrJobFlowSensor 2021-04-29T22:06:00.948260+00:00 2021-04-29T22:15:03.626855+00:00 0:09:02.678595 22702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T22:05:58.465467+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T22:05:38.593119+00:00 2021-04-29T22:05:40.377935+00:00 0:00:01.784816 22701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T22:05:36.360202+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T21:05:00+00:00 PythonOperator 2021-04-29T22:05:18.794834+00:00 2021-04-29T22:05:21.815700+00:00 0:00:03.020866 22700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T22:05:16.334582+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T21:00:00+00:00 EmrJobFlowSensor 2021-04-29T22:01:12.361248+00:00 2021-04-29T22:11:15.154873+00:00 0:10:02.793625 22699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T22:01:09.943851+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T22:00:52.047150+00:00 2021-04-29T22:00:53.873655+00:00 0:00:01.826505 22698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T22:00:49.810038+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T21:00:00+00:00 PythonOperator 2021-04-29T22:00:24.071749+00:00 2021-04-29T22:00:27.391511+00:00 0:00:03.319762 22697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T22:00:21.781567+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T20:00:00+00:00 EmrJobFlowSensor 2021-04-29T21:12:31.132213+00:00 2021-04-29T21:21:33.685053+00:00 0:09:02.552840 22696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T21:12:28.662904+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T20:00:00+00:00 EmrJobFlowSensor 2021-04-29T21:12:25.011259+00:00 2021-04-29T21:22:27.858523+00:00 0:10:02.847264 22695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T21:12:22.652687+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T21:12:05.013131+00:00 2021-04-29T21:12:06.904809+00:00 0:00:01.891678 22694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T21:12:02.573168+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T21:11:54.868416+00:00 2021-04-29T21:11:56.565599+00:00 0:00:01.697183 22693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T21:11:52.555337+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T20:00:00+00:00 PythonOperator 2021-04-29T21:11:36.847482+00:00 2021-04-29T21:11:39.859369+00:00 0:00:03.011887 22692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T21:11:34.580746+00:00 2 default_pool