@@ -176,7 +176,7 @@ def run_workflow_nextflow(container, num_tasks, str_dirpath):
176176 exit_code , output = container .exec_run (f"nextflow run ./workflow.nf --pwd . "
177177 # f"-with-report execution_report.html "
178178 # f"-with-timeline execution_timeline.html "
179- # f"-with-trace trace_file "
179+ #f"-with-trace trace_file "
180180 # f"-plugins nf-prov -with-prov prov.json "
181181 # f"-with-dag dag_file.html"
182182 f"-c plugin.config " ,
@@ -331,19 +331,19 @@ class TestTranslators:
331331 @pytest .mark .parametrize (
332332 "backend" ,
333333 [
334- # "swiftt",
335- # "dask",
336- # "parsl",
334+ "swiftt" ,
335+ "dask" ,
336+ "parsl" ,
337337 "nextflow" ,
338- # "nextflow_subworkflow",
339- # "airflow",
340- # "bash",
341- # "taskvine",
342- # "makeflow",
343- # "snakemake",
344- # "cwl",
345- # "streamflow",
346- # "pegasus",
338+ "nextflow_subworkflow" ,
339+ "airflow" ,
340+ "bash" ,
341+ "taskvine" ,
342+ "makeflow" ,
343+ "snakemake" ,
344+ "cwl" ,
345+ "streamflow" ,
346+ "pegasus" ,
347347 ])
348348 @pytest .mark .unit
349349 # @pytest.mark.skip(reason="tmp")
@@ -402,12 +402,6 @@ def test_translator(self, backend) -> None:
402402 instruments_to_ignore = ["shell.cwl" ])
403403 elif backend == "snakemake" :
404404 parser = SnakemakeLogsParser (dirpath , snkmt_db = dirpath / "snkmt.sqlite" , rules_to_ignore = ["all_wfbench_tasks" ])
405- elif backend == "nextflow" :
406- # parser = NextflowLogsParser(execution_dir = dirpath)
407- parser = ROCrateLogsParser (dirpath ,
408- steps_to_ignore = ["main.cwl#compile_output_files" , "main.cwl#compile_log_files" ],
409- file_extensions_to_ignore = [".out" , ".err" ],
410- instruments_to_ignore = ["shell.cwl" ])
411405
412406
413407 if parser is not None :
0 commit comments