adding flowcept and IO for swift/t

Author: rafaelfsilva

wfcommons/wfbench/translator/swift_t.py

@@ -76,7 +76,7 @@ def translate(self, output_folder: pathlib.Path) -> None:
         in_count = 0
         self.output_folder = output_folder
         self.cpu_benchmark = output_folder.joinpath("./bin/cpu-benchmark").absolute()
-        self.script = f"string fs = sprintf(flowcept_start, \"{self.workflow.workflow_id}\");\nstring fss = python_persist(fs);\n\n" if self.workflow.workflow_id else ""
+        self.script = f"string fs = sprintf(flowcept_start, \"{self.workflow.workflow_id}\", \"{self.workflow.name}\");\nstring fss = python_persist(fs);\n\n" if self.workflow.workflow_id else ""
         self.script += "string root_in_files[];\n"
 
         for task_name in self.root_task_names:

wfcommons/wfbench/translator/templates/swift_t_templates/workflow.swift

@@ -8,7 +8,7 @@ global const string flowcept_start =
 """
 workflow_id = "%s"
 from flowcept.flowcept_api.flowcept_controller import Flowcept
-flowcept_agent = Flowcept(workflow_id=workflow_id, workflow_name="Blast-Benchmark", bundle_exec_id=workflow_id)
+flowcept_agent = Flowcept(workflow_id=workflow_id, workflow_name="%s", bundle_exec_id=workflow_id)
 flowcept_agent.start()
 """
 
@@ -43,11 +43,11 @@ workflow_id = "%s"
 if 'workflow_id':
     logging.info("Running with Flowcept.")
     from flowcept import Flowcept, FlowceptTask
-    fc = Flowcept(workflow_id=args.workflow_id,
-                bundle_exec_id=args.workflow_id,
+    fc = Flowcept(workflow_id=workflow_id,
+                bundle_exec_id=workflow_id,
                 start_persistence=False, save_workflow=False)
     fc.start()
-    fc_task = FlowceptTask(workflow_id=args.workflow_id, used={
+    fc_task = FlowceptTask(workflow_id=workflow_id, used={
       'workflow_id': workflow_id
     })