Skip to content

Commit

Permalink
Removes url_to_destination, as this is only for legacy destinations (…
Browse files Browse the repository at this point in the history
…which I guess our's isn't, wouldn't have any URL to transform either)
  • Loading branch information
pcm32 committed Apr 19, 2016
1 parent e50ed67 commit daf8ccb
Showing 1 changed file with 0 additions and 13 deletions.
13 changes: 0 additions & 13 deletions lib/galaxy/jobs/runners/kubernetes.py
Original file line number Diff line number Diff line change
Expand Up @@ -51,19 +51,6 @@ def __init__(self, app, nworkers):
# self._init_monitor_thread()
# self._init_worker_threads()

def url_to_destination(self, url):
# TODO apparently needs to be implemented for pykube-k8s
params = {}
shell_params, job_params = url.split('/')[2:4]
# split 'foo=bar&baz=quux' into { 'foo' : 'bar', 'baz' : 'quux' }
shell_params = dict([('shell_' + k, v) for k, v in [kv.split('=', 1) for kv in shell_params.split('&')]])
job_params = dict([('job_' + k, v) for k, v in [kv.split('=', 1) for kv in job_params.split('&')]])
params.update(shell_params)
params.update(job_params)
log.debug("Converted URL '%s' to destination runner=cli, params=%s" % (url, params))
# Create a dynamic JobDestination
return JobDestination(runner='cli', params=params)

def queue_job(self, job_wrapper):
"""Create job script and submit it to Kubernetes cluster"""
# prepare the job
Expand Down

0 comments on commit daf8ccb

Please sign in to comment.