File tree Expand file tree Collapse file tree
wfcommons/wfbench/translator Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -298,7 +298,8 @@ def _generate_workflow_code(self, sorted_tasks: List[Task]) -> str:
298298 code += "workflow {\n "
299299 code += "\t results = bootstrap()\n "
300300 for task in sorted_tasks :
301- code += f"\t results = function_{ task .task_id } (results)\n "
301+ function_name = task .task_id .replace ("." , "_" )
302+ code += f"\t results = function_{ function_name } (results)\n "
302303 code += "}\n "
303304 return code
304305
@@ -312,7 +313,8 @@ def _generate_task_function(self, task: Task) -> str:
312313 :rtype: str
313314 """
314315 code = f"// Function to call task { task .task_id } \n "
315- code += f"def function_{ task .task_id } (Map inputs) " + "{\n "
316+ function_name = task .task_id .replace ("." , "_" )
317+ code += f"def function_{ function_name } (Map inputs) " + "{\n "
316318
317319 if self ._find_parents (task .task_id ):
318320 # Input channel mixing and then call
You can’t perform that action at this time.
0 commit comments