feat: merge release-1.6.0 with updates

.env.example

@@ -104,7 +104,7 @@ LANGFLOW_STORE_ENVIRONMENT_VARIABLES=
 # Should enable the MCP composer feature in MCP projects
 # Values: true, false
 # Default: true
-LANGFLOW_FEATURE_MCP_COMPOSER=
+LANGFLOW_MCP_COMPOSER_ENABLED=
 
 # STORE_URL
 # Example: LANGFLOW_STORE_URL=https://api.langflow.store

.gitignore

@@ -280,4 +280,6 @@ src/frontend/temp
 *.mcp.json
 
 news-aggregated.json
-CLAUDE.md
+CLAUDE.md
+
+member_servers.json

docker/build_and_push.Dockerfile

@@ -96,3 +96,4 @@ ENV LANGFLOW_HOST=0.0.0.0
 ENV LANGFLOW_PORT=7860
 
 CMD ["langflow", "run"]
+

docs/docs/Integrations/Cleanlab/eval_and_remediate_cleanlab.json

@@ -892,7 +892,7 @@
                 "tool_mode": false,
                 "trace_as_metadata": true,
                 "type": "str",
-                "value": "gpt-4o"
+                "value": "gpt-4.1"
               },
               "openai_api_base": {
                 "_input_type": "StrInput",
@@ -1200,7 +1200,7 @@
                 "tool_mode": false,
                 "trace_as_metadata": true,
                 "type": "str",
-                "value": "gpt-4o-mini"
+                "value": "gpt-4.1"
               },
               "prompt": {
                 "_input_type": "MessageTextInput",

docs/docs/Integrations/Notion/Conversational_Notion_Agent.json

@@ -2811,7 +2811,7 @@
                 "tool_mode": false,
                 "trace_as_metadata": true,
                 "type": "str",
-                "value": "gpt-4o"
+                "value": "gpt-4.1"
               },
               "openai_api_base": {
                 "_input_type": "StrInput",

docs/docs/Integrations/Notion/Meeting_Notes_Agent.json

@@ -1093,7 +1093,7 @@
                                 "placeholder": "",
                                 "show": true,
                                 "name": "model_name",
-                                "value": "gpt-4o",
+                                "value": "gpt-4.1",
                                 "display_name": "Model Name",
                                 "advanced": true,
                                 "dynamic": false,
@@ -1878,7 +1878,7 @@
                                 "placeholder": "",
                                 "show": true,
                                 "name": "model_name",
-                                "value": "gpt-4o",
+                                "value": "gpt-4.1",
                                 "display_name": "Model Name",
                                 "advanced": true,
                                 "dynamic": false,

pyproject.toml

@@ -122,13 +122,15 @@ dependencies = [
     "cleanlab-tlm>=1.1.2",
     'gassist>=0.0.1; sys_platform == "win32"',
     "twelvelabs>=0.4.7",
-    "docling_core>=2.36.1",
+    "docling>=2.36.1",
     "filelock>=3.18.0",
     "jigsawstack==0.2.7",
     "structlog>=25.4.0",
     "aiosqlite==0.21.0",
     "fastparquet>=2024.11.0",
     "traceloop-sdk>=0.43.1",
+    "easyocr>=1.7.2",
+    "opencv-python>=4.11",
 ]
 
 [dependency-groups]
@@ -179,7 +181,6 @@ dev = [
     "pytest-timeout>=2.3.1",
     "pyyaml>=6.0.2",
     "pyleak>=0.1.14",
-    "docling>=2.36.1"
 ]
 
 [tool.uv.sources]

src/backend/base/langflow/__main__.py

@@ -683,7 +683,7 @@ async def _create_superuser(username: str, password: str, auth_token: str | None
     if settings_service.auth_settings.AUTO_LOGIN:
         # Force default credentials for AUTO_LOGIN mode
         username = DEFAULT_SUPERUSER
-        password = DEFAULT_SUPERUSER_PASSWORD
+        password = DEFAULT_SUPERUSER_PASSWORD.get_secret_value()
     else:
         # Production mode - prompt for credentials if not provided
         if not username:
@@ -711,7 +711,7 @@ async def _create_superuser(username: str, password: str, auth_token: str | None
             raise typer.Exit(1)
 
         typer.echo(f"AUTO_LOGIN enabled. Creating default superuser '{username}'...")
-        typer.echo(f"Note: Default credentials are {DEFAULT_SUPERUSER}/{DEFAULT_SUPERUSER_PASSWORD}")
+        # Do not echo the default password to avoid exposing it in logs.
     # AUTO_LOGIN is false - production mode
     elif is_first_setup:
         typer.echo("No superusers found. Creating first superuser...")

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

@@ -0,0 +1,222 @@
+"""Drop single constraint on file.name column
+
+Revision ID: d37bc4322900
+Revises: 0882f9657f22
+Create Date: 2025-09-15 11:11:37.610294
+
+"""
+import logging
+
+from typing import Sequence, Union
+
+import sqlalchemy as sa
+from alembic import op
+
+logger = logging.getLogger(__name__)
+
+# revision identifiers, used by Alembic.
+revision: str = "d37bc4322900"
+down_revision: Union[str, None] = "0882f9657f22"
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    """Remove single UNIQUE constraint on name column while preserving composite constraint."""
+    conn = op.get_bind()
+    inspector = sa.inspect(conn)
+
+    # Check if file table exists
+    table_names = inspector.get_table_names()
+    if "file" not in table_names:
+        logger.info("file table does not exist, skipping")
+        return
+
+    db_dialect = conn.dialect.name
+    logger.info(f"Running migration on {db_dialect} database")
+
+    try:
+        if db_dialect == "sqlite":
+            # SQLite: Recreate table without single UNIQUE constraint
+            logger.info("SQLite: Recreating table to remove single UNIQUE constraint on name")
+
+            # Guard against schema drift: ensure expected columns before destructive rebuild
+            res = conn.execute(sa.text('PRAGMA table_info("file")'))
+            cols = [row[1] for row in res]
+            expected = ['id', 'user_id', 'name', 'path', 'size', 'provider', 'created_at', 'updated_at']
+            if set(cols) != set(expected):
+                raise RuntimeError(f"SQLite: Unexpected columns on file table: {cols}. Aborting migration to avoid data loss.")
+
+            # Create the new table without the single UNIQUE(name) constraint
+            op.execute("""
+                CREATE TABLE file_new (
+                    id CHAR(32) NOT NULL, 
+                    user_id CHAR(32) NOT NULL, 
+                    name VARCHAR NOT NULL, 
+                    path VARCHAR NOT NULL, 
+                    size INTEGER NOT NULL, 
+                    provider VARCHAR, 
+                    created_at DATETIME NOT NULL, 
+                    updated_at DATETIME NOT NULL, 
+                    PRIMARY KEY (id), 
+                    CONSTRAINT file_name_user_id_key UNIQUE (name, user_id), 
+                    FOREIGN KEY(user_id) REFERENCES user (id)
+                )
+            """)
+
+            # Copy data from old table to new table
+            op.execute("""
+                INSERT INTO file_new (id, user_id, name, path, size, provider, created_at, updated_at)
+                SELECT id, user_id, name, path, size, provider, created_at, updated_at
+                FROM file
+            """)
+
+            # Drop old table and rename new table
+            op.execute("PRAGMA foreign_keys=OFF")
+            try:
+                op.execute("DROP TABLE file")
+                op.execute("ALTER TABLE file_new RENAME TO file")
+            finally:
+                op.execute("PRAGMA foreign_keys=ON")
+
+            logger.info("SQLite: Successfully recreated file table without single UNIQUE constraint on name")
+
+        elif db_dialect == "postgresql":
+            # PostgreSQL: Find and drop single-column unique constraints on 'name'
+            logger.info("PostgreSQL: Finding and dropping single UNIQUE constraints and indexes on name")
+
+            # Determine target schema
+            schema = sa.inspect(conn).default_schema_name or "public"
+
+            # Get constraint names that are single-column unique on 'name'
+            result = conn.execute(sa.text("""
+                SELECT conname 
+                FROM pg_constraint c
+                JOIN pg_class t ON c.conrelid = t.oid
+                JOIN pg_namespace n ON t.relnamespace = n.oid
+                WHERE t.relname = 'file' 
+                AND n.nspname = :schema
+                AND c.contype = 'u'
+                AND array_length(c.conkey, 1) = 1
+                AND EXISTS (
+                    SELECT 1 FROM pg_attribute a
+                    WHERE a.attrelid = t.oid 
+                    AND a.attnum = c.conkey[1]
+                    AND a.attname = 'name'
+                )
+            """), {"schema": schema})
+
+            constraints_to_drop = [row[0] for row in result.fetchall()]
+
+            if constraints_to_drop:
+                for constraint_name in constraints_to_drop:
+                    op.drop_constraint(constraint_name, "file", type_="unique", schema=schema)
+                    logger.info(f"PostgreSQL: Dropped constraint {constraint_name}")
+            else:
+                logger.info("PostgreSQL: No single UNIQUE constraints found on name column")
+
+            # Also drop any single-column UNIQUE indexes on name not backed by constraints
+            idx_result = conn.execute(sa.text("""
+                SELECT i.relname
+                FROM pg_class t
+                JOIN pg_namespace n ON n.oid = t.relnamespace
+                JOIN pg_index ix ON ix.indrelid = t.oid
+                JOIN pg_class i ON i.oid = ix.indexrelid
+                WHERE t.relname = 'file'
+                  AND n.nspname = :schema
+                  AND ix.indisunique = TRUE
+                  AND array_length(ix.indkey, 1) = 1
+                  AND NOT EXISTS (SELECT 1 FROM pg_constraint c WHERE c.conindid = ix.indexrelid)
+                  AND (SELECT a.attname FROM pg_attribute a 
+                       WHERE a.attrelid = t.oid AND a.attnum = ix.indkey[1]) = 'name'
+            """), {"schema": schema})
+            for (index_name,) in idx_result.fetchall():
+                op.drop_index(index_name, table_name="file", schema=schema)
+                logger.info(f"PostgreSQL: Dropped unique index {index_name}")
+
+        else:
+            raise ValueError(f"Unsupported database dialect: {db_dialect}")
+
+    except Exception as e:
+        logger.error(f"Error during constraint removal: {e}")
+        raise
+
+
+def downgrade() -> None:
+    """Add back the single unique constraint on name column."""
+    conn = op.get_bind()
+    inspector = sa.inspect(conn)
+
+    # Check if file table exists
+    table_names = inspector.get_table_names()
+    if "file" not in table_names:
+        logger.info("file table does not exist, skipping downgrade")
+        return
+
+    db_dialect = conn.dialect.name
+
+    try:
+        # Pre-check for duplicates that would violate UNIQUE(name)
+        dup = conn.execute(sa.text("SELECT name FROM file GROUP BY name HAVING COUNT(*) > 1 LIMIT 1")).first()
+        if dup:
+            raise RuntimeError(
+                "Downgrade aborted: duplicates in file.name would violate UNIQUE(name). "
+                "Deduplicate before downgrading."
+            )
+        if db_dialect == "sqlite":
+            # Add the same column validation as upgrade
+            res = conn.execute(sa.text('PRAGMA table_info("file")'))
+            cols = [row[1] for row in res]
+            expected = ['id', 'user_id', 'name', 'path', 'size', 'provider', 'created_at', 'updated_at']
+            if set(cols) != set(expected):
+                raise RuntimeError(f"SQLite: Unexpected columns on file table: {cols}. Aborting downgrade.")
+            # SQLite: Recreate table with both constraints
+            logger.info("SQLite: Recreating table with both constraints")
+
+            op.execute("""
+                CREATE TABLE file_new (
+                    id CHAR(32) NOT NULL, 
+                    user_id CHAR(32) NOT NULL, 
+                    name VARCHAR NOT NULL, 
+                    path VARCHAR NOT NULL, 
+                    size INTEGER NOT NULL, 
+                    provider VARCHAR, 
+                    created_at DATETIME NOT NULL, 
+                    updated_at DATETIME NOT NULL, 
+                    PRIMARY KEY (id), 
+                    CONSTRAINT file_name_user_id_key UNIQUE (name, user_id), 
+                    FOREIGN KEY(user_id) REFERENCES user (id),
+                    UNIQUE (name)
+                )
+            """)
+
+            # Copy data
+            op.execute("""
+                INSERT INTO file_new (id, user_id, name, path, size, provider, created_at, updated_at)
+                SELECT id, user_id, name, path, size, provider, created_at, updated_at
+                FROM file
+            """)
+
+            # Replace table
+            op.execute("PRAGMA foreign_keys=OFF")
+            try:
+                op.execute("DROP TABLE file")
+                op.execute("ALTER TABLE file_new RENAME TO file")
+            finally:
+                op.execute("PRAGMA foreign_keys=ON")
+
+            logger.info("SQLite: Restored single unique constraint on name column")
+
+        elif db_dialect == "postgresql":
+            # PostgreSQL: Add constraint back
+            schema = sa.inspect(conn).default_schema_name or "public"
+            op.create_unique_constraint("file_name_unique", "file", ["name"], schema=schema)
+            logger.info("PostgreSQL: Added back single unique constraint on 'name' column")
+
+        else:
+            logger.info(f"Downgrade not supported for dialect: {db_dialect}")
+
+    except Exception as e:
+        logger.error(f"Error during downgrade: {e}")
+        if "constraint" not in str(e).lower():
+            raise

src/backend/base/langflow/api/build.py

@@ -345,9 +345,14 @@ async def _build_vertex(vertex_id: str, graph: Graph, event_manager: EventManage
             result_data_response.duration = duration
             result_data_response.timedelta = timedelta
             vertex.add_build_time(timedelta)
-            inactivated_vertices = list(graph.inactivated_vertices)
+            # Capture both inactivated and conditionally excluded vertices
+            inactivated_vertices = list(graph.inactivated_vertices.union(graph.conditionally_excluded_vertices))
             graph.reset_inactivated_vertices()
             graph.reset_activated_vertices()
+
+            # Note: Do not reset conditionally_excluded_vertices each iteration
+            # This is handled by the ConditionalRouter component
+
             # graph.stop_vertex tells us if the user asked
             # to stop the build of the graph at a certain vertex
             # if it is in next_vertices_ids, we need to remove other
@@ -407,7 +412,7 @@ async def build_vertices(
         try:
             vertex_build_response: VertexBuildResponse = await _build_vertex(vertex_id, graph, event_manager)
         except asyncio.CancelledError as exc:
-            await logger.aerror(f"Build cancelled: {exc}")
+            await logger.ainfo(f"Build cancelled: {exc}")
             raise
 
         # send built event or error event