Skip to content
Snippets Groups Projects
Commit c9cd9480 authored by John Chilton's avatar John Chilton
Browse files

Better exception if container not specified for kubernetes staging.

parent 7bfed5d8
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 2 additions and 0 deletions
pulsar/client/client.py
+ 2
− 0
View file @ c9cd9480
...@@ -396,6 +396,8 @@ class MessageCoexecutionPodJobClient(BaseMessageJobClient): ...@@ -396,6 +396,8 @@ class MessageCoexecutionPodJobClient(BaseMessageJobClient):
{"mountPath": "/pulsar_staging", "name": "staging-directory"}, {"mountPath": "/pulsar_staging", "name": "staging-directory"},
] ]
tool_container_image = container # TODO: this isn't right at all... tool_container_image = container # TODO: this isn't right at all...
if not container:
raise Exception("Must declare a container for kubernetes job execution.")
pulsar_container_dict = { pulsar_container_dict = {
"name": "pulsar-container", "name": "pulsar-container",
"image": pulsar_container_image, "image": pulsar_container_image,
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment