summaryrefslogtreecommitdiffstats
path: root/docker/dockerplugin/tasks.py
diff options
context:
space:
mode:
authorSchmalzried, Terry <ts862m@att.com>2018-02-23 16:30:27 -0500
committerSchmalzried, Terry <ts862m@att.com>2018-02-23 16:34:29 -0500
commit8b98cdb87ad811c8fb5f0611471140f810728850 (patch)
tree3c1cdfe3985d8401814786cc5a2c730e2b254031 /docker/dockerplugin/tasks.py
parentb7c2ad68730bb75c3e468f94269d27160c50f2e5 (diff)
fixed dcaegen2-363
Change-Id: I3446be1a8c1240659baaa2de924ac295e19d3de5 Signed-off-by: Schmalzried, Terry <ts862m@att.com> Issue-ID: DCAEGEN2-363 Signed-off-by: Schmalzried, Terry <ts862m@att.com>
Diffstat (limited to 'docker/dockerplugin/tasks.py')
-rw-r--r--docker/dockerplugin/tasks.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/docker/dockerplugin/tasks.py b/docker/dockerplugin/tasks.py
index ff2f2af..899f4ed 100644
--- a/docker/dockerplugin/tasks.py
+++ b/docker/dockerplugin/tasks.py
@@ -451,6 +451,8 @@ def _update_delivery_url(**kwargs):
for dr_sub in dr_subs:
scheme = dr_sub["scheme"] if "scheme" in dr_sub else DEFAULT_SCHEME
+ if "route" not in dr_sub:
+ raise NonRecoverableError("'route' key missing from data router subscriber")
path = dr_sub["route"]
dr_sub["delivery_url"] = "{scheme}://{host}/{path}".format(
scheme=scheme, host=subscriber_host, path=path)