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-05-06T14:00:00+00:00 PythonOperator 2021-05-06T15:14:32.804218+00:00 2021-05-06T15:14:35.839839+00:00 0:00:03.035621 25136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T15:14:30.486194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T14:00:00+00:00 TriggerDagRunOperator 2021-05-06T15:14:16.738642+00:00 2021-05-06T15:14:17.265599+00:00 0:00:00.526957 25135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:14:14.446721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T14:00:00+00:00 TriggerDagRunOperator 2021-05-06T15:14:16.573365+00:00 2021-05-06T15:14:16.994531+00:00 0:00:00.421166 25134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:14:14.446753+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T14:05:00+00:00 EmrJobFlowSensor 2021-05-06T15:05:49.940363+00:00 2021-05-06T15:14:52.735646+00:00 0:09:02.795283 25133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:05:47.634407+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T15:05:27.926380+00:00 2021-05-06T15:05:29.715275+00:00 0:00:01.788895 25132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T15:05:25.613909+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T14:05:00+00:00 PythonOperator 2021-05-06T15:05:07.822682+00:00 2021-05-06T15:05:10.846224+00:00 0:00:03.023542 25131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T15:05:05.593614+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T14:00:00+00:00 EmrJobFlowSensor 2021-05-06T15:03:56.153774+00:00 2021-05-06T15:13:59.138336+00:00 0:10:02.984562 25130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T15:03:53.574023+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T15:03:17.634933+00:00 2021-05-06T15:03:19.374483+00:00 0:00:01.739550 25129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T15:03:15.480475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T14:00:00+00:00 PythonOperator 2021-05-06T15:02:56.010246+00:00 2021-05-06T15:02:59.284869+00:00 0:00:03.274623 25128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T15:02:53.461589+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T13:00:00+00:00 EmrJobFlowSensor 2021-05-06T14:11:38.230786+00:00 2021-05-06T14:21:40.974829+00:00 0:10:02.744043 25126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:11:36.037570+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T13:00:00+00:00 EmrJobFlowSensor 2021-05-06T14:11:28.175602+00:00 2021-05-06T14:20:30.695638+00:00 0:09:02.520036 25125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:11:26.030158+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:11:16.393072+00:00 2021-05-06T14:11:18.078050+00:00 0:00:01.684978 25124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T14:11:14.076477+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:11:06.100134+00:00 2021-05-06T14:11:07.782257+00:00 0:00:01.682123 25123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T14:11:04.015474+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T13:00:00+00:00 PythonOperator 2021-05-06T14:10:56.183795+00:00 2021-05-06T14:10:59.558429+00:00 0:00:03.374634 25122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:10:54.047961+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T13:00:00+00:00 PythonOperator 2021-05-06T14:10:44.645137+00:00 2021-05-06T14:10:47.655257+00:00 0:00:03.010120 25121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:10:41.994087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T13:00:00+00:00 TriggerDagRunOperator 2021-05-06T14:10:36.238150+00:00 2021-05-06T14:10:36.773093+00:00 0:00:00.534943 25120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:10:33.989128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T13:00:00+00:00 TriggerDagRunOperator 2021-05-06T14:10:36.185647+00:00 2021-05-06T14:10:36.603288+00:00 0:00:00.417641 25119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:10:33.989093+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T13:05:00+00:00 EmrJobFlowSensor 2021-05-06T14:05:55.787078+00:00 2021-05-06T14:14:58.723687+00:00 0:09:02.936609 25118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:05:53.284076+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:05:35.491767+00:00 2021-05-06T14:05:37.251524+00:00 0:00:01.759757 25117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T14:05:33.262529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T13:05:00+00:00 PythonOperator 2021-05-06T14:05:13.414216+00:00 2021-05-06T14:05:16.408598+00:00 0:00:02.994382 25116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:05:11.193198+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T13:00:00+00:00 EmrJobFlowSensor 2021-05-06T14:01:08.921094+00:00 2021-05-06T14:10:11.702768+00:00 0:09:02.781674 25115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:01:06.788722+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:00:46.836155+00:00 2021-05-06T14:00:48.531238+00:00 0:00:01.695083 25114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T14:00:44.748549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T13:00:00+00:00 PythonOperator 2021-05-06T14:00:25.186778+00:00 2021-05-06T14:00:28.268707+00:00 0:00:03.081929 25113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T14:00:22.757790+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T12:00:00+00:00 EmrJobFlowSensor 2021-05-06T13:12:13.399695+00:00 2021-05-06T13:21:16.282027+00:00 0:09:02.882332 25111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:12:10.847742+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T12:00:00+00:00 EmrJobFlowSensor 2021-05-06T13:12:13.136770+00:00 2021-05-06T13:23:16.011522+00:00 0:11:02.874752 25110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:12:10.847777+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:11:51.302523+00:00 2021-05-06T13:11:53.130635+00:00 0:00:01.828112 25109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T13:11:48.775542+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:11:51.138680+00:00 2021-05-06T13:11:52.864261+00:00 0:00:01.725581 25108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T13:11:48.775490+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T12:00:00+00:00 PythonOperator 2021-05-06T13:11:26.946707+00:00 2021-05-06T13:11:29.975216+00:00 0:00:03.028509 25107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:11:24.713510+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T12:00:00+00:00 PythonOperator 2021-05-06T13:11:23.008301+00:00 2021-05-06T13:11:26.322882+00:00 0:00:03.314581 25106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:11:20.696076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T12:00:00+00:00 TriggerDagRunOperator 2021-05-06T13:11:09.182192+00:00 2021-05-06T13:11:09.611094+00:00 0:00:00.428902 25105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:11:06.690982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T12:00:00+00:00 TriggerDagRunOperator 2021-05-06T13:11:09.183219+00:00 2021-05-06T13:11:09.743766+00:00 0:00:00.560547 25104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:11:06.690948+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T12:05:00+00:00 EmrJobFlowSensor 2021-05-06T13:05:50.538772+00:00 2021-05-06T13:14:53.118619+00:00 0:09:02.579847 25103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:05:48.268392+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:05:28.550407+00:00 2021-05-06T13:05:30.311048+00:00 0:00:01.760641 25102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T13:05:26.183083+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T12:05:00+00:00 PythonOperator 2021-05-06T13:05:06.140636+00:00 2021-05-06T13:05:09.258901+00:00 0:00:03.118265 25101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:05:04.119685+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T12:00:00+00:00 EmrJobFlowSensor 2021-05-06T13:00:45.893347+00:00 2021-05-06T13:10:48.779346+00:00 0:10:02.885999 25100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:00:43.725339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:00:25.893673+00:00 2021-05-06T13:00:27.628736+00:00 0:00:01.735063 25099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T13:00:23.706750+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T12:00:00+00:00 PythonOperator 2021-05-06T13:00:03.976683+00:00 2021-05-06T13:00:07.185399+00:00 0:00:03.208716 25098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T13:00:01.697227+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T11:00:00+00:00 EmrJobFlowSensor 2021-05-06T12:27:52.887683+00:00 2021-05-06T12:36:55.565108+00:00 0:09:02.677425 25097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:27:50.450044+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T11:00:00+00:00 EmrJobFlowSensor 2021-05-06T12:27:42.485574+00:00 2021-05-06T12:36:45.271018+00:00 0:09:02.785444 25096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:27:40.325293+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T11:05:00+00:00 EmrJobFlowSensor 2021-05-06T12:27:32.605830+00:00 2021-05-06T12:36:35.411472+00:00 0:09:02.805642 25095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:27:30.321092+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:27:16.386953+00:00 2021-05-06T12:27:18.055692+00:00 0:00:01.668739 25094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T12:27:14.305371+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:27:14.707935+00:00 2021-05-06T12:27:16.541850+00:00 0:00:01.833915 25093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T12:27:12.304855+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:27:04.533254+00:00 2021-05-06T12:27:06.205126+00:00 0:00:01.671872 25092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T12:27:02.295510+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T11:00:00+00:00 PythonOperator 2021-05-06T12:26:54.966467+00:00 2021-05-06T12:26:58.353343+00:00 0:00:03.386876 25091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:26:52.296851+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T11:00:00+00:00 PythonOperator 2021-05-06T12:26:54.509994+00:00 2021-05-06T12:26:57.577652+00:00 0:00:03.067658 25090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:26:52.296810+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T11:05:00+00:00 PythonOperator 2021-05-06T12:26:44.883258+00:00 2021-05-06T12:26:47.930328+00:00 0:00:03.047070 25089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:26:42.266033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T11:00:00+00:00 TriggerDagRunOperator 2021-05-06T12:26:36.916531+00:00 2021-05-06T12:26:37.505321+00:00 0:00:00.588790 25088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:26:34.271721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T11:00:00+00:00 TriggerDagRunOperator 2021-05-06T12:26:36.774119+00:00 2021-05-06T12:26:37.175620+00:00 0:00:00.401501 25087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:26:34.271693+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T11:00:00+00:00 EmrJobFlowSensor 2021-05-06T12:00:56.104985+00:00 2021-05-06T12:10:59.011858+00:00 0:10:02.906873 25085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:00:53.781083+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:00:34.059749+00:00 2021-05-06T12:00:35.993604+00:00 0:00:01.933855 25084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T12:00:31.696695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T11:00:00+00:00 PythonOperator 2021-05-06T12:00:11.682856+00:00 2021-05-06T12:00:14.755247+00:00 0:00:03.072391 25083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T12:00:09.571320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T10:00:00+00:00 EmrJobFlowSensor 2021-05-06T11:13:54.717429+00:00 2021-05-06T11:23:57.364407+00:00 0:10:02.646978 25082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:13:52.602614+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T10:00:00+00:00 EmrJobFlowSensor 2021-05-06T11:13:50.676704+00:00 2021-05-06T11:23:53.469223+00:00 0:10:02.792519 25081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:13:48.611566+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:13:32.829325+00:00 2021-05-06T11:13:34.493172+00:00 0:00:01.663847 25080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T11:13:30.648437+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:13:28.890876+00:00 2021-05-06T11:13:30.625875+00:00 0:00:01.734999 25079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T11:13:26.579233+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T10:00:00+00:00 PythonOperator 2021-05-06T11:13:11.115017+00:00 2021-05-06T11:13:14.200375+00:00 0:00:03.085358 25078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:13:08.646817+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T10:00:00+00:00 PythonOperator 2021-05-06T11:13:08.789132+00:00 2021-05-06T11:13:12.069149+00:00 0:00:03.280017 25077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:13:06.552673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T10:00:00+00:00 TriggerDagRunOperator 2021-05-06T11:12:51.036345+00:00 2021-05-06T11:12:51.564295+00:00 0:00:00.527950 25076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:12:48.556352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T10:00:00+00:00 TriggerDagRunOperator 2021-05-06T11:12:50.874038+00:00 2021-05-06T11:12:51.296089+00:00 0:00:00.422051 25075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:12:48.556400+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T10:05:00+00:00 EmrJobFlowSensor 2021-05-06T11:05:51.981496+00:00 2021-05-06T11:14:54.694395+00:00 0:09:02.712899 25074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:05:49.800644+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:05:30.404410+00:00 2021-05-06T11:05:32.101126+00:00 0:00:01.696716 25073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T11:05:27.864293+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T10:05:00+00:00 PythonOperator 2021-05-06T11:05:07.943136+00:00 2021-05-06T11:05:10.963168+00:00 0:00:03.020032 25072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:05:05.752444+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T10:00:00+00:00 EmrJobFlowSensor 2021-05-06T11:03:25.923521+00:00 2021-05-06T11:12:28.886662+00:00 0:09:02.963141 25071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:03:23.586672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:03:05.732142+00:00 2021-05-06T11:03:07.426461+00:00 0:00:01.694319 25070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T11:03:03.549580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T10:00:00+00:00 PythonOperator 2021-05-06T11:02:44.200570+00:00 2021-05-06T11:02:47.285550+00:00 0:00:03.084980 25069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T11:02:41.531367+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T09:00:00+00:00 EmrJobFlowSensor 2021-05-06T10:10:07.607113+00:00 2021-05-06T10:19:10.263184+00:00 0:09:02.656071 25067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:10:05.357965+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T09:00:00+00:00 EmrJobFlowSensor 2021-05-06T10:09:57.464366+00:00 2021-05-06T10:20:00.384237+00:00 0:10:02.919871 25066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:09:55.238539+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T10:09:47.383064+00:00 2021-05-06T10:09:49.038209+00:00 0:00:01.655145 25065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T10:09:45.244588+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T10:09:35.392583+00:00 2021-05-06T10:09:37.053722+00:00 0:00:01.661139 25064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T10:09:33.184492+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T09:00:00+00:00 PythonOperator 2021-05-06T10:09:25.423596+00:00 2021-05-06T10:09:28.443024+00:00 0:00:03.019428 25063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T10:09:23.158403+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T09:00:00+00:00 PythonOperator 2021-05-06T10:09:13.265345+00:00 2021-05-06T10:09:17.192722+00:00 0:00:03.927377 25062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T10:09:11.085543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T09:00:00+00:00 TriggerDagRunOperator 2021-05-06T10:09:09.383916+00:00 2021-05-06T10:09:09.921034+00:00 0:00:00.537118 25061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:09:07.029526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T09:00:00+00:00 TriggerDagRunOperator 2021-05-06T10:09:09.315816+00:00 2021-05-06T10:09:09.752782+00:00 0:00:00.436966 25060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:09:07.029493+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T09:05:00+00:00 EmrJobFlowSensor 2021-05-06T10:05:58.892577+00:00 2021-05-06T10:14:01.277348+00:00 0:08:02.384771 25059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:05:56.677393+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T10:05:36.844820+00:00 2021-05-06T10:05:38.565273+00:00 0:00:01.720453 25058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T10:05:34.663492+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T09:05:00+00:00 PythonOperator 2021-05-06T10:05:12.725190+00:00 2021-05-06T10:05:15.762045+00:00 0:00:03.036855 25057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T10:05:10.486827+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T09:00:00+00:00 EmrJobFlowSensor 2021-05-06T10:00:50.686465+00:00 2021-05-06T10:08:53.351207+00:00 0:08:02.664742 25056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T10:00:48.173271+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T10:00:28.525909+00:00 2021-05-06T10:00:30.348978+00:00 0:00:01.823069 25055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T10:00:26.168076+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T09:00:00+00:00 PythonOperator 2021-05-06T10:00:08.381760+00:00 2021-05-06T10:00:11.459921+00:00 0:00:03.078161 25054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T10:00:06.084308+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T08:00:00+00:00 EmrJobFlowSensor 2021-05-06T09:11:02.493737+00:00 2021-05-06T09:21:05.296555+00:00 0:10:02.802818 25052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T09:11:00.243449+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T09:10:38.347798+00:00 2021-05-06T09:10:40.056180+00:00 0:00:01.708382 25051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T09:10:36.140542+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T08:00:00+00:00 EmrJobFlowSensor 2021-05-06T09:10:30.300560+00:00 2021-05-06T09:19:32.902556+00:00 0:09:02.601996 25050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T09:10:28.166234+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T08:00:00+00:00 PythonOperator 2021-05-06T09:10:08.336188+00:00 2021-05-06T09:10:11.487717+00:00 0:00:03.151529 25049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T09:10:06.114134+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T09:10:02.456192+00:00 2021-05-06T09:10:04.218859+00:00 0:00:01.762667 25048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T09:10:00.177570+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T08:00:00+00:00 PythonOperator 2021-05-06T09:09:32.327622+00:00 2021-05-06T09:09:35.614716+00:00 0:00:03.287094 25047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T09:09:30.083902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T08:00:00+00:00 TriggerDagRunOperator 2021-05-06T09:09:00.897102+00:00 2021-05-06T09:09:01.337069+00:00 0:00:00.439967 25046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T09:08:58.160766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T08:00:00+00:00 TriggerDagRunOperator 2021-05-06T09:09:00.827298+00:00 2021-05-06T09:09:01.396415+00:00 0:00:00.569117 25045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T09:08:58.160721+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T08:05:00+00:00 EmrJobFlowSensor 2021-05-06T09:05:55.961963+00:00 2021-05-06T09:14:58.597012+00:00 0:09:02.635049 25044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T09:05:53.709247+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T09:05:34.151771+00:00 2021-05-06T09:05:35.890869+00:00 0:00:01.739098 25043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T09:05:31.761692+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T08:05:00+00:00 PythonOperator 2021-05-06T09:05:11.913554+00:00 2021-05-06T09:05:15.009169+00:00 0:00:03.095615 25042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T09:05:09.755209+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2021-05-06T09:00:58.656867+00:00 PythonOperator 2021-05-06T09:01:27.538806+00:00 2021-05-06T09:01:30.620158+00:00 0:00:03.081352 25041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T09:01:25.341331+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T08:00:00+00:00 EmrJobFlowSensor 2021-05-06T09:00:51.438854+00:00 2021-05-06T09:08:53.880505+00:00 0:08:02.441651 25040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T09:00:49.305790+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T09:00:25.807460+00:00 2021-05-06T09:00:27.656082+00:00 0:00:01.848622 25039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T09:00:23.280655+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T08:00:00+00:00 PythonOperator 2021-05-06T09:00:05.610958+00:00 2021-05-06T09:00:08.651454+00:00 0:00:03.040496 25038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T09:00:03.265765+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T07:00:00+00:00 EmrJobFlowSensor 2021-05-06T08:10:01.317770+00:00 2021-05-06T08:19:03.945782+00:00 0:09:02.628012 25036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T08:09:59.181893+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T07:00:00+00:00 EmrJobFlowSensor 2021-05-06T08:09:57.509528+00:00 2021-05-06T08:20:00.299376+00:00 0:10:02.789848 25035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T08:09:55.172197+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T08:09:39.578013+00:00 2021-05-06T08:09:41.392989+00:00 0:00:01.814976 25034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T08:09:37.130149+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T08:09:37.207313+00:00 2021-05-06T08:09:38.902842+00:00 0:00:01.695529 25033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T08:09:35.128190+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T07:00:00+00:00 PythonOperator 2021-05-06T08:09:19.838918+00:00 2021-05-06T08:09:23.130287+00:00 0:00:03.291369 25032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T08:09:17.067374+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T07:00:00+00:00 PythonOperator 2021-05-06T08:09:15.295540+00:00 2021-05-06T08:09:19.211399+00:00 0:00:03.915859 25031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T08:09:13.064194+00:00 2 default_pool