Merge pull request #1055 from lyj715824/bugfix/superteam

Bugfix/superteam

Author: lyj715824

core/workflow/cache/event_registry.py

@@ -119,9 +119,10 @@ def init_event(cls, event: Event) -> None:
 
     @classmethod
     def lock_event(cls, event_id: str, sid: str, timeout: int = 180) -> None:
-        get_cache_service().set(
+        get_cache_service().set_ex(
             key=f"event_lock:{event_id}",
             value=f"locked_by_{sid}",
+            expire_time=timeout,
         )
 
     @classmethod

core/workflow/exception/errors/err_code.py

@@ -313,7 +313,6 @@ class CodeEnum(Enum):
     # 22200
 
     # Engine errors
-    ENG_PROTOCOL_VALIDATE_ERROR = (22300, "Workflow engine protocol validation failed")
     ENG_RUN_ERROR = (22301, "Workflow engine run failed")
     NODE_RUN_ERROR = (22302, "Node execution failed")
     NODE_RUN_TIMEOUT_ERROR = (22303, "Node execution timeout")