From c9cd948001eab1c02db170c6d3d72e27c3c314d7 Mon Sep 17 00:00:00 2001
From: John Chilton <jmchilton@gmail.com>
Date: Fri, 3 May 2019 11:54:40 -0400
Subject: [PATCH] Better exception if container not specified for kubernetes
staging.
---
pulsar/client/client.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/pulsar/client/client.py b/pulsar/client/client.py
index 88fbb245..06603a4a 100644
--- a/pulsar/client/client.py
+++ b/pulsar/client/client.py
@@ -396,6 +396,8 @@ class MessageCoexecutionPodJobClient(BaseMessageJobClient):
{"mountPath": "/pulsar_staging", "name": "staging-directory"},
]
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 = {
"name": "pulsar-container",
"image": pulsar_container_image,
--
GitLab