swift/t with flowcept

Author: rafaelfsilva

wfcommons/wfbench/translator/swift_t.py

@@ -100,9 +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);"
+        # flowcept end
+        if self.workflow.workflow_id:
+            self.script += f"string fc_stop = sprintf(flowcept_stop, dep_{self.cmd_counter - 1});\n" \
+                            "python_persist(fc_stop);"
 
         run_workflow_code = self._merge_codelines("templates/swift_t_templates/workflow.swift", self.script)
 

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

@@ -17,6 +17,13 @@ except Exception:
     traceback.print_exc()
 """;
 
+global const string flowcept_stop = 
+"""
+import time
+dep = %i
+time.sleep(240)
+""";
+
 string command = 
 """
 import logging