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-06T16:00:00+00:00 EmrJobFlowSensor 2021-04-06T17:00:55.998810+00:00 2021-04-06T17:08:58.407249+00:00 0:08:02.408439 14269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T17:00:53.666362+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T17:00:36.046022+00:00 2021-04-06T17:00:37.869881+00:00 0:00:01.823859 14268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T17:00:33.661745+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T16:00:00+00:00 PythonOperator 2021-04-06T17:00:14.452079+00:00 2021-04-06T17:00:17.330953+00:00 0:00:02.878874 14267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T17:00:11.594035+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:11:23.923378+00:00 2021-04-06T16:20:26.635369+00:00 0:09:02.711991 14265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:11:21.633525+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:11:19.807389+00:00 2021-04-06T16:22:22.585867+00:00 0:11:02.778478 14264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:11:17.629138+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:11:00.690189+00:00 2021-04-06T16:11:02.442549+00:00 0:00:01.752360 14263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:10:57.609531+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:10:58.534729+00:00 2021-04-06T16:11:00.573971+00:00 0:00:02.039242 14262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:10:55.609137+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:10:38.256274+00:00 2021-04-06T16:10:41.046097+00:00 0:00:02.789823 14261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:10:35.596332+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:10:36.209211+00:00 2021-04-06T16:10:39.118048+00:00 0:00:02.908837 14260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:10:33.596643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T15:00:00+00:00 TriggerDagRunOperator 2021-04-06T16:10:18.430264+00:00 2021-04-06T16:10:18.961118+00:00 0:00:00.530854 14259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:10:15.543812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T15:00:00+00:00 TriggerDagRunOperator 2021-04-06T16:10:18.290923+00:00 2021-04-06T16:10:18.698856+00:00 0:00:00.407933 14258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:10:15.543776+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T15:05:00+00:00 EmrJobFlowSensor 2021-04-06T16:05:59.090882+00:00 2021-04-06T16:15:01.670311+00:00 0:09:02.579429 14257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T16:05:56.865719+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:05:37.043476+00:00 2021-04-06T16:05:38.671577+00:00 0:00:01.628101 14256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T16:05:34.853190+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T15:05:00+00:00 PythonOperator 2021-04-06T16:05:17.000403+00:00 2021-04-06T16:05:19.747579+00:00 0:00:02.747176 14255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:05:14.751800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T15:00:00+00:00 EmrJobFlowSensor 2021-04-06T16:00:54.820690+00:00 2021-04-06T16:09:57.524526+00:00 0:09:02.703836 14254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T16:00:52.375248+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T16:00:34.525273+00:00 2021-04-06T16:00:36.228858+00:00 0:00:01.703585 14253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T16:00:32.284725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T15:00:00+00:00 PythonOperator 2021-04-06T16:00:12.790476+00:00 2021-04-06T16:00:15.538256+00:00 0:00:02.747780 14252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T16:00:10.220164+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:12:16.702987+00:00 2021-04-06T15:21:19.400771+00:00 0:09:02.697784 14250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:12:14.451403+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:12:00.802148+00:00 2021-04-06T15:22:03.723409+00:00 0:10:02.921261 14249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:58.363768+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:11:56.637432+00:00 2021-04-06T15:11:58.333016+00:00 0:00:01.695584 14248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T15:11:54.351086+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:11:40.536019+00:00 2021-04-06T15:11:42.330713+00:00 0:00:01.794694 14247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T15:11:38.241960+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:11:34.514044+00:00 2021-04-06T15:11:37.217243+00:00 0:00:02.703199 14246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:11:32.237346+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:11:18.850361+00:00 2021-04-06T15:11:21.947405+00:00 0:00:03.097044 14245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:11:16.221693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T14:00:00+00:00 TriggerDagRunOperator 2021-04-06T15:11:12.741542+00:00 2021-04-06T15:11:13.169844+00:00 0:00:00.428302 14244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:10.216527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T14:00:00+00:00 TriggerDagRunOperator 2021-04-06T15:11:12.438966+00:00 2021-04-06T15:11:12.975269+00:00 0:00:00.536303 14243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:11:10.216563+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T14:05:00+00:00 EmrJobFlowSensor 2021-04-06T15:05:57.955832+00:00 2021-04-06T15:14:00.598378+00:00 0:08:02.642546 14242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T15:05:55.640079+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:05:35.857612+00:00 2021-04-06T15:05:37.529784+00:00 0:00:01.672172 14241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T15:05:33.622115+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T14:05:00+00:00 PythonOperator 2021-04-06T15:05:13.657102+00:00 2021-04-06T15:05:16.350798+00:00 0:00:02.693696 14240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:05:11.545690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T14:00:00+00:00 EmrJobFlowSensor 2021-04-06T15:01:03.403842+00:00 2021-04-06T15:11:06.241145+00:00 0:10:02.837303 14239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T15:01:01.209764+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T15:00:41.295407+00:00 2021-04-06T15:00:42.973155+00:00 0:00:01.677748 14238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T15:00:39.191796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T14:00:00+00:00 PythonOperator 2021-04-06T15:00:19.708132+00:00 2021-04-06T15:00:22.419543+00:00 0:00:02.711411 14237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T15:00:17.167560+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T13:00:00+00:00 EmrJobFlowSensor 2021-04-06T14:11:37.702023+00:00 2021-04-06T14:20:40.435679+00:00 0:09:02.733656 14235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:11:35.407838+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T13:00:00+00:00 EmrJobFlowSensor 2021-04-06T14:11:19.990950+00:00 2021-04-06T14:23:23.038103+00:00 0:12:03.047153 14234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:11:17.402139+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:11:07.566834+00:00 2021-04-06T14:11:09.253877+00:00 0:00:01.687043 14233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T14:11:05.380210+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:10:57.645076+00:00 2021-04-06T14:10:59.509995+00:00 0:00:01.864919 14232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T14:10:55.323019+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T13:00:00+00:00 PythonOperator 2021-04-06T14:10:47.708358+00:00 2021-04-06T14:10:50.390425+00:00 0:00:02.682067 14231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:10:45.321883+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T13:00:00+00:00 PythonOperator 2021-04-06T14:10:37.667718+00:00 2021-04-06T14:10:40.539356+00:00 0:00:02.871638 14230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:10:35.303939+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T13:00:00+00:00 TriggerDagRunOperator 2021-04-06T14:10:21.902817+00:00 2021-04-06T14:10:22.348604+00:00 0:00:00.445787 14229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:10:19.293274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T13:00:00+00:00 TriggerDagRunOperator 2021-04-06T14:10:21.516489+00:00 2021-04-06T14:10:22.081194+00:00 0:00:00.564705 14228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:10:19.293308+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T13:05:00+00:00 EmrJobFlowSensor 2021-04-06T14:05:50.780128+00:00 2021-04-06T14:14:53.292870+00:00 0:09:02.512742 14227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T14:05:48.600053+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:05:30.946557+00:00 2021-04-06T14:05:32.684429+00:00 0:00:01.737872 14226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T14:05:28.641330+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T13:05:00+00:00 PythonOperator 2021-04-06T14:05:08.901528+00:00 2021-04-06T14:05:11.580640+00:00 0:00:02.679112 14225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:05:06.570771+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T13:00:00+00:00 EmrJobFlowSensor 2021-04-06T14:01:04.476420+00:00 2021-04-06T14:10:07.215175+00:00 0:09:02.738755 14224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T14:01:02.182357+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T14:00:42.376226+00:00 2021-04-06T14:00:44.233770+00:00 0:00:01.857544 14223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T14:00:40.110709+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T13:00:00+00:00 PythonOperator 2021-04-06T14:00:20.629453+00:00 2021-04-06T14:00:23.373684+00:00 0:00:02.744231 14222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T14:00:18.152110+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T12:00:00+00:00 EmrJobFlowSensor 2021-04-06T13:11:56.658264+00:00 2021-04-06T13:23:59.847305+00:00 0:12:03.189041 14220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:11:54.293840+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T12:00:00+00:00 EmrJobFlowSensor 2021-04-06T13:11:52.553133+00:00 2021-04-06T13:20:55.264757+00:00 0:09:02.711624 14219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:11:50.254267+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:11:36.406616+00:00 2021-04-06T13:11:38.090325+00:00 0:00:01.683709 14218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T13:11:34.242379+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:11:30.777047+00:00 2021-04-06T13:11:32.552962+00:00 0:00:01.775915 14217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T13:11:28.257558+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T12:00:00+00:00 PythonOperator 2021-04-06T13:11:10.548814+00:00 2021-04-06T13:11:13.616251+00:00 0:00:03.067437 14216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:11:08.221384+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T12:00:00+00:00 PythonOperator 2021-04-06T13:11:02.642332+00:00 2021-04-06T13:11:05.402402+00:00 0:00:02.760070 14215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:11:00.220496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T12:00:00+00:00 TriggerDagRunOperator 2021-04-06T13:10:58.635597+00:00 2021-04-06T13:10:59.105489+00:00 0:00:00.469892 14214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:10:56.217300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T12:00:00+00:00 TriggerDagRunOperator 2021-04-06T13:10:58.606947+00:00 2021-04-06T13:10:59.153463+00:00 0:00:00.546516 14213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:10:56.217351+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T12:05:00+00:00 EmrJobFlowSensor 2021-04-06T13:06:05.981667+00:00 2021-04-06T13:15:08.664138+00:00 0:09:02.682471 14212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T13:06:03.751939+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:05:39.994546+00:00 2021-04-06T13:05:41.641734+00:00 0:00:01.647188 14211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T13:05:37.718258+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T12:05:00+00:00 PythonOperator 2021-04-06T13:05:18.077735+00:00 2021-04-06T13:05:20.827535+00:00 0:00:02.749800 14210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:05:15.756289+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T12:00:00+00:00 EmrJobFlowSensor 2021-04-06T13:00:51.353659+00:00 2021-04-06T13:10:54.116046+00:00 0:10:02.762387 14209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T13:00:49.187214+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T13:00:31.384569+00:00 2021-04-06T13:00:33.095708+00:00 0:00:01.711139 14208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T13:00:29.173474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T12:00:00+00:00 PythonOperator 2021-04-06T13:00:09.612227+00:00 2021-04-06T13:00:12.404216+00:00 0:00:02.791989 14207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T13:00:07.151790+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:11:14.345184+00:00 2021-04-06T12:20:17.101980+00:00 0:09:02.756796 14205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:11:11.945166+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:11:10.338321+00:00 2021-04-06T12:21:13.302120+00:00 0:10:02.963799 14204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:11:07.947877+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:10:52.421520+00:00 2021-04-06T12:10:54.210692+00:00 0:00:01.789172 14203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:10:49.985506+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:10:48.329957+00:00 2021-04-06T12:10:50.042893+00:00 0:00:01.712936 14202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:10:45.980568+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:10:30.631697+00:00 2021-04-06T12:10:33.552829+00:00 0:00:02.921132 14201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:10:28.048211+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:10:26.253732+00:00 2021-04-06T12:10:29.102298+00:00 0:00:02.848566 14200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:10:24.040798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T11:00:00+00:00 TriggerDagRunOperator 2021-04-06T12:10:12.246389+00:00 2021-04-06T12:10:12.695707+00:00 0:00:00.449318 14199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:10:09.946545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T11:00:00+00:00 TriggerDagRunOperator 2021-04-06T12:10:12.210780+00:00 2021-04-06T12:10:12.785913+00:00 0:00:00.575133 14198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:10:09.946512+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T11:05:00+00:00 EmrJobFlowSensor 2021-04-06T12:06:05.850151+00:00 2021-04-06T12:14:08.323691+00:00 0:08:02.473540 14197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T12:06:03.492453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:05:45.774009+00:00 2021-04-06T12:05:47.535312+00:00 0:00:01.761303 14196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T12:05:43.442326+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T11:05:00+00:00 PythonOperator 2021-04-06T12:05:23.754616+00:00 2021-04-06T12:05:26.524567+00:00 0:00:02.769951 14195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:05:21.423891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T11:00:00+00:00 EmrJobFlowSensor 2021-04-06T12:00:49.514231+00:00 2021-04-06T12:09:52.177904+00:00 0:09:02.663673 14194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T12:00:47.051977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T12:00:29.605969+00:00 2021-04-06T12:00:31.395737+00:00 0:00:01.789768 14193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T12:00:26.954757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T11:00:00+00:00 PythonOperator 2021-04-06T12:00:05.416338+00:00 2021-04-06T12:00:08.392730+00:00 0:00:02.976392 14192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T12:00:02.868626+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:11:35.309405+00:00 2021-04-06T11:20:37.937591+00:00 0:09:02.628186 14190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:11:32.887352+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:11:21.088376+00:00 2021-04-06T11:21:24.066081+00:00 0:10:02.977705 14189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:11:18.831926+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:11:13.067782+00:00 2021-04-06T11:11:14.866611+00:00 0:00:01.798829 14188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T11:11:10.825177+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:11:01.093203+00:00 2021-04-06T11:11:02.842642+00:00 0:00:01.749439 14187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T11:10:58.843930+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T10:00:00+00:00 PythonOperator 2021-04-06T11:10:53.105118+00:00 2021-04-06T11:10:55.924774+00:00 0:00:02.819656 14186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:10:50.808180+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T10:00:00+00:00 PythonOperator 2021-04-06T11:10:39.119897+00:00 2021-04-06T11:10:42.207514+00:00 0:00:03.087617 14185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:10:36.795568+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T10:00:00+00:00 TriggerDagRunOperator 2021-04-06T11:10:33.352416+00:00 2021-04-06T11:10:33.893248+00:00 0:00:00.540832 14184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:10:30.847204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T10:00:00+00:00 TriggerDagRunOperator 2021-04-06T11:10:33.146857+00:00 2021-04-06T11:10:33.598181+00:00 0:00:00.451324 14183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:10:30.847168+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T10:05:00+00:00 EmrJobFlowSensor 2021-04-06T11:06:01.035078+00:00 2021-04-06T11:14:03.498086+00:00 0:08:02.463008 14182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T11:05:58.648127+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:05:38.599401+00:00 2021-04-06T11:05:40.302845+00:00 0:00:01.703444 14181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T11:05:36.407466+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T10:05:00+00:00 PythonOperator 2021-04-06T11:05:16.780823+00:00 2021-04-06T11:05:19.428797+00:00 0:00:02.647974 14180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:05:14.444606+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T10:00:00+00:00 EmrJobFlowSensor 2021-04-06T11:01:06.163732+00:00 2021-04-06T11:10:08.881531+00:00 0:09:02.717799 14179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T11:01:03.934967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T11:00:44.354819+00:00 2021-04-06T11:00:46.106480+00:00 0:00:01.751661 14178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T11:00:41.910941+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T10:00:00+00:00 PythonOperator 2021-04-06T11:00:24.454400+00:00 2021-04-06T11:00:27.285951+00:00 0:00:02.831551 14177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T11:00:21.891723+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T09:00:00+00:00 EmrJobFlowSensor 2021-04-06T10:12:43.306854+00:00 2021-04-06T10:22:46.211789+00:00 0:10:02.904935 14175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:12:41.018169+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T09:00:00+00:00 EmrJobFlowSensor 2021-04-06T10:12:37.246536+00:00 2021-04-06T10:22:39.983493+00:00 0:10:02.736957 14174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:12:35.013659+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:12:21.294203+00:00 2021-04-06T10:12:23.114505+00:00 0:00:01.820302 14173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:12:19.000105+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:12:15.405363+00:00 2021-04-06T10:12:17.178110+00:00 0:00:01.772747 14172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:12:13.062617+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T09:00:00+00:00 PythonOperator 2021-04-06T10:11:59.396298+00:00 2021-04-06T10:12:02.225716+00:00 0:00:02.829418 14171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:11:56.964898+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T09:00:00+00:00 PythonOperator 2021-04-06T10:11:55.137764+00:00 2021-04-06T10:11:58.081131+00:00 0:00:02.943367 14170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:11:52.908637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T09:00:00+00:00 TriggerDagRunOperator 2021-04-06T10:11:35.246121+00:00 2021-04-06T10:11:35.767321+00:00 0:00:00.521200 14169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:11:32.889712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T09:00:00+00:00 TriggerDagRunOperator 2021-04-06T10:11:35.127424+00:00 2021-04-06T10:11:35.569186+00:00 0:00:00.441762 14168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:11:32.889745+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T09:05:00+00:00 EmrJobFlowSensor 2021-04-06T10:05:56.501317+00:00 2021-04-06T10:14:59.099472+00:00 0:09:02.598155 14167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:05:54.302435+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:05:34.542329+00:00 2021-04-06T10:05:36.272255+00:00 0:00:01.729926 14166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:05:32.288684+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T09:05:00+00:00 PythonOperator 2021-04-06T10:05:12.388740+00:00 2021-04-06T10:05:15.107529+00:00 0:00:02.718789 14165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:05:10.194690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T09:00:00+00:00 EmrJobFlowSensor 2021-04-06T10:01:06.339987+00:00 2021-04-06T10:11:09.270902+00:00 0:10:02.930915 14164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:01:03.785518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:00:44.278503+00:00 2021-04-06T10:00:46.063086+00:00 0:00:01.784583 14163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T10:00:41.718736+00:00 2 default_pool