Merge branch 'wfbench_updated_args' of github.com:wfcommons/WfCommons…

… into wfbench_updated_args
wfcommons · Feb 16, 2025 · 7a86210 · 7a86210
2 parents b069d2f + 8c6fb82
commit 7a86210
Showing 1 changed file with 5 additions and 9 deletions.
diff --git a/wfcommons/wfbench/bench.py b/wfcommons/wfbench/bench.py
@@ -174,15 +174,11 @@ def create_benchmark_from_synthetic_workflow(
 
         # create data footprint
         for task in self.workflow.tasks.values():
-            outfiles = {file.file_id: file.size for file in task.output_files}
-            outfiles_str = str(outfiles).replace("{", "\"{") \
-                .replace("}", "}\"").replace("'", "\\\\\"").replace(": ", ":")
-            task.args.append(f"--out {outfiles_str}")
-
-            infiles = [f"\"{file.file_id}\"" for file in task.input_files]
-            infiles_str = str(infiles).replace("[", "\"[") \
-                .replace("]", "]\"").replace("'", "\\\\\"")
-            task.args.append(f"--input-files {infiles_str}")
+            output_files = {file.file_id: file.size for file in task.output_files}
+            task.args.append(f"--output-files {output_files}")
+
+            input_files = [file.file_id for file in task.input_files]
+            task.args.append(f"--input-files {input_files}")
 
         workflow_input_files: Dict[str, int] = self._rename_files_to_wfbench_format()