adding flowcept and IO for swift/t

Author: rafaelfsilva

wfcommons/wfbench/translator/swift_t.py

@@ -76,7 +76,8 @@ 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 = "string root_in_files[];\n"
+        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 += "string root_in_files[];\n"
 
         for task_name in self.root_task_names:
             task = self.tasks[task_name]
@@ -99,6 +100,10 @@ def translate(self, output_folder: pathlib.Path) -> None:
         for category in self.categories_list:
             self._add_tasks(category)
 
+        # flowcept stop
+        # if self.workflow.workflow_id:
+        #     self.script += "string fss = sprintf(flowcept_stop);\npython_persist(fss);"
+
         run_workflow_code = self._merge_codelines("templates/swift_t_templates/workflow.swift", self.script)
 
         # write benchmark files
@@ -206,7 +211,7 @@ def _add_tasks(self, category: str) -> None:
             in_str = ""
         self.script += f"int dep_{self.cmd_counter} = {cats};\n"
         args += f", dep_{self.cmd_counter}"
-        args += f", \"{self.workflow.workflow_id}\"" if self.workflow.workflow_id else ", \"\""
+        args += f", \"{self.workflow.workflow_id}\", fss" if self.workflow.workflow_id else ", \"\""
         self.script += f"string {category}_in = \"{self.output_folder.absolute()}/data/{in_str}\";\n"
 
         if num_tasks > 1:

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

@@ -4,6 +4,14 @@ import python;
 import string;
 import unix;
 
+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.start()
+"""
+
 string command = 
 """
 import logging
@@ -33,7 +41,7 @@ dep = %i
 workflow_id = "%s"
 
 if 'workflow_id':
-    loggin.info("Running with Flowcept.")
+    logging.info("Running with Flowcept.")
     from flowcept import Flowcept, FlowceptTask
     fc = Flowcept(workflow_id=args.workflow_id,
                 bundle_exec_id=args.workflow_id,