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 booking-processing-job_v002 check_cluster_status 2021-04-14T13:00:00+00:00 EmrJobFlowSensor 2021-04-14T14:15:14.091063+00:00 2021-04-14T14:25:17.069912+00:00 0:10:02.978849 17128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:15:11.749480+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:15:10.090664+00:00 2021-04-14T14:15:11.799446+00:00 0:00:01.708782 17127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T14:15:07.781784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:14:51.845702+00:00 2021-04-14T14:14:53.542574+00:00 0:00:01.696872 17126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T14:14:49.687619+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T13:00:00+00:00 PythonOperator 2021-04-14T14:14:45.891677+00:00 2021-04-14T14:14:48.869893+00:00 0:00:02.978216 17125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:14:43.678586+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T13:00:00+00:00 PythonOperator 2021-04-14T14:14:31.879078+00:00 2021-04-14T14:14:35.080868+00:00 0:00:03.201790 17124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:14:29.668336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T13:00:00+00:00 TriggerDagRunOperator 2021-04-14T14:14:26.289048+00:00 2021-04-14T14:14:26.752243+00:00 0:00:00.463195 17123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:14:23.665588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T13:00:00+00:00 TriggerDagRunOperator 2021-04-14T14:14:26.319446+00:00 2021-04-14T14:14:26.887547+00:00 0:00:00.568101 17122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:14:23.665554+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T13:05:00+00:00 EmrJobFlowSensor 2021-04-14T14:06:03.311192+00:00 2021-04-14T14:15:05.802091+00:00 0:09:02.490899 17120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:06:00.989907+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:05:41.247539+00:00 2021-04-14T14:05:42.866235+00:00 0:00:01.618696 17119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T14:05:38.960421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T13:05:00+00:00 PythonOperator 2021-04-14T14:05:20.999624+00:00 2021-04-14T14:05:24.212339+00:00 0:00:03.212715 17118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:05:18.855119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T13:00:00+00:00 EmrJobFlowSensor 2021-04-14T14:01:14.703121+00:00 2021-04-14T14:10:17.439504+00:00 0:09:02.736383 17117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:01:12.394269+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:00:42.590723+00:00 2021-04-14T14:00:44.321868+00:00 0:00:01.731145 17116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T14:00:40.343885+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T13:00:00+00:00 PythonOperator 2021-04-14T14:00:14.674168+00:00 2021-04-14T14:00:17.597375+00:00 0:00:02.923207 17115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T14:00:12.322854+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T12:00:00+00:00 EmrJobFlowSensor 2021-04-14T13:12:07.115643+00:00 2021-04-14T13:21:09.789288+00:00 0:09:02.673645 17114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:12:04.953584+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T12:00:00+00:00 EmrJobFlowSensor 2021-04-14T13:11:47.598167+00:00 2021-04-14T13:20:50.358708+00:00 0:09:02.760541 17113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:11:44.971437+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:11:43.908082+00:00 2021-04-14T13:11:45.763045+00:00 0:00:01.854963 17112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T13:11:40.970760+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:11:25.663059+00:00 2021-04-14T13:11:27.338524+00:00 0:00:01.675465 17111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T13:11:22.955408+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T12:00:00+00:00 PythonOperator 2021-04-14T13:11:23.336761+00:00 2021-04-14T13:11:27.097474+00:00 0:00:03.760713 17110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:11:20.962122+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T12:00:00+00:00 PythonOperator 2021-04-14T13:11:03.170480+00:00 2021-04-14T13:11:06.133483+00:00 0:00:02.963003 17109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:11:00.875379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T12:00:00+00:00 TriggerDagRunOperator 2021-04-14T13:10:59.310646+00:00 2021-04-14T13:10:59.743423+00:00 0:00:00.432777 17108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:10:56.858116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T12:00:00+00:00 TriggerDagRunOperator 2021-04-14T13:10:59.298818+00:00 2021-04-14T13:10:59.850448+00:00 0:00:00.551630 17107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:10:56.858165+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T12:05:00+00:00 EmrJobFlowSensor 2021-04-14T13:09:40.875284+00:00 2021-04-14T13:18:43.409491+00:00 0:09:02.534207 17106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:09:38.694165+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:09:20.857860+00:00 2021-04-14T13:09:22.667647+00:00 0:00:01.809787 17105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T13:09:18.652683+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T12:05:00+00:00 PythonOperator 2021-04-14T13:08:59.295758+00:00 2021-04-14T13:09:02.136706+00:00 0:00:02.840948 17104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:08:56.629111+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T12:00:00+00:00 EmrJobFlowSensor 2021-04-14T13:00:49.304715+00:00 2021-04-14T13:10:52.113074+00:00 0:10:02.808359 17102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:00:47.126272+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:00:27.399579+00:00 2021-04-14T13:00:29.122222+00:00 0:00:01.722643 17101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T13:00:25.106062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T12:00:00+00:00 PythonOperator 2021-04-14T13:00:05.500686+00:00 2021-04-14T13:00:08.383325+00:00 0:00:02.882639 17100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T13:00:03.148311+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T11:00:00+00:00 EmrJobFlowSensor 2021-04-14T12:14:56.839325+00:00 2021-04-14T12:24:59.507973+00:00 0:10:02.668648 17099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:14:54.604548+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T11:00:00+00:00 EmrJobFlowSensor 2021-04-14T12:14:52.989635+00:00 2021-04-14T12:24:55.636709+00:00 0:10:02.647074 17098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:14:50.601196+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T12:14:34.838346+00:00 2021-04-14T12:14:36.672953+00:00 0:00:01.834607 17097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T12:14:32.596272+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T12:14:31.014968+00:00 2021-04-14T12:14:32.697320+00:00 0:00:01.682352 17096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T12:14:28.646418+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T11:00:00+00:00 PythonOperator 2021-04-14T12:14:12.732136+00:00 2021-04-14T12:14:16.107028+00:00 0:00:03.374892 17095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T12:14:10.519010+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T11:00:00+00:00 PythonOperator 2021-04-14T12:14:10.785699+00:00 2021-04-14T12:14:13.700028+00:00 0:00:02.914329 17094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T12:14:08.517859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T11:00:00+00:00 TriggerDagRunOperator 2021-04-14T12:13:56.882581+00:00 2021-04-14T12:13:57.392253+00:00 0:00:00.509672 17093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:13:54.504259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T11:00:00+00:00 TriggerDagRunOperator 2021-04-14T12:13:56.765815+00:00 2021-04-14T12:13:57.161815+00:00 0:00:00.396000 17092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:13:54.504231+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T11:00:00+00:00 EmrJobFlowSensor 2021-04-14T12:05:48.104502+00:00 2021-04-14T12:13:50.649654+00:00 0:08:02.545152 17091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T12:05:45.719076+00:00 2 default_pool
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