diff --git a/api/core/app/entities/queue_entities.py b/api/core/app/entities/queue_entities.py index d663dbb17..db0297c35 100644 --- a/api/core/app/entities/queue_entities.py +++ b/api/core/app/entities/queue_entities.py @@ -118,7 +118,7 @@ class QueueIterationNextEvent(AppQueueEvent): parent_parallel_start_node_id: Optional[str] = None """parent parallel start node id if node is in parallel""" 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 output: Optional[Any] = None # output for the current iteration duration: Optional[float] = None @@ -201,7 +201,7 @@ class QueueLoopNextEvent(AppQueueEvent): parent_parallel_start_node_id: Optional[str] = None """parent parallel start node id if node is in parallel""" 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 output: Optional[Any] = None # output for the current loop duration: Optional[float] = None @@ -382,7 +382,7 @@ class QueueNodeStartedEvent(AppQueueEvent): """loop id if node is in loop""" start_at: datetime 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 diff --git a/api/core/app/task_pipeline/exc.py b/api/core/app/task_pipeline/exc.py index df6277697..d88caa987 100644 --- a/api/core/app/task_pipeline/exc.py +++ b/api/core/app/task_pipeline/exc.py @@ -1,8 +1,8 @@ -class TaskPipilineError(ValueError): +class TaskPipelineError(ValueError): pass -class RecordNotFoundError(TaskPipilineError): +class RecordNotFoundError(TaskPipelineError): def __init__(self, record_name: str, record_id: str): super().__init__(f"{record_name} with id {record_id} not found") diff --git a/api/core/workflow/graph_engine/entities/event.py b/api/core/workflow/graph_engine/entities/event.py index e57e9e4d6..6e72f8b15 100644 --- a/api/core/workflow/graph_engine/entities/event.py +++ b/api/core/workflow/graph_engine/entities/event.py @@ -166,7 +166,7 @@ class BaseIterationEvent(GraphEngineEvent): parent_parallel_start_node_id: Optional[str] = None """parent parallel start node id if node is in parallel""" parallel_mode_run_id: Optional[str] = None - """iteratoin run in parallel mode run id""" + """iteration run in parallel mode run id""" class IterationRunStartedEvent(BaseIterationEvent):