Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 check_cluster_status 2021-05-12T11:00:00+00:00 EmrJobFlowSensor 2021-05-12T12:00:54.007584+00:00 2021-05-12T12:10:57.005323+00:00 0:10:02.997739 27264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T12:00:51.402205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T12:00:31.502234+00:00 2021-05-12T12:00:33.221622+00:00 0:00:01.719388 27263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T12:00:29.386865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T11:00:00+00:00 PythonOperator 2021-05-12T12:00:11.565344+00:00 2021-05-12T12:00:14.714562+00:00 0:00:03.149218 27262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T12:00:09.343073+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T10:00:00+00:00 EmrJobFlowSensor 2021-05-12T11:11:28.791242+00:00 2021-05-12T11:20:31.487033+00:00 0:09:02.695791 27260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:11:26.378279+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T10:00:00+00:00 EmrJobFlowSensor 2021-05-12T11:11:12.643744+00:00 2021-05-12T11:21:15.603789+00:00 0:10:02.960045 27259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:11:10.362164+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T11:11:08.497426+00:00 2021-05-12T11:11:10.245575+00:00 0:00:01.748149 27258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T11:11:06.362020+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T11:10:50.463839+00:00 2021-05-12T11:10:52.172179+00:00 0:00:01.708340 27257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T11:10:48.226177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T10:00:00+00:00 PythonOperator 2021-05-12T11:10:38.448951+00:00 2021-05-12T11:10:41.548305+00:00 0:00:03.099354 27256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T11:10:36.214861+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T10:00:00+00:00 PythonOperator 2021-05-12T11:10:28.491140+00:00 2021-05-12T11:10:31.940255+00:00 0:00:03.449115 27255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T11:10:26.221409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T10:00:00+00:00 TriggerDagRunOperator 2021-05-12T11:10:23.287691+00:00 2021-05-12T11:10:23.832518+00:00 0:00:00.544827 27254 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:10:20.266334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T10:00:00+00:00 TriggerDagRunOperator 2021-05-12T11:10:22.637323+00:00 2021-05-12T11:10:23.014399+00:00 0:00:00.377076 27253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:10:20.266303+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T10:05:00+00:00 EmrJobFlowSensor 2021-05-12T11:05:51.909498+00:00 2021-05-12T11:14:54.491257+00:00 0:09:02.581759 27252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T11:05:49.811107+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T11:05:27.865062+00:00 2021-05-12T11:05:29.500775+00:00 0:00:01.635713 27251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T11:05:25.741608+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T10:05:00+00:00 PythonOperator 2021-05-12T11:05:05.938894+00:00 2021-05-12T11:05:09.060115+00:00 0:00:03.121221 27250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T11:05:03.724949+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T10:00:00+00:00 EmrJobFlowSensor 2021-05-12T11:01:11.453830+00:00 2021-05-12T11:10:14.307739+00:00 0:09:02.853909 27249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T11:01:09.256608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T11:00:45.686220+00:00 2021-05-12T11:00:47.510761+00:00 0:00:01.824541 27248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T11:00:43.234852+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T10:00:00+00:00 PythonOperator 2021-05-12T11:00:24.090270+00:00 2021-05-12T11:00:27.221181+00:00 0:00:03.130911 27247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T11:00:21.251059+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T09:00:00+00:00 EmrJobFlowSensor 2021-05-12T10:24:19.676321+00:00 2021-05-12T10:34:22.342882+00:00 0:10:02.666561 27245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T10:24:17.604334+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T09:00:00+00:00 EmrJobFlowSensor 2021-05-12T10:24:06.130118+00:00 2021-05-12T10:33:08.769478+00:00 0:09:02.639360 27244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T10:24:03.592510+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T10:23:57.775427+00:00 2021-05-12T10:23:59.478420+00:00 0:00:01.702993 27243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T10:23:55.647732+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T10:23:41.680757+00:00 2021-05-12T10:23:43.396852+00:00 0:00:01.716095 27242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T10:23:39.565411+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T09:00:00+00:00 PythonOperator 2021-05-12T10:23:35.802564+00:00 2021-05-12T10:23:39.106948+00:00 0:00:03.304384 27241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T10:23:33.570988+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T09:00:00+00:00 PythonOperator 2021-05-12T10:23:15.777895+00:00 2021-05-12T10:23:18.927952+00:00 0:00:03.150057 27240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T10:23:13.516562+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T09:00:00+00:00 TriggerDagRunOperator 2021-05-12T10:23:09.891651+00:00 2021-05-12T10:23:10.439262+00:00 0:00:00.547611 27239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T10:23:07.518997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T09:00:00+00:00 TriggerDagRunOperator 2021-05-12T10:23:09.644067+00:00 2021-05-12T10:23:10.045920+00:00 0:00:00.401853 27238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T10:23:07.518966+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T09:05:00+00:00 EmrJobFlowSensor 2021-05-12T10:05:47.905349+00:00 2021-05-12T10:14:50.591855+00:00 0:09:02.686506 27237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T10:05:45.603182+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T10:05:25.853790+00:00 2021-05-12T10:05:27.509079+00:00 0:00:01.655289 27236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T10:05:23.594436+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T09:05:00+00:00 PythonOperator 2021-05-12T10:05:05.845279+00:00 2021-05-12T10:05:08.948788+00:00 0:00:03.103509 27235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T10:05:03.562236+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T09:00:00+00:00 EmrJobFlowSensor 2021-05-12T10:00:49.494893+00:00 2021-05-12T10:22:54.043062+00:00 0:22:04.548169 27234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T10:00:47.166463+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T10:00:29.399666+00:00 2021-05-12T10:00:31.119522+00:00 0:00:01.719856 27233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T10:00:27.146767+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T09:00:00+00:00 PythonOperator 2021-05-12T10:00:07.489998+00:00 2021-05-12T10:00:10.631784+00:00 0:00:03.141786 27232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T10:00:05.039410+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T08:00:00+00:00 EmrJobFlowSensor 2021-05-12T09:11:16.305125+00:00 2021-05-12T09:21:19.156944+00:00 0:10:02.851819 27230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T09:11:14.047394+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T08:00:00+00:00 EmrJobFlowSensor 2021-05-12T09:11:08.255246+00:00 2021-05-12T09:23:11.334567+00:00 0:12:03.079321 27229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T09:11:06.042509+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T09:10:56.503546+00:00 2021-05-12T09:10:58.238048+00:00 0:00:01.734502 27228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T09:10:54.033985+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T09:10:48.257727+00:00 2021-05-12T09:10:50.110260+00:00 0:00:01.852533 27227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T09:10:46.021887+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T08:00:00+00:00 PythonOperator 2021-05-12T09:10:34.741219+00:00 2021-05-12T09:10:37.780068+00:00 0:00:03.038849 27226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T09:10:32.011630+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T08:00:00+00:00 PythonOperator 2021-05-12T09:10:26.455551+00:00 2021-05-12T09:10:29.997708+00:00 0:00:03.542157 27225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T09:10:24.005267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T08:00:00+00:00 TriggerDagRunOperator 2021-05-12T09:10:20.488695+00:00 2021-05-12T09:10:21.006966+00:00 0:00:00.518271 27224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T09:10:18.004615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T08:00:00+00:00 TriggerDagRunOperator 2021-05-12T09:10:20.370380+00:00 2021-05-12T09:10:20.758143+00:00 0:00:00.387763 27223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T09:10:18.004569+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T08:05:00+00:00 EmrJobFlowSensor 2021-05-12T09:06:07.785228+00:00 2021-05-12T09:14:10.247839+00:00 0:08:02.462611 27222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T09:06:05.639292+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T09:05:45.753127+00:00 2021-05-12T09:05:47.366952+00:00 0:00:01.613825 27221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T09:05:43.619897+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T08:05:00+00:00 PythonOperator 2021-05-12T09:05:25.758254+00:00 2021-05-12T09:05:28.876648+00:00 0:00:03.118394 27220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T09:05:23.601470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T08:00:00+00:00 EmrJobFlowSensor 2021-05-12T09:00:59.454187+00:00 2021-05-12T09:10:02.253588+00:00 0:09:02.799401 27219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T09:00:57.173246+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T09:00:39.493586+00:00 2021-05-12T09:00:41.182029+00:00 0:00:01.688443 27218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T09:00:37.167268+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T08:00:00+00:00 PythonOperator 2021-05-12T09:00:17.611892+00:00 2021-05-12T09:00:20.695699+00:00 0:00:03.083807 27217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T09:00:15.143617+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T07:00:00+00:00 EmrJobFlowSensor 2021-05-12T08:14:30.669182+00:00 2021-05-12T08:23:33.297275+00:00 0:09:02.628093 27215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T08:14:28.076010+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T07:00:00+00:00 EmrJobFlowSensor 2021-05-12T08:14:28.307638+00:00 2021-05-12T08:24:31.386468+00:00 0:10:03.078830 27214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T08:14:26.023706+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T08:14:08.666626+00:00 2021-05-12T08:14:10.450280+00:00 0:00:01.783654 27213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T08:14:06.063995+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T08:14:06.176014+00:00 2021-05-12T08:14:08.269528+00:00 0:00:02.093514 27212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T08:14:04.058745+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T07:00:00+00:00 PythonOperator 2021-05-12T08:13:46.570445+00:00 2021-05-12T08:13:49.707505+00:00 0:00:03.137060 27211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T08:13:43.985130+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T07:00:00+00:00 PythonOperator 2021-05-12T08:13:44.136635+00:00 2021-05-12T08:13:47.892995+00:00 0:00:03.756360 27210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T08:13:41.989145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T07:00:00+00:00 TriggerDagRunOperator 2021-05-12T08:13:30.456316+00:00 2021-05-12T08:13:30.968350+00:00 0:00:00.512034 27209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T08:13:27.957863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T07:00:00+00:00 TriggerDagRunOperator 2021-05-12T08:13:30.374063+00:00 2021-05-12T08:13:30.759979+00:00 0:00:00.385916 27208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T08:13:27.957834+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T07:05:00+00:00 EmrJobFlowSensor 2021-05-12T08:05:47.480991+00:00 2021-05-12T08:14:50.146381+00:00 0:09:02.665390 27207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T08:05:45.202450+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T08:05:25.466682+00:00 2021-05-12T08:05:27.110498+00:00 0:00:01.643816 27206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T08:05:23.241427+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T07:05:00+00:00 PythonOperator 2021-05-12T08:05:05.214571+00:00 2021-05-12T08:05:08.278164+00:00 0:00:03.063593 27205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T08:05:03.117542+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T07:00:00+00:00 EmrJobFlowSensor 2021-05-12T08:01:04.920320+00:00 2021-05-12T08:13:08.199673+00:00 0:12:03.279353 27204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T08:01:02.783705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T08:00:42.908258+00:00 2021-05-12T08:00:44.742290+00:00 0:00:01.834032 27203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T08:00:40.715278+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T07:00:00+00:00 PythonOperator 2021-05-12T08:00:21.047333+00:00 2021-05-12T08:00:24.129401+00:00 0:00:03.082068 27202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T08:00:18.700051+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T06:00:00+00:00 EmrJobFlowSensor 2021-05-12T07:12:04.212733+00:00 2021-05-12T07:24:07.167504+00:00 0:12:02.954771 27200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T07:12:01.989452+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T06:00:00+00:00 EmrJobFlowSensor 2021-05-12T07:12:02.441664+00:00 2021-05-12T07:22:05.443527+00:00 0:10:03.001863 27199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T07:11:59.985745+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T07:11:42.623491+00:00 2021-05-12T07:11:44.327076+00:00 0:00:01.703585 27198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T07:11:39.957459+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T07:11:40.296544+00:00 2021-05-12T07:11:42.293741+00:00 0:00:01.997197 27197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T07:11:37.944492+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T06:00:00+00:00 PythonOperator 2021-05-12T07:11:22.122148+00:00 2021-05-12T07:11:25.479362+00:00 0:00:03.357214 27196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T07:11:19.884983+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T06:00:00+00:00 PythonOperator 2021-05-12T07:11:20.175944+00:00 2021-05-12T07:11:23.304391+00:00 0:00:03.128447 27195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T07:11:17.956923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T06:00:00+00:00 TriggerDagRunOperator 2021-05-12T07:11:10.208263+00:00 2021-05-12T07:11:10.737010+00:00 0:00:00.528747 27194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T07:11:07.827093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T06:00:00+00:00 TriggerDagRunOperator 2021-05-12T07:11:10.046190+00:00 2021-05-12T07:11:10.450338+00:00 0:00:00.404148 27193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T07:11:07.827127+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T06:05:00+00:00 EmrJobFlowSensor 2021-05-12T07:06:07.450745+00:00 2021-05-12T07:15:10.061788+00:00 0:09:02.611043 27192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T07:06:05.361124+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T07:05:45.483645+00:00 2021-05-12T07:05:47.248390+00:00 0:00:01.764745 27191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T07:05:43.262278+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T06:05:00+00:00 PythonOperator 2021-05-12T07:05:25.554148+00:00 2021-05-12T07:05:28.628425+00:00 0:00:03.074277 27190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T07:05:23.245521+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T06:00:00+00:00 EmrJobFlowSensor 2021-05-12T07:00:53.209673+00:00 2021-05-12T07:10:56.135611+00:00 0:10:02.925938 27189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T07:00:50.815251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T07:00:27.026715+00:00 2021-05-12T07:00:28.745289+00:00 0:00:01.718574 27188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T07:00:24.788534+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T06:00:00+00:00 PythonOperator 2021-05-12T07:00:06.885827+00:00 2021-05-12T07:00:09.998159+00:00 0:00:03.112332 27187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T07:00:04.686605+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T05:00:00+00:00 EmrJobFlowSensor 2021-05-12T06:12:30.517995+00:00 2021-05-12T06:22:33.484085+00:00 0:10:02.966090 27185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T06:12:28.248279+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T05:00:00+00:00 EmrJobFlowSensor 2021-05-12T06:12:28.408963+00:00 2021-05-12T06:21:31.136981+00:00 0:09:02.728018 27184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T06:12:26.211170+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T06:12:08.779786+00:00 2021-05-12T06:12:10.553100+00:00 0:00:01.773314 27183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T06:12:06.187161+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T06:12:06.305039+00:00 2021-05-12T06:12:08.341175+00:00 0:00:02.036136 27182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T06:12:04.186055+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T05:00:00+00:00 PythonOperator 2021-05-12T06:11:44.685520+00:00 2021-05-12T06:11:48.019732+00:00 0:00:03.334212 27181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T06:11:42.129809+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T05:00:00+00:00 PythonOperator 2021-05-12T06:11:42.701060+00:00 2021-05-12T06:11:45.799794+00:00 0:00:03.098734 27180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T06:11:40.177481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T05:00:00+00:00 TriggerDagRunOperator 2021-05-12T06:11:36.832509+00:00 2021-05-12T06:11:37.370467+00:00 0:00:00.537958 27179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T06:11:34.485710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T05:00:00+00:00 TriggerDagRunOperator 2021-05-12T06:11:36.661771+00:00 2021-05-12T06:11:37.074752+00:00 0:00:00.412981 27178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T06:11:34.485752+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T05:05:00+00:00 EmrJobFlowSensor 2021-05-12T06:05:51.764036+00:00 2021-05-12T06:14:54.463689+00:00 0:09:02.699653 27177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T06:05:49.702568+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T06:05:29.978376+00:00 2021-05-12T06:05:31.611051+00:00 0:00:01.632675 27176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T06:05:27.759095+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T05:05:00+00:00 PythonOperator 2021-05-12T06:05:09.956948+00:00 2021-05-12T06:05:13.130399+00:00 0:00:03.173451 27175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T06:05:07.640030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T05:00:00+00:00 EmrJobFlowSensor 2021-05-12T06:01:07.197048+00:00 2021-05-12T06:11:10.158940+00:00 0:10:02.961892 27174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T06:01:05.097907+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T06:00:45.664214+00:00 2021-05-12T06:00:47.535307+00:00 0:00:01.871093 27173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T06:00:43.078296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-12T05:00:00+00:00 PythonOperator 2021-05-12T06:00:24.000453+00:00 2021-05-12T06:00:27.075021+00:00 0:00:03.074568 27172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-12T06:00:21.076274+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-12T04:00:00+00:00 EmrJobFlowSensor 2021-05-12T05:17:13.753510+00:00 2021-05-12T05:26:16.436988+00:00 0:09:02.683478 27170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T05:17:11.554095+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-12T04:00:00+00:00 EmrJobFlowSensor 2021-05-12T05:16:13.943127+00:00 2021-05-12T05:24:16.680511+00:00 0:08:02.737384 27169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T05:16:11.563582+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T05:15:56.003173+00:00 2021-05-12T05:15:57.883851+00:00 0:00:01.880678 27168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T05:15:53.492318+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T05:15:51.679711+00:00 2021-05-12T05:15:53.350874+00:00 0:00:01.671163 27167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T05:15:49.452260+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-12T04:00:00+00:00 PythonOperator 2021-05-12T05:15:36.171107+00:00 2021-05-12T05:15:39.665392+00:00 0:00:03.494285 27166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T05:15:33.436629+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-12T04:00:00+00:00 PythonOperator 2021-05-12T05:15:31.553639+00:00 2021-05-12T05:15:35.320432+00:00 0:00:03.766793 27165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T05:15:29.433859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-12T04:00:00+00:00 TriggerDagRunOperator 2021-05-12T05:15:20.075890+00:00 2021-05-12T05:15:20.597860+00:00 0:00:00.521970 27164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T05:15:17.433975+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-12T04:00:00+00:00 TriggerDagRunOperator 2021-05-12T05:15:19.953228+00:00 2021-05-12T05:15:20.439427+00:00 0:00:00.486199 27163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T05:15:17.433940+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-12T04:05:00+00:00 EmrJobFlowSensor 2021-05-12T05:06:04.710357+00:00 2021-05-12T05:17:07.623186+00:00 0:11:02.912829 27162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-12T05:06:02.650425+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-12T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-12T05:05:42.714213+00:00 2021-05-12T05:05:44.351622+00:00 0:00:01.637409 27161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-12T05:05:40.614621+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-12T04:05:00+00:00 PythonOperator 2021-05-12T05:05:20.743328+00:00 2021-05-12T05:05:23.826571+00:00 0:00:03.083243 27160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T05:05:18.596770+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-12T04:00:00+00:00 EmrJobFlowSensor 2021-05-12T05:01:06.327888+00:00 2021-05-12T05:15:09.909494+00:00 0:14:03.581606 27159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-12T05:01:04.008561+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-12T05:00:42.357428+00:00 2021-05-12T05:00:44.029382+00:00 0:00:01.671954 27158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-12T05:00:40.048031+00:00 2 default_pool