clean typos words. (#24667)
Signed-off-by: zhanluxianshen <zhanluxianshen@163.com>
This commit is contained in:
@@ -118,7 +118,7 @@ class QueueIterationNextEvent(AppQueueEvent):
|
|||||||
parent_parallel_start_node_id: Optional[str] = None
|
parent_parallel_start_node_id: Optional[str] = None
|
||||||
"""parent parallel start node id if node is in parallel"""
|
"""parent parallel start node id if node is in parallel"""
|
||||||
parallel_mode_run_id: Optional[str] = None
|
parallel_mode_run_id: Optional[str] = None
|
||||||
"""iteratoin run in parallel mode run id"""
|
"""iteration run in parallel mode run id"""
|
||||||
node_run_index: int
|
node_run_index: int
|
||||||
output: Optional[Any] = None # output for the current iteration
|
output: Optional[Any] = None # output for the current iteration
|
||||||
duration: Optional[float] = None
|
duration: Optional[float] = None
|
||||||
@@ -201,7 +201,7 @@ class QueueLoopNextEvent(AppQueueEvent):
|
|||||||
parent_parallel_start_node_id: Optional[str] = None
|
parent_parallel_start_node_id: Optional[str] = None
|
||||||
"""parent parallel start node id if node is in parallel"""
|
"""parent parallel start node id if node is in parallel"""
|
||||||
parallel_mode_run_id: Optional[str] = None
|
parallel_mode_run_id: Optional[str] = None
|
||||||
"""iteratoin run in parallel mode run id"""
|
"""iteration run in parallel mode run id"""
|
||||||
node_run_index: int
|
node_run_index: int
|
||||||
output: Optional[Any] = None # output for the current loop
|
output: Optional[Any] = None # output for the current loop
|
||||||
duration: Optional[float] = None
|
duration: Optional[float] = None
|
||||||
@@ -382,7 +382,7 @@ class QueueNodeStartedEvent(AppQueueEvent):
|
|||||||
"""loop id if node is in loop"""
|
"""loop id if node is in loop"""
|
||||||
start_at: datetime
|
start_at: datetime
|
||||||
parallel_mode_run_id: Optional[str] = None
|
parallel_mode_run_id: Optional[str] = None
|
||||||
"""iteratoin run in parallel mode run id"""
|
"""iteration run in parallel mode run id"""
|
||||||
agent_strategy: Optional[AgentNodeStrategyInit] = None
|
agent_strategy: Optional[AgentNodeStrategyInit] = None
|
||||||
|
|
||||||
|
|
||||||
|
@@ -1,8 +1,8 @@
|
|||||||
class TaskPipilineError(ValueError):
|
class TaskPipelineError(ValueError):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
class RecordNotFoundError(TaskPipilineError):
|
class RecordNotFoundError(TaskPipelineError):
|
||||||
def __init__(self, record_name: str, record_id: str):
|
def __init__(self, record_name: str, record_id: str):
|
||||||
super().__init__(f"{record_name} with id {record_id} not found")
|
super().__init__(f"{record_name} with id {record_id} not found")
|
||||||
|
|
||||||
|
@@ -166,7 +166,7 @@ class BaseIterationEvent(GraphEngineEvent):
|
|||||||
parent_parallel_start_node_id: Optional[str] = None
|
parent_parallel_start_node_id: Optional[str] = None
|
||||||
"""parent parallel start node id if node is in parallel"""
|
"""parent parallel start node id if node is in parallel"""
|
||||||
parallel_mode_run_id: Optional[str] = None
|
parallel_mode_run_id: Optional[str] = None
|
||||||
"""iteratoin run in parallel mode run id"""
|
"""iteration run in parallel mode run id"""
|
||||||
|
|
||||||
|
|
||||||
class IterationRunStartedEvent(BaseIterationEvent):
|
class IterationRunStartedEvent(BaseIterationEvent):
|
||||||
|
Reference in New Issue
Block a user