refactor(api): Rename `continuation_node_id` to `next_node_id`

in `WorkflowSuspension`.

This aligns with the naming convension of the codebase.
pull/22621/head
QuantumGhost 10 months ago
parent b804f7179f
commit ff7f1c1f17

@ -19,7 +19,7 @@ class WorkflowSuspension(BaseModel):
workflow_id: str workflow_id: str
continuation_node_id: str next_node_id: str
state: str state: str

@ -28,7 +28,7 @@ def upgrade():
sa.Column('workflow_id', models.types.StringUUID(), nullable=False), sa.Column('workflow_id', models.types.StringUUID(), nullable=False),
sa.Column('workflow_run_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('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_version', sa.String(length=20), nullable=False),
sa.Column('state', sa.Text(), nullable=False), sa.Column('state', sa.Text(), nullable=False),
sa.Column('inputs', sa.Text(), nullable=True), sa.Column('inputs', sa.Text(), nullable=True),

@ -1340,12 +1340,12 @@ class WorkflowSuspension(Base):
default=sa.null, 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 # Although this information is embedded within the `state` field, it is extracted
# into a separate field to facilitate debugging and data analysis. # into a separate field to facilitate debugging and data analysis.
continuation_node_id: Mapped[str] = mapped_column( next_node_id: Mapped[str] = mapped_column(
sa.String(length=255), __name_pos=sa.String(length=255),
nullable=False, nullable=False,
) )

Loading…
Cancel
Save