Skip to content

Commit 3b3c6c0

Browse files
committed
add default value for compute_checksum
1 parent 9eeff23 commit 3b3c6c0

File tree

2 files changed

+14
-8
lines changed

2 files changed

+14
-8
lines changed

cwltool/executors.py

+6-6
Original file line numberDiff line numberDiff line change
@@ -69,10 +69,10 @@ def execute(self, t, # type: Process
6969
self.run_jobs(t, job_order_object, logger, **kwargs)
7070

7171
if self.final_output and self.final_output[0] and finaloutdir:
72-
self.final_output[0] = relocateOutputs(self.final_output[0], finaloutdir,
73-
self.output_dirs, kwargs.get("move_outputs"),
74-
kwargs["make_fs_access"](""),
75-
kwargs["compute_checksum"])
72+
self.final_output[0] = relocateOutputs(
73+
self.final_output[0], finaloutdir, self.output_dirs,
74+
kwargs.get("move_outputs"), kwargs["make_fs_access"](""),
75+
kwargs.get("compute_checksum", True))
7676

7777
if kwargs.get("rm_tmpdir"):
7878
cleanIntermediate(self.output_dirs)
@@ -120,8 +120,8 @@ def __init__(self):
120120
self.exceptions = []
121121

122122
def run_job(self,
123-
job, # type: JobBase
124-
**kwargs # type: Any
123+
job, # type: JobBase
124+
**kwargs # type: Any
125125
):
126126
# type: (...) -> None
127127
def runner():

cwltool/process.py

+8-2
Original file line numberDiff line numberDiff line change
@@ -256,8 +256,14 @@ def collectFilesAndDirs(obj, out):
256256
collectFilesAndDirs(l, out)
257257

258258

259-
def relocateOutputs(outputObj, outdir, output_dirs, action, fs_access, compute_checksum):
260-
# type: (Union[Dict[Text, Any], List[Dict[Text, Any]]], Text, Set[Text], Text, StdFsAccess, bool) -> Union[Dict[Text, Any], List[Dict[Text, Any]]]
259+
def relocateOutputs(outputObj, # type: Union[Dict[Text, Any],List[Dict[Text, Any]]]
260+
outdir, # type: Text
261+
output_dirs, # type: Set[Text]
262+
action, # type: Text
263+
fs_access, # type: StdFsAccess
264+
compute_checksum=True # type: bool
265+
):
266+
# type: (...) -> Union[Dict[Text, Any], List[Dict[Text, Any]]]
261267
adjustDirObjs(outputObj, functools.partial(get_listing, fs_access, recursive=True))
262268

263269
if action not in ("move", "copy"):

0 commit comments

Comments
 (0)