feat(graph_engine): yield control to other threads before node run. (#17689)

Signed-off-by: -LAN- <laipz8200@outlook.com>
10 months ago · ec29bcf013
parent c9f18aae0f
commit ec29bcf013
1 changed files with 2 additions and 0 deletions
--- a/api/core/workflow/graph_engine/graph_engine.py
+++ b/api/core/workflow/graph_engine/graph_engine.py
@ -641,6 +641,8 @@ class GraphEngine:
            try:
                # run node
                retry_start_at = datetime.now(UTC).replace(tzinfo=None)
+                # yield control to other threads
+                time.sleep(0.001)
                generator = node_instance.run()
                for item in generator:
                    if isinstance(item, GraphEngineEvent):