Skip to content

Commit 2097c88

Browse files
author
Peter Amstutz
committed
Basic resources works.
1 parent 3984325 commit 2097c88

File tree

3 files changed

+8
-4
lines changed

3 files changed

+8
-4
lines changed

cwltool/main.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -299,6 +299,7 @@ def load_tool(argsworkflow, updateonly, strict, makeTool, debug, print_pre=False
299299
def main(args=None,
300300
executor=single_job_executor,
301301
makeTool=workflow.defaultMakeTool,
302+
selectResources=None,
302303
parser=None,
303304
stdin=sys.stdin,
304305
stdout=sys.stdout,
@@ -434,7 +435,8 @@ def main(args=None,
434435
tmpdir_prefix=args.tmpdir_prefix,
435436
rm_tmpdir=args.rm_tmpdir,
436437
makeTool=makeTool,
437-
move_outputs=args.move_outputs
438+
move_outputs=args.move_outputs,
439+
select_resources=selectResources
438440
)
439441
# This is the workflow output, it needs to be written
440442
stdout.write(json.dumps(out, indent=4))

cwltool/process.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,8 @@ def _init_job(self, joborder, input_basedir, **kwargs):
186186

187187
builder.bindings.extend(builder.bind_input(self.inputs_record_schema, builder.job))
188188

189-
builder.resources = self.evalResources(builder)
189+
builder.resources = {}
190+
builder.resources = self.evalResources(builder, kwargs)
190191

191192
return builder
192193

@@ -199,7 +200,7 @@ def evalResources(self, builder, kwargs):
199200
"ramMax": 1024,
200201
"tmpdirMin": 1024,
201202
"tmpdirMax": 1024,
202-
"outdirMin": 1024
203+
"outdirMin": 1024,
203204
"outdirMax": 1024
204205
}
205206
for a in ("cores", "ram", "tmpdir", "outdir"):
@@ -225,7 +226,7 @@ def evalResources(self, builder, kwargs):
225226
"cores": request["coresMin"],
226227
"ram": request["ramMin"],
227228
"tmpdir": request["tmpdirMin"],
228-
"outdir": request["outdirMiax"],
229+
"outdir": request["outdirMin"],
229230
}
230231

231232
def validate_hints(self, hints, strict):

node-expr-engine/cwlNodeEngine.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ process.stdin.on('end', function() {
3434

3535
fn += "var $job = " + JSON.stringify(j.job) + ";\n";
3636
fn += "var $self = " + JSON.stringify(j.context) + ";\n"
37+
fn += "var $resources = " + JSON.stringify(j.resources) + ";\n"
3738

3839
fn += "(function()" + exp + ")()";
3940

0 commit comments

Comments
 (0)