diff --git a/api/core/workflow/entities/workflow_suspension.py b/api/core/workflow/entities/workflow_suspension.py index 9304e6cadd..61da6a6a8e 100644 --- a/api/core/workflow/entities/workflow_suspension.py +++ b/api/core/workflow/entities/workflow_suspension.py @@ -19,7 +19,7 @@ class WorkflowSuspension(BaseModel): workflow_id: str - continuation_node_id: str + next_node_id: str state: str diff --git a/api/migrations/versions/2025_07_17_2020-1091956b9ee0_add_workflowsuspension_model_add_.py b/api/migrations/versions/2025_07_17_2020-1091956b9ee0_add_workflowsuspension_model_add_.py index 49182e6474..b5945b4706 100644 --- a/api/migrations/versions/2025_07_17_2020-1091956b9ee0_add_workflowsuspension_model_add_.py +++ b/api/migrations/versions/2025_07_17_2020-1091956b9ee0_add_workflowsuspension_model_add_.py @@ -28,7 +28,7 @@ def upgrade(): sa.Column('workflow_id', models.types.StringUUID(), nullable=False), sa.Column('workflow_run_id', models.types.StringUUID(), nullable=False), sa.Column('resumed_at', sa.DateTime(), nullable=True), - sa.Column('continuation_node_id', sa.String(length=255), nullable=False), + sa.Column('next_node_id', sa.String(length=255), nullable=False), sa.Column('state_version', sa.String(length=20), nullable=False), sa.Column('state', sa.Text(), nullable=False), sa.Column('inputs', sa.Text(), nullable=True), diff --git a/api/models/workflow.py b/api/models/workflow.py index 8c153af741..3bdb6dbde6 100644 --- a/api/models/workflow.py +++ b/api/models/workflow.py @@ -1340,12 +1340,12 @@ class WorkflowSuspension(Base): default=sa.null, ) - # `continuation_node_id` specifies the next node to execute when the workflow resumes. + # `next_node_id` specifies the next node to execute when the workflow resumes. # # Although this information is embedded within the `state` field, it is extracted # into a separate field to facilitate debugging and data analysis. - continuation_node_id: Mapped[str] = mapped_column( - sa.String(length=255), + next_node_id: Mapped[str] = mapped_column( + __name_pos=sa.String(length=255), nullable=False, )