completed workflow engine main logic

2026-04-28 14:38:06 +08:00 · 2024-03-06 17:43:42 +08:00
parent c7618fc377
commit 5963e7d1c5
10 changed files with 366 additions and 80 deletions
--- a/api/core/workflow/callbacks/base_workflow_callback.py
+++ b/api/core/workflow/callbacks/base_workflow_callback.py
@ -31,3 +31,11 @@ class BaseWorkflowCallback:
        Workflow node execute finished
        """
        raise NotImplementedError
+
+    @abstractmethod
+    def on_text_chunk(self, text: str) -> None:
+        """
+        Publish text chunk
+        """
+        raise NotImplementedError
+