if docker_req and kwargs.get("use_container") is not False:
runtime_constraints["docker_image"] = arv_docker_get_image(self.arvrunner.api, docker_req, pull_image)
+ resources = self.builder.resources
+ if resources is not None:
+ if "coresMin" in resources.keys():
+ try:
+ runtime_constraints["min_cores_per_node"] = int(resources["coresMin"])
+ except:
+ runtime_constraints["min_cores_per_node"] = None
+ if "ramMin" in resources.keys():
+ try:
+ runtime_constraints["min_ram_mb_per_node"] = int(resources["ramMin"])
+ except:
+ runtime_constraints["min_ram_mb_per_node"] = None
+
try:
response = self.arvrunner.api.jobs().create(body={
"script": "crunchrunner",
break
self.builder.outdir = outdir
+ self.builder.pathmapper.keepdir = keepdir
outputs = self.collect_outputs("keep:" + record["output"])
except Exception as e:
logger.exception("Got exception while collecting job outputs:")
arvrunner.add_uploaded(src, (ab, st.fn))
self._pathmap[src] = (ab, st.fn)
+ self.keepdir = None
+
+ def reversemap(self, target):
+ if target.startswith("keep:"):
+ return target
+ elif self.keepdir and target.startswith(self.keepdir):
+ return "keep:" + target[len(self.keepdir)+1:]
+ else:
+ return super(ArvPathMapper, self).reversemap(target)
class ArvadosCommandTool(cwltool.draft2tool.CommandLineTool):