Skip to content

Commit 9b2273c

Browse files
committed
adding flowcept and IO for swift/t
1 parent be422b6 commit 9b2273c

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

wfcommons/wfbench/translator/swift_t.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -200,15 +200,15 @@ def _add_tasks(self, category: str) -> None:
200200
num_tasks += 1
201201

202202
cats = " + ".join(f"{k}__out[{v - 1}]" for k, v in input_files_cat.items())
203-
in_str = ", ".join(f"{k}__{v}" for k, v in input_files_cat.items())
203+
in_str = ", ".join(f"{k}_{v - 1}_output.txt" for k, v in input_files_cat.items())
204204
if "ins[" in cats:
205205
cats = "0"
206206
in_str = ""
207207
self.script += f"int dep_{self.cmd_counter} = {cats};\n"
208208
args += f", dep_{self.cmd_counter}"
209209
if self.workflow.workflow_id:
210210
args += f", \"{self.workflow.workflow_id}\""
211-
self.script += f"string {category}_in = \"{in_str}\";\n"
211+
self.script += f"string {category}_in = \"{self.output_folder.absolute()}/data/{in_str}\";\n"
212212

213213
if num_tasks > 1:
214214
self.script += f"foreach i in [0:{num_tasks - 1}] {{\n" \

0 commit comments

Comments
 (0)