feat: KnowledgeBase Enhancements + Knowledge Ingestion flow + Polymorphic Job Tracking

.secrets.baseline

@@ -1527,13 +1527,6 @@
         "hashed_secret": "c2dc8a1d72a39ee9da360d47dcadfd7a5560ee7f",
         "is_verified": false,
         "line_number": 93
-      },
-      {
-        "type": "Hex High Entropy String",
-        "filename": "src/backend/base/langflow/initial_setup/starter_projects/Knowledge Ingestion.json",
-        "hashed_secret": "2db95e850ecd2695362e438d827e9a58ee36e4b0",
-        "is_verified": false,
-        "line_number": 766
       }
     ],
     "src/backend/base/langflow/initial_setup/starter_projects/Knowledge Retrieval.json": [
@@ -5358,13 +5351,6 @@
         "is_verified": false,
         "line_number": 769
       },
-      {
-        "type": "Hex High Entropy String",
-        "filename": "src/lfx/src/lfx/_assets/stable_hash_history.json",
-        "hashed_secret": "2db95e850ecd2695362e438d827e9a58ee36e4b0",
-        "is_verified": false,
-        "line_number": 774
-      },
       {
         "type": "Hex High Entropy String",
         "filename": "src/lfx/src/lfx/_assets/stable_hash_history.json",

src/backend/base/langflow/alembic/versions/169b35510b37_added_job_type_to_make_jobs_generic_and_.py

@@ -0,0 +1,62 @@
+"""added job_type to make jobs generic and user_id for ownership
+
+Revision ID: 169b35510b37
+Revises: 369268b9af8b
+Create Date: 2026-02-10 16:15:51.830502
+
+Phase: EXPAND
+"""
+
+from collections.abc import Sequence
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision: str = "169b35510b37"  # pragma: allowlist secret
+down_revision: str | None = "b1c2d3e4f5a6"  # pragma: allowlist secret
+branch_labels: str | Sequence[str] | None = None
+depends_on: str | Sequence[str] | None = None
+
+
+def upgrade() -> None:
+    conn = op.get_bind()
+    # Check which columns already exist (handles fresh DB where model creates them)
+    inspector = sa.inspect(conn)
+    existing_columns = {col["name"] for col in inspector.get_columns("job")}
+    existing_indexes = {idx["name"] for idx in inspector.get_indexes("job")}
+    job_type_enum = sa.Enum("workflow", "ingestion", "evaluation", name="job_type_enum")
+    job_type_enum.create(conn, checkfirst=True)
+
+    with op.batch_alter_table("job", schema=None) as batch_op:
+        if "type" not in existing_columns:
+            batch_op.add_column(sa.Column("type", job_type_enum, nullable=True))
+        if "user_id" not in existing_columns:
+            batch_op.add_column(sa.Column("user_id", sa.Uuid(), nullable=True))
+        if "ix_job_status" in existing_indexes:
+            batch_op.drop_index(batch_op.f("ix_job_status"))
+        if "ix_job_type" not in existing_indexes:
+            batch_op.create_index(batch_op.f("ix_job_type"), ["type"], unique=False)
+        if "ix_job_user_id" not in existing_indexes:
+            batch_op.create_index(batch_op.f("ix_job_user_id"), ["user_id"], unique=False)
+
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    conn = op.get_bind()
+    inspector = sa.inspect(conn)
+    existing_columns = {col["name"] for col in inspector.get_columns("job")}
+
+    with op.batch_alter_table("job", schema=None) as batch_op:
+        batch_op.drop_index(batch_op.f("ix_job_user_id"))
+        batch_op.drop_index(batch_op.f("ix_job_type"))
+        batch_op.create_index(batch_op.f("ix_job_status"), ["status"], unique=False)
+        batch_op.drop_column("user_id")
+        batch_op.drop_column("type")
+
+    if "type" in existing_columns:
+        job_type_enum = sa.Enum("workflow", "ingestion", "evaluation", name="job_type_enum")
+        job_type_enum.drop(conn, checkfirst=True)
+
+    # ### end Alembic commands ###

src/backend/base/langflow/alembic/versions/26ef53e27502_adding_asset_id_and_asset_type_to_job_.py

@@ -0,0 +1,49 @@
+"""adding asset_id and asset_type to job table for polymorphism of jobs.
+
+Revision ID: 26ef53e27502
+Revises: 169b35510b37
+Create Date: 2026-02-12 16:42:09.706216
+
+Phase: EXPAND
+"""
+
+from collections.abc import Sequence
+
+import sqlalchemy as sa
+import sqlmodel
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision: str = "26ef53e27502"
+down_revision: str | None = "169b35510b37"
+branch_labels: str | Sequence[str] | None = None
+depends_on: str | Sequence[str] | None = None
+
+
+def upgrade() -> None:
+    conn = op.get_bind()
+    # Check which columns/indexes already exist (handles fresh DB where model creates them)
+    inspector = sa.inspect(conn)
+    existing_columns = {col["name"] for col in inspector.get_columns("job")}
+    existing_indexes = {idx["name"] for idx in inspector.get_indexes("job")}
+
+    with op.batch_alter_table("job", schema=None) as batch_op:
+        if "asset_id" not in existing_columns:
+            batch_op.add_column(sa.Column("asset_id", sa.Uuid(), nullable=True))
+        if "asset_type" not in existing_columns:
+            batch_op.add_column(sa.Column("asset_type", sqlmodel.sql.sqltypes.AutoString(), nullable=True))
+        if "ix_job_asset_id" not in existing_indexes:
+            batch_op.create_index(batch_op.f("ix_job_asset_id"), ["asset_id"], unique=False)
+
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    conn = op.get_bind()
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table("job", schema=None) as batch_op:
+        batch_op.drop_index(batch_op.f("ix_job_asset_id"))
+        batch_op.drop_column("asset_type")
+        batch_op.drop_column("asset_id")
+
+    # ### end Alembic commands ###

src/backend/base/langflow/alembic/versions/369268b9af8b_add_job_id_to_vertex_build_create_job_.py

@@ -61,14 +61,20 @@ def upgrade() -> None:
 
 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")
+    from langflow.utils import migration
+
+    conn = op.get_bind()
 
-    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"))
+    # Drop vertex_build column if it exists
+    if migration.column_exists("vertex_build", "job_id", conn):
+        with op.batch_alter_table("vertex_build", schema=None) as batch_op:
+            try:
+                batch_op.drop_index(batch_op.f("ix_vertex_build_job_id"))
+            except Exception:  # noqa: S110
+                pass  # Index might not exist
+            batch_op.drop_column("job_id")
 
-    op.drop_table("job")
+    # Drop job table if it exists (this will automatically drop all indexes)
+    if migration.table_exists("job", conn):
+        op.drop_table("job")
     # ### end Alembic commands ###

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

@@ -0,0 +1,24 @@
+"""merge_job_asset_and_sso_heads
+
+Revision ID: c187c3b9bb94
+Revises: 26ef53e27502, b1c2d3e4f5a6
+Create Date: 2026-02-25 14:19:54.858370
+
+Phase: EXPAND
+"""
+
+from collections.abc import Sequence
+
+# revision identifiers, used by Alembic.
+revision: str = "c187c3b9bb94"
+down_revision: str | Sequence[str] | None = ("26ef53e27502", "b1c2d3e4f5a6")  # pragma: allowlist secret
+branch_labels: str | Sequence[str] | None = None
+depends_on: str | Sequence[str] | None = None
+
+
+def upgrade() -> None:
+    pass
+
+
+def downgrade() -> None:
+    pass