diff --git a/docker/coexecutor/Dockerfile b/docker/coexecutor/Dockerfile index 058b8008f4ae010740dfeadcbc721e5fc0aec7ce..7d55e69a58bce36a1379b3d089153b4d15434ba7 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 cfe7ccf23e8fab24a268a109eb795b1e8f286984..e8e6184ee1f8b854bbb33b6209dcb0d2743de7de 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):