Skip to content

Commit ecac600

Browse files
committed
correct error
1 parent 82bf697 commit ecac600

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

cwltool/job.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ def run(self, dry_run=False, pull_image=True, rm_container=True,
193193

194194
rcode = sp.wait()
195195

196-
if not isinstance(stdin, int):
196+
if stdin != subprocess.PIPE:
197197
stdin.close()
198198

199199
if stdout is not sys.stderr:

cwltool/workflow.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -443,12 +443,8 @@ def __init__(self, toolpath_object, pos, **kwargs):
443443
runobj = None
444444
if isinstance(toolpath_object["run"], basestring):
445445
runobj, _ = schema_salad.schema.load_and_validate(
446-
kwargs["loader"],
447-
kwargs[
448-
"avsc_names"],
449-
toolpath_object[
450-
"run"],
451-
True)
446+
kwargs["loader"], kwargs["avsc_names"],
447+
toolpath_object["run"], True)
452448
else:
453449
runobj = toolpath_object["run"]
454450
self.embedded_tool = makeTool(runobj, **kwargs)

0 commit comments

Comments
 (0)