More coexecutor tweaks..

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

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):