Starts monitor thread and worker threads.

galaxyproject · Apr 20, 2016 · 43ff13d · 43ff13d
1 parent 0c08228
commit 43ff13d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/galaxy/jobs/runners/kubernetes.py b/lib/galaxy/jobs/runners/kubernetes.py
@@ -58,9 +58,9 @@ def __init__(self, app, nworkers, **kwargs):
         self._pykube_api = HTTPClient(KubeConfig.from_file(self.runner_params["k8s_config_path"]))
         self._galaxy_vol_name = "pvc_galaxy"
 
-        # TODO do we need these?
-        # self._init_monitor_thread()
-        # self._init_worker_threads()
+
+        self._init_monitor_thread()
+        self._init_worker_threads()
 
     def queue_job(self, job_wrapper):
         """Create job script and submit it to Kubernetes cluster"""