from .arvdocker import arv_docker_get_image
from .pathmapper import ArvPathMapper
+from ._version import __version__
logger = logging.getLogger('arvados.cwl-runner')
job_order.get("id", "#"),
False)
- adjustDirObjs(job_order, trim_listing)
-
if "id" in job_order:
del job_order["id"]
return workflowmapper
+def arvados_jobs_image(arvrunner):
+ img = "arvados/jobs:"+__version__
+ try:
+ arv_docker_get_image(arvrunner.api, {"dockerPull": img}, True, arvrunner.project_uuid)
+ except Exception as e:
+ raise Exception("Docker image %s is not available\n%s" % (img, e) )
+ return img
class Runner(object):
def __init__(self, runner, tool, job_order, enable_reuse, output_name):
def arvados_job_spec(self, *args, **kwargs):
self.name = os.path.basename(self.tool.tool["id"])
- return upload_instance(self.arvrunner, self.name, self.tool, self.job_order)
+ workflowmapper = upload_instance(self.arvrunner, self.name, self.tool, self.job_order)
+ adjustDirObjs(self.job_order, trim_listing)
+ return workflowmapper
def done(self, record):
if record["state"] == "Complete":