Features: job status table with related DB model, migration files, job status tracking.

Added status wrapper to handle job status updates in the DB.

Added filtration using job_id to fetch job status responses.

fix: Generate job response from vertex builds history by job id.  (#11457)

* feat: reconstruct workflow execution response from vertex_build by job_id

* [autofix.ci] apply automated fixes

* fix: use correct attribute name 'id' instead of 'vertex_id' in VertexBuildTable

* Updated the GET endpoint to return WorkflowExecutionResponse

---------

Co-authored-by: Janardan S Kavia <[email protected]>
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>

Added /stop endpoint, task handling, job_id typing through job_service, job_status updates.

Author: dkaushik94

db_dump.json

@@ -0,0 +1,35 @@
+"""Changed job_id in JobTable to be UUID instead of string
+
+Revision ID: 00e5ef437a72
+Revises: dd3dd875cd97
+Create Date: 2026-01-25 21:32:44.515850
+
+Phase: MIGRATE
+"""
+
+from collections.abc import Sequence
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision: str = "00e5ef437a72"  # pragma: allowlist secret
+down_revision: str | None = "dd3dd875cd97"  # pragma: allowlist secret
+branch_labels: str | Sequence[str] | None = None
+depends_on: str | Sequence[str] | None = None
+
+
+def upgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table("job", schema=None) as batch_op:
+        batch_op.alter_column("job_id", existing_type=sa.VARCHAR(), type_=sa.Uuid(), existing_nullable=False)
+
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table("job", schema=None) as batch_op:
+        batch_op.alter_column("job_id", existing_type=sa.Uuid(), type_=sa.VARCHAR(), existing_nullable=False)
+
+    # ### end Alembic commands ###

src/backend/base/langflow/alembic/versions/00e5ef437a72_changed_job_id_in_jobtable_to_be_uuid_.py

@@ -0,0 +1,35 @@
+"""Changed job_id in vertex_build table to be UUID instead of str.
+
+Revision ID: dd3dd875cd97
+Revises: f7a564a956a8
+Create Date: 2026-01-25 20:23:02.795268
+
+Phase: MIGRATE
+"""
+
+from collections.abc import Sequence
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision: str = "dd3dd875cd97"
+down_revision: str | None = "f7a564a956a8"
+branch_labels: str | Sequence[str] | None = None
+depends_on: str | Sequence[str] | None = None
+
+
+def upgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table("vertex_build", schema=None) as batch_op:
+        batch_op.alter_column("job_id", existing_type=sa.VARCHAR(), type_=sa.Uuid(), existing_nullable=True)
+
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table("vertex_build", schema=None) as batch_op:
+        batch_op.alter_column("job_id", existing_type=sa.Uuid(), type_=sa.VARCHAR(), existing_nullable=True)
+
+    # ### end Alembic commands ###

src/backend/base/langflow/alembic/versions/dd3dd875cd97_changed_job_id_in_vertex_build_table_to_.py

@@ -0,0 +1,62 @@
+"""Add job_id to vertex_build, create job_id status model
+
+Revision ID: f7a564a956a8
+Revises: 182e5471b900
+Create Date: 2026-01-25 19:07:45.358554
+
+Phase: EXPAND
+"""
+
+from collections.abc import Sequence
+
+import sqlalchemy as sa
+import sqlmodel
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision: str = "f7a564a956a8"
+down_revision: str | None = "182e5471b900"  # pragma: allowlist secret
+branch_labels: str | Sequence[str] | None = None
+depends_on: str | Sequence[str] | None = None
+
+
+def upgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_table(
+        "job",
+        sa.Column("job_id", sqlmodel.sql.sqltypes.AutoString(), nullable=False),
+        sa.Column("flow_id", sa.Uuid(), nullable=False),
+        sa.Column(
+            "status",
+            sa.Enum("queued", "in_progress", "completed", "failed", "cancelled", "timed_out", name="job_status_enum"),
+            nullable=False,
+        ),
+        sa.Column("created_timestamp", sa.DateTime(timezone=True), nullable=False),
+        sa.Column("finished_timestamp", sa.DateTime(timezone=True), nullable=True),
+        sa.PrimaryKeyConstraint("job_id"),
+    )
+    with op.batch_alter_table("job", schema=None) as batch_op:
+        batch_op.create_index(batch_op.f("ix_job_flow_id"), ["flow_id"], unique=False)
+        batch_op.create_index(batch_op.f("ix_job_job_id"), ["job_id"], unique=False)
+        batch_op.create_index(batch_op.f("ix_job_status"), ["status"], unique=False)
+
+    with op.batch_alter_table("vertex_build", schema=None) as batch_op:
+        batch_op.add_column(sa.Column("job_id", sqlmodel.sql.sqltypes.AutoString(), nullable=True))
+        batch_op.create_index(batch_op.f("ix_vertex_build_job_id"), ["job_id"], unique=False)
+
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table("vertex_build", schema=None) as batch_op:
+        batch_op.drop_index(batch_op.f("ix_vertex_build_job_id"))
+        batch_op.drop_column("job_id")
+
+    with op.batch_alter_table("job", schema=None) as batch_op:
+        batch_op.drop_index(batch_op.f("ix_job_status"))
+        batch_op.drop_index(batch_op.f("ix_job_job_id"))
+        batch_op.drop_index(batch_op.f("ix_job_flow_id"))
+
+    op.drop_table("job")
+    # ### end Alembic commands ###