Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 check_cluster_status 2021-04-14T11:05:00+00:00 EmrJobFlowSensor 2021-04-14T12:05:47.983137+00:00 2021-04-14T12:14:50.425300+00:00 0:09:02.442163 17090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:05:45.719046+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T12:05:28.243549+00:00 2021-04-14T12:05:29.962524+00:00 0:00:01.718975 17089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T12:05:25.706897+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T12:05:26.009231+00:00 2021-04-14T12:05:27.704241+00:00 0:00:01.695010 17088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T12:05:23.705004+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T11:00:00+00:00 PythonOperator 2021-04-14T12:05:06.355265+00:00 2021-04-14T12:05:09.295712+00:00 0:00:02.940447 17087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T12:05:03.466157+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T11:05:00+00:00 PythonOperator 2021-04-14T12:05:06.260686+00:00 2021-04-14T12:05:09.332481+00:00 0:00:03.071795 17086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T12:05:03.466121+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-14T11:41:29.172080+00:00 PythonOperator 2021-04-14T11:41:59.255927+00:00 2021-04-14T11:42:02.723537+00:00 0:00:03.467610 17084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T11:41:57.101566+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-14T11:41:29.172080+00:00 PythonOperator 2021-04-14T11:41:35.856085+00:00 2021-04-14T11:41:36.168563+00:00 0:00:00.312478 17083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T11:41:33.081064+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T10:00:00+00:00 EmrJobFlowSensor 2021-04-14T11:10:10.881402+00:00 2021-04-14T11:20:13.637204+00:00 0:10:02.755802 17082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T11:10:08.187737+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T10:00:00+00:00 EmrJobFlowSensor 2021-04-14T11:10:08.394770+00:00 2021-04-14T11:18:11.340974+00:00 0:08:02.946204 17081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T11:10:06.188524+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T11:09:48.373236+00:00 2021-04-14T11:09:50.155725+00:00 0:00:01.782489 17080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T11:09:46.121148+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T11:09:44.600285+00:00 2021-04-14T11:09:46.402209+00:00 0:00:01.801924 17079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T11:09:42.171159+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T10:00:00+00:00 PythonOperator 2021-04-14T11:09:27.544880+00:00 2021-04-14T11:09:30.643711+00:00 0:00:03.098831 17078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T11:09:24.107413+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T10:00:00+00:00 PythonOperator 2021-04-14T11:09:25.245768+00:00 2021-04-14T11:09:28.746219+00:00 0:00:03.500451 17077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T11:09:22.154142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T10:00:00+00:00 TriggerDagRunOperator 2021-04-14T11:09:16.779128+00:00 2021-04-14T11:09:17.271825+00:00 0:00:00.492697 17076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T11:09:14.171591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T10:00:00+00:00 TriggerDagRunOperator 2021-04-14T11:09:16.577985+00:00 2021-04-14T11:09:17.014668+00:00 0:00:00.436683 17075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T11:09:14.171643+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T10:05:00+00:00 EmrJobFlowSensor 2021-04-14T11:06:10.222829+00:00 2021-04-14T11:15:12.747817+00:00 0:09:02.524988 17074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T11:06:07.893530+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T11:05:42.032099+00:00 2021-04-14T11:05:43.663445+00:00 0:00:01.631346 17073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T11:05:39.829264+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T10:05:00+00:00 PythonOperator 2021-04-14T11:05:15.967307+00:00 2021-04-14T11:05:18.884702+00:00 0:00:02.917395 17072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T11:05:13.804066+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T10:00:00+00:00 EmrJobFlowSensor 2021-04-14T11:00:47.658531+00:00 2021-04-14T11:08:50.188954+00:00 0:08:02.530423 17071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T11:00:45.352466+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T11:00:26.065798+00:00 2021-04-14T11:00:27.932750+00:00 0:00:01.866952 17070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T11:00:23.245641+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T10:00:00+00:00 PythonOperator 2021-04-14T11:00:05.904000+00:00 2021-04-14T11:00:08.851296+00:00 0:00:02.947296 17069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T11:00:03.252883+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T09:00:00+00:00 EmrJobFlowSensor 2021-04-14T10:11:11.400560+00:00 2021-04-14T10:20:14.205076+00:00 0:09:02.804516 17067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T10:11:08.948229+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T09:00:00+00:00 EmrJobFlowSensor 2021-04-14T10:11:11.205231+00:00 2021-04-14T10:20:13.872659+00:00 0:09:02.667428 17066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T10:11:08.948181+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T10:10:51.146645+00:00 2021-04-14T10:10:52.846114+00:00 0:00:01.699469 17065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T10:10:48.803156+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T10:10:51.151476+00:00 2021-04-14T10:10:52.939691+00:00 0:00:01.788215 17064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T10:10:48.803120+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T09:00:00+00:00 PythonOperator 2021-04-14T10:10:29.839489+00:00 2021-04-14T10:10:32.972086+00:00 0:00:03.132597 17063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T10:10:26.864479+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T09:00:00+00:00 PythonOperator 2021-04-14T10:10:29.733759+00:00 2021-04-14T10:10:33.047498+00:00 0:00:03.313739 17062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T10:10:26.864446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T09:00:00+00:00 TriggerDagRunOperator 2021-04-14T10:10:17.043921+00:00 2021-04-14T10:10:17.459757+00:00 0:00:00.415836 17061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T10:10:14.747172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T09:00:00+00:00 TriggerDagRunOperator 2021-04-14T10:10:17.045052+00:00 2021-04-14T10:10:17.576085+00:00 0:00:00.531033 17060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T10:10:14.747204+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T09:05:00+00:00 EmrJobFlowSensor 2021-04-14T10:06:10.837015+00:00 2021-04-14T10:15:13.414907+00:00 0:09:02.577892 17059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T10:06:08.553750+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T10:05:50.579432+00:00 2021-04-14T10:05:52.204764+00:00 0:00:01.625332 17058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T10:05:48.427329+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T09:05:00+00:00 PythonOperator 2021-04-14T10:05:28.689551+00:00 2021-04-14T10:05:31.553115+00:00 0:00:02.863564 17057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T10:05:26.417776+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T09:00:00+00:00 EmrJobFlowSensor 2021-04-14T10:01:04.727137+00:00 2021-04-14T10:10:07.489182+00:00 0:09:02.762045 17056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T10:01:02.162825+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T10:00:42.406216+00:00 2021-04-14T10:00:44.129674+00:00 0:00:01.723458 17055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T10:00:40.159372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T09:00:00+00:00 PythonOperator 2021-04-14T10:00:22.401709+00:00 2021-04-14T10:00:25.450583+00:00 0:00:03.048874 17054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T10:00:20.076066+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T08:00:00+00:00 EmrJobFlowSensor 2021-04-14T09:11:18.179317+00:00 2021-04-14T09:21:21.008119+00:00 0:10:02.828802 17052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T09:11:15.771223+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T08:00:00+00:00 EmrJobFlowSensor 2021-04-14T09:11:08.384793+00:00 2021-04-14T09:20:11.101349+00:00 0:09:02.716556 17051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T09:11:05.745859+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T09:10:56.227859+00:00 2021-04-14T09:10:57.936108+00:00 0:00:01.708249 17050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T09:10:53.753686+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T09:10:46.327554+00:00 2021-04-14T09:10:48.091088+00:00 0:00:01.763534 17049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T09:10:43.743849+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T08:00:00+00:00 PythonOperator 2021-04-14T09:10:34.046958+00:00 2021-04-14T09:10:37.151014+00:00 0:00:03.104056 17048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T09:10:31.728424+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T08:00:00+00:00 PythonOperator 2021-04-14T09:10:24.296063+00:00 2021-04-14T09:10:27.285512+00:00 0:00:02.989449 17047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T09:10:21.741827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T08:00:00+00:00 TriggerDagRunOperator 2021-04-14T09:10:20.223711+00:00 2021-04-14T09:10:20.741104+00:00 0:00:00.517393 17046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T09:10:17.688280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T08:00:00+00:00 TriggerDagRunOperator 2021-04-14T09:10:20.137682+00:00 2021-04-14T09:10:20.535664+00:00 0:00:00.397982 17045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T09:10:17.688315+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T08:05:00+00:00 EmrJobFlowSensor 2021-04-14T09:05:49.466804+00:00 2021-04-14T09:14:51.980676+00:00 0:09:02.513872 17044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T09:05:47.264920+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T09:05:29.493744+00:00 2021-04-14T09:05:31.198399+00:00 0:00:01.704655 17043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T09:05:27.157347+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T08:05:00+00:00 PythonOperator 2021-04-14T09:05:07.341621+00:00 2021-04-14T09:05:10.205581+00:00 0:00:02.863960 17042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T09:05:05.144456+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T08:00:00+00:00 EmrJobFlowSensor 2021-04-14T09:01:04.915466+00:00 2021-04-14T09:10:07.797851+00:00 0:09:02.882385 17041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T09:01:02.393928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T09:00:36.600208+00:00 2021-04-14T09:00:38.313475+00:00 0:00:01.713267 17040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T09:00:34.363361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T08:00:00+00:00 PythonOperator 2021-04-14T09:00:12.598324+00:00 2021-04-14T09:00:15.571225+00:00 0:00:02.972901 17039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T09:00:10.321533+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T07:00:00+00:00 EmrJobFlowSensor 2021-04-14T08:12:34.965677+00:00 2021-04-14T08:21:37.682803+00:00 0:09:02.717126 17037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T08:12:32.561150+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T07:00:00+00:00 EmrJobFlowSensor 2021-04-14T08:12:17.329373+00:00 2021-04-14T08:21:19.893070+00:00 0:09:02.563697 17036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T08:12:14.541497+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T08:12:11.337247+00:00 2021-04-14T08:12:13.092753+00:00 0:00:01.755506 17035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T08:12:08.536614+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T08:11:56.838963+00:00 2021-04-14T08:11:58.606718+00:00 0:00:01.767755 17034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T08:11:54.525326+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T07:00:00+00:00 PythonOperator 2021-04-14T08:11:50.709278+00:00 2021-04-14T08:11:53.777707+00:00 0:00:03.068429 17033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T08:11:48.521338+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T07:00:00+00:00 PythonOperator 2021-04-14T08:11:34.872560+00:00 2021-04-14T08:11:38.549425+00:00 0:00:03.676865 17032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T08:11:32.511450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T07:00:00+00:00 TriggerDagRunOperator 2021-04-14T08:11:25.133895+00:00 2021-04-14T08:11:25.666803+00:00 0:00:00.532908 17031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T08:11:22.569795+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T07:00:00+00:00 TriggerDagRunOperator 2021-04-14T08:11:25.086223+00:00 2021-04-14T08:11:25.478367+00:00 0:00:00.392144 17030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T08:11:22.569750+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T07:05:00+00:00 EmrJobFlowSensor 2021-04-14T08:05:50.251067+00:00 2021-04-14T08:14:52.862534+00:00 0:09:02.611467 17029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T08:05:48.024173+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T08:05:28.322937+00:00 2021-04-14T08:05:29.998923+00:00 0:00:01.675986 17028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T08:05:26.066425+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T07:05:00+00:00 PythonOperator 2021-04-14T08:05:08.343175+00:00 2021-04-14T08:05:11.654455+00:00 0:00:03.311280 17027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T08:05:05.992406+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T07:00:00+00:00 EmrJobFlowSensor 2021-04-14T08:00:58.447874+00:00 2021-04-14T08:11:01.332732+00:00 0:10:02.884858 17026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T08:00:55.766884+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T08:00:37.947190+00:00 2021-04-14T08:00:39.606648+00:00 0:00:01.659458 17025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T08:00:35.699292+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T07:00:00+00:00 PythonOperator 2021-04-14T08:00:16.485455+00:00 2021-04-14T08:00:19.488721+00:00 0:00:03.003266 17024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T08:00:13.614318+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T06:00:00+00:00 EmrJobFlowSensor 2021-04-14T07:11:10.988946+00:00 2021-04-14T07:21:13.828526+00:00 0:10:02.839580 17022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T07:11:08.791812+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T06:00:00+00:00 EmrJobFlowSensor 2021-04-14T07:11:06.933290+00:00 2021-04-14T07:23:09.968849+00:00 0:12:03.035559 17021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T07:11:04.755214+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T07:10:50.887310+00:00 2021-04-14T07:10:52.593328+00:00 0:00:01.706018 17020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T07:10:48.734017+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T07:10:47.310057+00:00 2021-04-14T07:10:49.171342+00:00 0:00:01.861285 17019 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T07:10:44.729602+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T06:00:00+00:00 PythonOperator 2021-04-14T07:10:29.977660+00:00 2021-04-14T07:10:32.956762+00:00 0:00:02.979102 17018 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T07:10:26.777368+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T06:00:00+00:00 PythonOperator 2021-04-14T07:10:25.819320+00:00 2021-04-14T07:10:29.512946+00:00 0:00:03.693626 17017 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T07:10:22.771237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T06:00:00+00:00 TriggerDagRunOperator 2021-04-14T07:10:13.167881+00:00 2021-04-14T07:10:13.572774+00:00 0:00:00.404893 17016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T07:10:10.692585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T06:00:00+00:00 TriggerDagRunOperator 2021-04-14T07:10:13.208919+00:00 2021-04-14T07:10:13.754706+00:00 0:00:00.545787 17015 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T07:10:10.692620+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T06:05:00+00:00 EmrJobFlowSensor 2021-04-14T07:05:54.763852+00:00 2021-04-14T07:14:57.394619+00:00 0:09:02.630767 17014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T07:05:52.458272+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T07:05:33.107726+00:00 2021-04-14T07:05:34.820603+00:00 0:00:01.712877 17013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T07:05:30.319897+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T06:05:00+00:00 PythonOperator 2021-04-14T07:05:12.539840+00:00 2021-04-14T07:05:15.441724+00:00 0:00:02.901884 17012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T07:05:10.304681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T06:00:00+00:00 EmrJobFlowSensor 2021-04-14T07:01:02.326426+00:00 2021-04-14T07:10:05.090732+00:00 0:09:02.764306 17011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T07:00:59.944349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T07:00:40.098775+00:00 2021-04-14T07:00:41.912783+00:00 0:00:01.814008 17010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T07:00:37.829734+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T06:00:00+00:00 PythonOperator 2021-04-14T07:00:20.586821+00:00 2021-04-14T07:00:23.446956+00:00 0:00:02.860135 17009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T07:00:17.813187+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T05:00:00+00:00 EmrJobFlowSensor 2021-04-14T06:12:21.078095+00:00 2021-04-14T06:22:24.020297+00:00 0:10:02.942202 17007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:12:18.883500+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T05:00:00+00:00 EmrJobFlowSensor 2021-04-14T06:12:14.997995+00:00 2021-04-14T06:21:17.600720+00:00 0:09:02.602725 17006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:12:12.816179+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:11:59.315142+00:00 2021-04-14T06:12:01.139569+00:00 0:00:01.824427 17005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T06:11:56.869772+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:11:53.684595+00:00 2021-04-14T06:11:55.347323+00:00 0:00:01.662728 17004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T06:11:50.797936+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T05:00:00+00:00 PythonOperator 2021-04-14T06:11:39.130236+00:00 2021-04-14T06:11:42.206409+00:00 0:00:03.076173 17003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:11:36.788624+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T05:00:00+00:00 PythonOperator 2021-04-14T06:11:31.045276+00:00 2021-04-14T06:11:34.049093+00:00 0:00:03.003817 17002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:11:28.779834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T05:00:00+00:00 TriggerDagRunOperator 2021-04-14T06:11:25.151159+00:00 2021-04-14T06:11:25.559668+00:00 0:00:00.408509 17001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:11:22.776370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T05:00:00+00:00 TriggerDagRunOperator 2021-04-14T06:11:25.118866+00:00 2021-04-14T06:11:25.677406+00:00 0:00:00.558540 17000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:11:22.776403+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T05:05:00+00:00 EmrJobFlowSensor 2021-04-14T06:06:00.980412+00:00 2021-04-14T06:15:03.839656+00:00 0:09:02.859244 16999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:05:58.541295+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:05:40.557333+00:00 2021-04-14T06:05:42.261511+00:00 0:00:01.704178 16998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T06:05:38.379462+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T05:05:00+00:00 PythonOperator 2021-04-14T06:05:16.451591+00:00 2021-04-14T06:05:19.312247+00:00 0:00:02.860656 16997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:05:14.311967+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T05:00:00+00:00 EmrJobFlowSensor 2021-04-14T06:01:04.435622+00:00 2021-04-14T06:11:07.498167+00:00 0:10:03.062545 16996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:01:02.006839+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:00:40.240479+00:00 2021-04-14T06:00:41.965756+00:00 0:00:01.725277 16995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T06:00:38.044397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T05:00:00+00:00 PythonOperator 2021-04-14T06:00:20.460677+00:00 2021-04-14T06:00:23.373024+00:00 0:00:02.912347 16994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T06:00:17.930326+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T04:00:00+00:00 EmrJobFlowSensor 2021-04-14T05:12:10.200127+00:00 2021-04-14T05:22:13.079178+00:00 0:10:02.879051 16992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:12:07.758213+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T04:00:00+00:00 EmrJobFlowSensor 2021-04-14T05:12:06.096414+00:00 2021-04-14T05:22:08.898244+00:00 0:10:02.801830 16991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:12:03.688594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T05:11:48.097716+00:00 2021-04-14T05:11:49.823962+00:00 0:00:01.726246 16990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T05:11:45.636744+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T05:11:44.240102+00:00 2021-04-14T05:11:46.081169+00:00 0:00:01.841067 16989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T05:11:41.630794+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T04:00:00+00:00 PythonOperator 2021-04-14T05:11:16.435984+00:00 2021-04-14T05:11:19.342627+00:00 0:00:02.906643 16988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T05:11:13.613691+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T04:00:00+00:00 PythonOperator 2021-04-14T05:11:11.921203+00:00 2021-04-14T05:11:15.112532+00:00 0:00:03.191329 16987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T05:11:09.600497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T04:00:00+00:00 TriggerDagRunOperator 2021-04-14T05:11:04.186794+00:00 2021-04-14T05:11:04.832715+00:00 0:00:00.645921 16986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:11:01.596446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T04:00:00+00:00 TriggerDagRunOperator 2021-04-14T05:11:04.032087+00:00 2021-04-14T05:11:04.776484+00:00 0:00:00.744397 16985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:11:01.596413+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T04:05:00+00:00 EmrJobFlowSensor 2021-04-14T05:07:03.421300+00:00 2021-04-14T05:15:06.084776+00:00 0:08:02.663476 16984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:07:01.101539+00:00 2 default_pool