From f31a152508b3e39310631ad9fda846088ab9fec8 Mon Sep 17 00:00:00 2001
From: John Chilton <jmchilton@gmail.com>
Date: Mon, 6 May 2019 13:24:34 -0400
Subject: [PATCH] More coexecutor tweaks..
---
docker/coexecutor/Dockerfile | 4 +---
pulsar/client/client.py | 2 +-
2 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/docker/coexecutor/Dockerfile b/docker/coexecutor/Dockerfile
index 058b8008..7d55e69a 100644
--- a/docker/coexecutor/Dockerfile
+++ b/docker/coexecutor/Dockerfile
@@ -15,10 +15,8 @@ RUN apt-get update \
&& apt-get autoclean \
&& rm -rf /var/lib/apt/lists/* /var/log/dpkg.log
-RUN pip install -U pip && pip install wheel
+RUN pip install -U pip && pip install wheel kombu pykube poster
ADD pulsar_app-*.dev0-py2.py3-none-any.whl /pulsar_app-*.dev0-py2.py3-none-any.whl
RUN pip install /pulsar_app-*.dev0-py2.py3-none-any.whl
-
-RUN pip install kombu pykube poster
diff --git a/pulsar/client/client.py b/pulsar/client/client.py
index cfe7ccf2..e8e6184e 100644
--- a/pulsar/client/client.py
+++ b/pulsar/client/client.py
@@ -365,7 +365,7 @@ class MessageCoexecutionPodJobClient(BaseMessageJobClient):
def __init__(self, destination_params, job_id, client_manager):
super(MessageCoexecutionPodJobClient, self).__init__(destination_params, job_id, client_manager)
- self.pulsar_container_image = destination_params.get("pulsar_container_image", "galaxy/pulsar-pod-staging:0.1")
+ self.pulsar_container_image = destination_params.get("pulsar_container_image", "galaxy/pulsar-pod-staging:0.10.0")
self._default_pull_policy = pull_policy(destination_params)
def launch(self, command_line, dependencies_description=None, env=[], remote_staging=[], job_config=None, container=None, pulsar_app_config=None):
--
GitLab