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-04-25T07:00:00+00:00 EmrJobFlowSensor 2021-04-25T08:01:03.768836+00:00 2021-04-25T08:09:06.466251+00:00 0:08:02.697415 21032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T08:01:01.291501+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T08:00:39.697887+00:00 2021-04-25T08:00:41.498939+00:00 0:00:01.801052 21031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T08:00:37.264444+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T07:00:00+00:00 PythonOperator 2021-04-25T08:00:17.581805+00:00 2021-04-25T08:00:20.592388+00:00 0:00:03.010583 21030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T08:00:15.220833+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T06:00:00+00:00 EmrJobFlowSensor 2021-04-25T07:11:16.667773+00:00 2021-04-25T07:21:19.458590+00:00 0:10:02.790817 21028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T07:11:14.298815+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T06:00:00+00:00 EmrJobFlowSensor 2021-04-25T07:11:16.458425+00:00 2021-04-25T07:20:19.113679+00:00 0:09:02.655254 21027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T07:11:14.298788+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T07:10:54.683515+00:00 2021-04-25T07:10:56.422394+00:00 0:00:01.738879 21026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T07:10:52.253305+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T07:10:54.657651+00:00 2021-04-25T07:10:56.503754+00:00 0:00:01.846103 21025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T07:10:52.253338+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T06:00:00+00:00 PythonOperator 2021-04-25T07:10:34.618396+00:00 2021-04-25T07:10:37.715242+00:00 0:00:03.096846 21024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T07:10:32.210390+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T06:00:00+00:00 PythonOperator 2021-04-25T07:10:34.532050+00:00 2021-04-25T07:10:38.067500+00:00 0:00:03.535450 21023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T07:10:32.210417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T06:00:00+00:00 TriggerDagRunOperator 2021-04-25T07:10:22.735199+00:00 2021-04-25T07:10:23.167901+00:00 0:00:00.432702 21022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T07:10:20.200552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T06:00:00+00:00 TriggerDagRunOperator 2021-04-25T07:10:22.705141+00:00 2021-04-25T07:10:23.263826+00:00 0:00:00.558685 21021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T07:10:20.200579+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T06:05:00+00:00 EmrJobFlowSensor 2021-04-25T07:06:06.264363+00:00 2021-04-25T07:14:08.883769+00:00 0:08:02.619406 21020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T07:06:03.916309+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T07:05:44.420944+00:00 2021-04-25T07:05:46.144294+00:00 0:00:01.723350 21019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T07:05:41.960346+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T06:05:00+00:00 PythonOperator 2021-04-25T07:05:22.039739+00:00 2021-04-25T07:05:25.000502+00:00 0:00:02.960763 21018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T07:05:19.855290+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T06:00:00+00:00 EmrJobFlowSensor 2021-04-25T07:01:01.758574+00:00 2021-04-25T07:10:04.737057+00:00 0:09:02.978483 21017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T07:00:59.440924+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T07:00:39.910794+00:00 2021-04-25T07:00:41.709384+00:00 0:00:01.798590 21016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T07:00:37.427912+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T06:00:00+00:00 PythonOperator 2021-04-25T07:00:17.998374+00:00 2021-04-25T07:00:20.985981+00:00 0:00:02.987607 21015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T07:00:15.467720+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T05:00:00+00:00 EmrJobFlowSensor 2021-04-25T06:12:19.390524+00:00 2021-04-25T06:20:22.004614+00:00 0:08:02.614090 21013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T06:12:17.097556+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T05:00:00+00:00 EmrJobFlowSensor 2021-04-25T06:12:03.475523+00:00 2021-04-25T06:22:06.339244+00:00 0:10:02.863721 21012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T06:12:01.148074+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T06:11:57.418116+00:00 2021-04-25T06:11:59.104068+00:00 0:00:01.685952 21011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T06:11:55.060352+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T06:11:41.295194+00:00 2021-04-25T06:11:43.139837+00:00 0:00:01.844643 21010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T06:11:39.044026+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T05:00:00+00:00 PythonOperator 2021-04-25T06:11:35.311327+00:00 2021-04-25T06:11:38.360440+00:00 0:00:03.049113 21009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T06:11:32.987212+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T05:00:00+00:00 PythonOperator 2021-04-25T06:11:19.221630+00:00 2021-04-25T06:11:22.550905+00:00 0:00:03.329275 21008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T06:11:16.954636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T05:00:00+00:00 TriggerDagRunOperator 2021-04-25T06:11:13.264396+00:00 2021-04-25T06:11:13.854700+00:00 0:00:00.590304 21007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T06:11:10.946281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T05:00:00+00:00 TriggerDagRunOperator 2021-04-25T06:11:13.204297+00:00 2021-04-25T06:11:13.609778+00:00 0:00:00.405481 21006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T06:11:10.946316+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T05:05:00+00:00 EmrJobFlowSensor 2021-04-25T06:05:54.773814+00:00 2021-04-25T06:15:57.540815+00:00 0:10:02.767001 21005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T06:05:52.513014+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T06:05:32.656138+00:00 2021-04-25T06:05:34.305504+00:00 0:00:01.649366 21004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T06:05:30.483726+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T05:05:00+00:00 PythonOperator 2021-04-25T06:05:10.668621+00:00 2021-04-25T06:05:13.653680+00:00 0:00:02.985059 21003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T06:05:08.463786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T05:00:00+00:00 EmrJobFlowSensor 2021-04-25T06:00:54.430273+00:00 2021-04-25T06:10:57.318506+00:00 0:10:02.888233 21002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T06:00:51.980006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T06:00:34.425148+00:00 2021-04-25T06:00:36.236348+00:00 0:00:01.811200 21001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T06:00:31.947291+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T05:00:00+00:00 PythonOperator 2021-04-25T06:00:12.447116+00:00 2021-04-25T06:00:15.407700+00:00 0:00:02.960584 21000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T06:00:09.952800+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T04:00:00+00:00 EmrJobFlowSensor 2021-04-25T05:11:34.311405+00:00 2021-04-25T05:20:36.919157+00:00 0:09:02.607752 20998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T05:11:32.040986+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T04:00:00+00:00 EmrJobFlowSensor 2021-04-25T05:11:24.219347+00:00 2021-04-25T05:20:26.775248+00:00 0:09:02.555901 20997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T05:11:21.905699+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T05:11:12.101925+00:00 2021-04-25T05:11:13.941696+00:00 0:00:01.839771 20996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T05:11:09.896055+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T05:11:02.153276+00:00 2021-04-25T05:11:03.841283+00:00 0:00:01.688007 20995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T05:10:59.890089+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T04:00:00+00:00 PythonOperator 2021-04-25T05:10:46.118744+00:00 2021-04-25T05:10:49.331274+00:00 0:00:03.212530 20994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T05:10:43.876176+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T04:00:00+00:00 PythonOperator 2021-04-25T05:10:30.676547+00:00 2021-04-25T05:10:33.730247+00:00 0:00:03.053700 20993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T05:10:28.144635+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T04:00:00+00:00 TriggerDagRunOperator 2021-04-25T05:10:16.098175+00:00 2021-04-25T05:10:16.512062+00:00 0:00:00.413887 20992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T05:10:13.787139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T04:00:00+00:00 TriggerDagRunOperator 2021-04-25T05:10:16.011786+00:00 2021-04-25T05:10:16.564818+00:00 0:00:00.553032 20991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T05:10:13.787106+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T04:05:00+00:00 EmrJobFlowSensor 2021-04-25T05:05:53.645022+00:00 2021-04-25T05:14:56.241084+00:00 0:09:02.596062 20990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T05:05:51.457109+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T05:05:33.687289+00:00 2021-04-25T05:05:35.325274+00:00 0:00:01.637985 20989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T05:05:31.383314+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T04:05:00+00:00 PythonOperator 2021-04-25T05:05:09.878572+00:00 2021-04-25T05:05:12.877289+00:00 0:00:02.998717 20988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T05:05:07.370754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T04:00:00+00:00 EmrJobFlowSensor 2021-04-25T05:00:54.934683+00:00 2021-04-25T05:09:57.663958+00:00 0:09:02.729275 20987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T05:00:52.618735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T05:00:32.825252+00:00 2021-04-25T05:00:34.475035+00:00 0:00:01.649783 20986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T05:00:30.585697+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T04:00:00+00:00 PythonOperator 2021-04-25T05:00:11.216252+00:00 2021-04-25T05:00:14.206226+00:00 0:00:02.989974 20985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T05:00:08.564329+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T03:00:00+00:00 EmrJobFlowSensor 2021-04-25T04:12:20.574460+00:00 2021-04-25T04:22:23.400924+00:00 0:10:02.826464 20983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T04:12:18.249376+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T03:00:00+00:00 EmrJobFlowSensor 2021-04-25T04:12:12.510140+00:00 2021-04-25T04:22:15.326589+00:00 0:10:02.816449 20982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T04:12:10.152804+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T04:12:01.094521+00:00 2021-04-25T04:12:02.885513+00:00 0:00:01.790992 20981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T04:11:58.245977+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T04:11:52.305740+00:00 2021-04-25T04:11:54.116164+00:00 0:00:01.810424 20980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T04:11:50.101866+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T03:00:00+00:00 PythonOperator 2021-04-25T04:11:38.793975+00:00 2021-04-25T04:11:42.002790+00:00 0:00:03.208815 20979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T04:11:36.088089+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T03:00:00+00:00 PythonOperator 2021-04-25T04:11:30.423919+00:00 2021-04-25T04:11:33.431906+00:00 0:00:03.007987 20978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T04:11:28.151684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T03:00:00+00:00 TriggerDagRunOperator 2021-04-25T04:11:16.826999+00:00 2021-04-25T04:11:17.245192+00:00 0:00:00.418193 20977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T04:11:14.026949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T03:00:00+00:00 TriggerDagRunOperator 2021-04-25T04:11:16.515353+00:00 2021-04-25T04:11:17.054982+00:00 0:00:00.539629 20976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T04:11:14.026999+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T03:05:00+00:00 EmrJobFlowSensor 2021-04-25T04:05:53.732995+00:00 2021-04-25T04:14:56.277122+00:00 0:09:02.544127 20975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T04:05:51.465461+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T04:05:33.756052+00:00 2021-04-25T04:05:35.407932+00:00 0:00:01.651880 20974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T04:05:31.451126+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T03:05:00+00:00 PythonOperator 2021-04-25T04:05:09.719616+00:00 2021-04-25T04:05:12.648320+00:00 0:00:02.928704 20973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T04:05:07.453560+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T03:00:00+00:00 EmrJobFlowSensor 2021-04-25T04:01:05.337674+00:00 2021-04-25T04:11:08.324493+00:00 0:10:02.986819 20972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T04:01:02.984613+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T04:00:43.279081+00:00 2021-04-25T04:00:44.959048+00:00 0:00:01.679967 20971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T04:00:40.922001+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T03:00:00+00:00 PythonOperator 2021-04-25T04:00:21.362454+00:00 2021-04-25T04:00:24.385733+00:00 0:00:03.023279 20970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T04:00:18.903919+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T02:00:00+00:00 EmrJobFlowSensor 2021-04-25T03:11:29.514937+00:00 2021-04-25T03:20:32.161801+00:00 0:09:02.646864 20968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T03:11:27.167079+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T02:00:00+00:00 EmrJobFlowSensor 2021-04-25T03:11:25.310009+00:00 2021-04-25T03:20:27.912654+00:00 0:09:02.602645 20967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T03:11:23.101715+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T03:11:07.471464+00:00 2021-04-25T03:11:09.376456+00:00 0:00:01.904992 20966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T03:11:05.095603+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T03:11:05.511337+00:00 2021-04-25T03:11:07.277475+00:00 0:00:01.766138 20965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T03:11:03.153956+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T02:00:00+00:00 PythonOperator 2021-04-25T03:10:47.363075+00:00 2021-04-25T03:10:50.547924+00:00 0:00:03.184849 20964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T03:10:45.062045+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T02:00:00+00:00 PythonOperator 2021-04-25T03:10:43.205467+00:00 2021-04-25T03:10:46.291011+00:00 0:00:03.085544 20963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T03:10:40.982330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T02:00:00+00:00 TriggerDagRunOperator 2021-04-25T03:10:21.254194+00:00 2021-04-25T03:10:21.821619+00:00 0:00:00.567425 20962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T03:10:18.924849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T02:00:00+00:00 TriggerDagRunOperator 2021-04-25T03:10:21.159992+00:00 2021-04-25T03:10:21.616440+00:00 0:00:00.456448 20961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T03:10:18.924817+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T02:05:00+00:00 EmrJobFlowSensor 2021-04-25T03:06:08.846276+00:00 2021-04-25T03:15:11.572762+00:00 0:09:02.726486 20960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T03:06:06.444042+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T03:05:40.664797+00:00 2021-04-25T03:05:42.485556+00:00 0:00:01.820759 20959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T03:05:38.421823+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T02:05:00+00:00 PythonOperator 2021-04-25T03:05:12.745179+00:00 2021-04-25T03:05:15.711191+00:00 0:00:02.966012 20958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T03:05:10.394089+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T02:00:00+00:00 EmrJobFlowSensor 2021-04-25T03:01:04.509136+00:00 2021-04-25T03:10:07.373723+00:00 0:09:02.864587 20957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T03:01:02.066928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T03:00:42.421950+00:00 2021-04-25T03:00:44.160873+00:00 0:00:01.738923 20956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T03:00:40.061516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T02:00:00+00:00 PythonOperator 2021-04-25T03:00:22.316952+00:00 2021-04-25T03:00:25.292960+00:00 0:00:02.976008 20955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T03:00:19.974335+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T01:00:00+00:00 EmrJobFlowSensor 2021-04-25T02:11:23.518993+00:00 2021-04-25T02:21:26.544562+00:00 0:10:03.025569 20953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T02:11:21.253129+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T01:00:00+00:00 EmrJobFlowSensor 2021-04-25T02:11:11.430832+00:00 2021-04-25T02:19:13.988851+00:00 0:08:02.558019 20952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T02:11:09.249075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T02:10:55.618815+00:00 2021-04-25T02:10:57.314663+00:00 0:00:01.695848 20951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T02:10:53.354710+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T02:10:41.957652+00:00 2021-04-25T02:10:43.661454+00:00 0:00:01.703802 20950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T02:10:39.266861+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T01:00:00+00:00 PythonOperator 2021-04-25T02:10:33.429053+00:00 2021-04-25T02:10:36.564829+00:00 0:00:03.135776 20949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T02:10:31.210082+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T01:00:00+00:00 PythonOperator 2021-04-25T02:10:19.947504+00:00 2021-04-25T02:10:22.907000+00:00 0:00:02.959496 20948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T02:10:17.199959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T01:00:00+00:00 TriggerDagRunOperator 2021-04-25T02:10:11.411382+00:00 2021-04-25T02:10:12.043497+00:00 0:00:00.632115 20947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T02:10:09.190693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T01:00:00+00:00 TriggerDagRunOperator 2021-04-25T02:10:11.386920+00:00 2021-04-25T02:10:11.872849+00:00 0:00:00.485929 20946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T02:10:09.190728+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T01:05:00+00:00 EmrJobFlowSensor 2021-04-25T02:06:00.872724+00:00 2021-04-25T02:14:03.278829+00:00 0:08:02.406105 20945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T02:05:58.716096+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T02:05:39.057777+00:00 2021-04-25T02:05:40.757730+00:00 0:00:01.699953 20944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T02:05:36.687791+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T01:05:00+00:00 PythonOperator 2021-04-25T02:05:16.758788+00:00 2021-04-25T02:05:19.696174+00:00 0:00:02.937386 20943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T02:05:14.621494+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T01:00:00+00:00 EmrJobFlowSensor 2021-04-25T02:01:02.618543+00:00 2021-04-25T02:10:05.424025+00:00 0:09:02.805482 20942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T02:01:00.290164+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T02:00:42.412106+00:00 2021-04-25T02:00:44.098405+00:00 0:00:01.686299 20941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T02:00:40.244891+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T01:00:00+00:00 PythonOperator 2021-04-25T02:00:20.547114+00:00 2021-04-25T02:00:23.551176+00:00 0:00:03.004062 20940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T02:00:18.226888+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T00:00:00+00:00 EmrJobFlowSensor 2021-04-25T01:11:11.536102+00:00 2021-04-25T01:20:14.163849+00:00 0:09:02.627747 20938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T01:11:09.248711+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T00:00:00+00:00 EmrJobFlowSensor 2021-04-25T01:11:03.574806+00:00 2021-04-25T01:20:06.226755+00:00 0:09:02.651949 20937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T01:11:01.263326+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T01:10:51.363519+00:00 2021-04-25T01:10:53.069894+00:00 0:00:01.706375 20936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T01:10:49.188542+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T01:10:41.476171+00:00 2021-04-25T01:10:43.255027+00:00 0:00:01.778856 20935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T01:10:39.180771+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T00:00:00+00:00 PythonOperator 2021-04-25T01:10:29.699032+00:00 2021-04-25T01:10:32.998323+00:00 0:00:03.299291 20934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T01:10:27.180194+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T00:00:00+00:00 PythonOperator 2021-04-25T01:10:19.721289+00:00 2021-04-25T01:10:22.728084+00:00 0:00:03.006795 20933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T01:10:17.161764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T00:00:00+00:00 TriggerDagRunOperator 2021-04-25T01:10:13.468433+00:00 2021-04-25T01:10:14.000856+00:00 0:00:00.532423 20932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T01:10:11.096268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T00:00:00+00:00 TriggerDagRunOperator 2021-04-25T01:10:13.279900+00:00 2021-04-25T01:10:13.708520+00:00 0:00:00.428620 20931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T01:10:11.096301+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T00:05:00+00:00 EmrJobFlowSensor 2021-04-25T01:05:58.672236+00:00 2021-04-25T01:15:01.163517+00:00 0:09:02.491281 20930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T01:05:56.534505+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T01:05:36.771626+00:00 2021-04-25T01:05:38.399023+00:00 0:00:01.627397 20929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T01:05:34.514466+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T00:05:00+00:00 PythonOperator 2021-04-25T01:05:16.661792+00:00 2021-04-25T01:05:19.583064+00:00 0:00:02.921272 20928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T01:05:14.495240+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T00:00:00+00:00 EmrJobFlowSensor 2021-04-25T01:00:50.179499+00:00 2021-04-25T01:09:52.739382+00:00 0:09:02.559883 20927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T01:00:47.937307+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T01:00:28.128537+00:00 2021-04-25T01:00:29.895852+00:00 0:00:01.767315 20926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T01:00:25.908435+00:00 2 default_pool