Merge branch 'release-1.12.0' into fix/background-job-timeout-ignored

Both conflicts were additive: langflow-ai#14353 added emit_output_capture to
_stream_event_frames and its background call site at the same spot this branch
adds execution_timeout. Kept both parameters.

Author: Saad ur Rehman

.github/changes-filter.yaml

@@ -3,7 +3,6 @@ python:
   - "src/backend/**"
   - "src/backend/**.py"
   - "src/lfx/**"
-  - "src/langflow-core/**"
   - "pyproject.toml"
   - "uv.lock"
   - "src/backend/base/pyproject.toml"
@@ -35,7 +34,6 @@ docker:
   - "src/backend/**"
   - "src/frontend/**"
   - "src/lfx/**"
-  - "src/langflow-core/**"
   - ".dockerignore"
   - ".github/workflows/docker-build-v2.yml"
   - ".github/workflows/docker_test.yml"

.github/workflows/cross-platform-test.yml

@@ -169,7 +169,7 @@ jobs:
           # `python -m langflow` could keep running the stable version and no real nightly migration
           # is exercised (false-positive test).
           echo "Removing stable langflow to force a clean install of the nightly dev version..."
-          uv pip uninstall -y langflow langflow-core langflow-base || true
+          uv pip uninstall -y langflow langflow-base || true
 
           # Extract version from Docker tag (format: langflowai/langflow:v1.10.0.dev20260522)
           if [[ "$NIGHTLY_TAG" == *":"* ]]; then
@@ -182,24 +182,24 @@ jobs:
 
             # Scope pre-release resolution to the langflow stack only. uv accepts a
             # pre-release for a package when its own requirement carries a pre-release
-            # marker, but NOT via transitive pins (langflow -> langflow-core ->
-            # langflow-base -> lfx -> langflow-sdk are exact ==devN pins on nightlies), so each lockstep package
+            # marker, but NOT via transitive pins (langflow -> langflow-base ->
+            # lfx -> langflow-sdk are exact ==devN pins on nightlies), so each lockstep package
             # must be requested directly. A global --prerelease=allow is NOT safe here:
             # it lets unrelated dependencies resolve to alphas (pydantic 2.14.0a1 broke
             # langchain-core imports on the first canonical-prerelease nightly).
             # langflow-sdk has its own version line, so an explicit .dev0 floor marks it
             # pre-release-eligible while the lfx pin selects the exact version.
             if [[ "$VERSION" == "latest" ]]; then
               # Install latest nightly (canonical pre-release) from PyPI
-              uv pip install --upgrade 'langflow[postgresql]>=0.0.0.dev0' 'langflow-core>=0.0.0.dev0' 'langflow-base>=0.0.0.dev0' 'lfx>=0.0.0.dev0' 'langflow-sdk>=0.0.0.dev0'
+              uv pip install --upgrade 'langflow[postgresql]>=0.0.0.dev0' 'langflow-base>=0.0.0.dev0' 'lfx>=0.0.0.dev0' 'langflow-sdk>=0.0.0.dev0'
             else
               # Install specific version
-              uv pip install --upgrade "langflow[postgresql]==$VERSION" "langflow-core==$VERSION" "langflow-base==$VERSION" "lfx==$VERSION" 'langflow-sdk>=0.0.0.dev0'
+              uv pip install --upgrade "langflow[postgresql]==$VERSION" "langflow-base==$VERSION" "lfx==$VERSION" 'langflow-sdk>=0.0.0.dev0'
             fi
           else
             # Direct version string (strip 'v' prefix if present)
             VERSION="${NIGHTLY_TAG#v}"
-            uv pip install --upgrade "langflow[postgresql]==$VERSION" "langflow-core==$VERSION" "langflow-base==$VERSION" "lfx==$VERSION" 'langflow-sdk>=0.0.0.dev0'
+            uv pip install --upgrade "langflow[postgresql]==$VERSION" "langflow-base==$VERSION" "lfx==$VERSION" 'langflow-sdk>=0.0.0.dev0'
           fi
 
           # Verify upgrade

.github/workflows/db-migration-validation.yml

@@ -24,7 +24,7 @@ on:
         type: string
         description: "Ref to check out. If not specified, will default to the main version or current branch."
       warning_check:
-        required: true
+        required: false
         type: boolean
         description: "Warning - use docker-build-v2 unless you have a very valid reason for using this deprecated workflow. By setting to True, you acknowledge all risks of using a possibly breaking workflow."
         default: false
@@ -160,6 +160,7 @@ jobs:
       docker_tags: ${{ steps.set-vars.outputs.docker_tags }}
       ghcr_tags: ${{ steps.set-vars.outputs.ghcr_tags }}
       file: ${{ steps.set-vars.outputs.file }}
+      target: ${{ steps.set-vars.outputs.target }}
     steps:
       - name: Set Dockerfile and Tags
         id: set-vars
@@ -173,13 +174,15 @@ jobs:
             # LANGFLOW-BASE RELEASE
             echo "docker_tags=langflowai/langflow${nightly_suffix}:base-${{ needs.get-version.outputs.version }},langflowai/langflow${nightly_suffix}:base-latest" >> $GITHUB_OUTPUT
             echo "ghcr_tags=ghcr.io/langflow-ai/langflow${nightly_suffix}:base-${{ needs.get-version.outputs.version }},ghcr.io/langflow-ai/langflow${nightly_suffix}:base-latest" >> $GITHUB_OUTPUT
-            echo "file=./docker/build_and_push_base.Dockerfile" >> $GITHUB_OUTPUT
+            echo "file=./docker/build_and_push.Dockerfile" >> $GITHUB_OUTPUT
+            echo "target=base" >> $GITHUB_OUTPUT
           else
             if [[ "${{ inputs.pre_release }}" == "true" ]]; then
               # LANGFLOW-MAIN PRE-RELEASE
               echo "docker_tags=langflowai/langflow${nightly_suffix}:${{ needs.get-version.outputs.version }}" >> $GITHUB_OUTPUT
               echo "ghcr_tags=ghcr.io/langflow-ai/langflow${nightly_suffix}:${{ needs.get-version.outputs.version }}" >> $GITHUB_OUTPUT
               echo "file=./docker/build_and_push.Dockerfile" >> $GITHUB_OUTPUT
+              echo "target=full" >> $GITHUB_OUTPUT
             elif [[ "${{ inputs.release_type }}" == "main-ep" ]]; then
               # LANGFLOW-MAIN (ENTRYPOINT) RELEASE
               echo "docker_tags=langflowai/langflow-ep${nightly_suffix}:${{ needs.get-version.outputs.version }},langflowai/langflow-ep${nightly_suffix}:latest" >> $GITHUB_OUTPUT
@@ -190,11 +193,13 @@ jobs:
               echo "docker_tags=langflowai/langflow${nightly_suffix}:${{ needs.get-version.outputs.version }},langflowai/langflow${nightly_suffix}:latest" >> $GITHUB_OUTPUT
               echo "ghcr_tags=ghcr.io/langflow-ai/langflow${nightly_suffix}:${{ needs.get-version.outputs.version }},ghcr.io/langflow-ai/langflow${nightly_suffix}:latest" >> $GITHUB_OUTPUT
               echo "file=./docker/build_and_push.Dockerfile" >> $GITHUB_OUTPUT
+              echo "target=full" >> $GITHUB_OUTPUT
             elif [[ "${{ inputs.release_type }}" == "main-all" || "${{ inputs.release_type }}" == "nightly-main-all" ]]; then
               # LANGFLOW-MAIN (ALL OPTIONAL DEPS) RELEASE
               echo "docker_tags=langflowai/langflow-all${nightly_suffix}:${{ needs.get-version.outputs.version }},langflowai/langflow-all${nightly_suffix}:latest" >> $GITHUB_OUTPUT
               echo "ghcr_tags=ghcr.io/langflow-ai/langflow-all${nightly_suffix}:${{ needs.get-version.outputs.version }},ghcr.io/langflow-ai/langflow-all${nightly_suffix}:latest" >> $GITHUB_OUTPUT
-              echo "file=./docker/build_and_push_with_extras.Dockerfile" >> $GITHUB_OUTPUT
+              echo "file=./docker/build_and_push.Dockerfile" >> $GITHUB_OUTPUT
+              echo "target=full-bundles" >> $GITHUB_OUTPUT
             else
               echo "Invalid release type. Exiting the workflow."
               exit 1
@@ -261,6 +266,7 @@ jobs:
             context: .
             push: true
             file: ${{ needs.setup.outputs.file }}
+            target: ${{ needs.setup.outputs.target }}
             tags: ${{ needs.setup.outputs.docker_tags }}
             platforms: linux/amd64,linux/arm64
             cache-from: type=gha
@@ -281,6 +287,7 @@ jobs:
             context: .
             push: true
             file: ${{ needs.setup.outputs.file }}
+            target: ${{ needs.setup.outputs.target }}
             tags: ${{ needs.setup.outputs.ghcr_tags }}
             platforms: linux/amd64,linux/arm64
             cache-from: type=gha
@@ -343,14 +350,14 @@ jobs:
             network=host
 
       - name: Login to Docker Hub
-        if: ${{ matrix.component == 'docker-backend' }} || ${{ matrix.component == 'docker-frontend' }}
+        if: ${{ matrix.component == 'docker-backend' || matrix.component == 'docker-frontend' }}
         uses: docker/login-action@v3
         with:
           username: ${{ secrets.DOCKERHUB_USERNAME }}
           password: ${{ secrets.DOCKERHUB_TOKEN }}
 
       - name: Login to Github Container Registry
-        if: ${{ matrix.component == 'ghcr-backend' }} || ${{ matrix.component == 'ghcr-frontend' }}
+        if: ${{ matrix.component == 'ghcr-backend' || matrix.component == 'ghcr-frontend' }}
         uses: docker/login-action@v3
         with:
           registry: ghcr.io

.github/workflows/docker-build-v2.yml

@@ -122,7 +122,8 @@ jobs:
           context: .
           push: ${{ inputs.push_to_registry }}
           pull: true
-          file: ./docker/build_and_push_base.Dockerfile
+          file: ./docker/build_and_push.Dockerfile
+          target: base
           tags: ${{ steps.tags.outputs.docker_tags }}
           platforms: linux/${{ matrix.arch }}
           provenance: false
@@ -135,7 +136,8 @@ jobs:
           context: .
           push: ${{ inputs.push_to_registry }}
           pull: true
-          file: ./docker/build_and_push_base.Dockerfile
+          file: ./docker/build_and_push.Dockerfile
+          target: base
           tags: ${{ steps.tags.outputs.ghcr_tags }}
           platforms: linux/${{ matrix.arch }}
           provenance: false
@@ -218,6 +220,7 @@ jobs:
           push: ${{ inputs.push_to_registry }}
           pull: true
           file: ./docker/build_and_push.Dockerfile
+          target: full
           tags: ${{ steps.tags.outputs.docker_tags }}
           platforms: linux/${{ matrix.arch }}
           provenance: false
@@ -231,6 +234,7 @@ jobs:
           push: ${{ inputs.push_to_registry }}
           pull: true
           file: ./docker/build_and_push.Dockerfile
+          target: full
           tags: ${{ steps.tags.outputs.ghcr_tags }}
           platforms: linux/${{ matrix.arch }}
           provenance: false
@@ -312,7 +316,8 @@ jobs:
           context: .
           push: ${{ inputs.push_to_registry }}
           pull: true
-          file: ./docker/build_and_push_with_extras.Dockerfile
+          file: ./docker/build_and_push.Dockerfile
+          target: full-bundles
           tags: ${{ steps.tags.outputs.docker_tags }}
           platforms: linux/${{ matrix.arch }}
           provenance: false
@@ -325,7 +330,8 @@ jobs:
           context: .
           push: ${{ inputs.push_to_registry }}
           pull: true
-          file: ./docker/build_and_push_with_extras.Dockerfile
+          file: ./docker/build_and_push.Dockerfile
+          target: full-bundles
           tags: ${{ steps.tags.outputs.ghcr_tags }}
           platforms: linux/${{ matrix.arch }}
           provenance: false

.github/workflows/docker-build.yml

@@ -82,45 +82,48 @@ jobs:
           echo "=== Disk usage after cleanup ==="
           df -h /
 
-      - name: Build core image
+      - name: Build base image
         run: |
-          ${{ env.CONTAINER_RUNTIME }} build -t langflowai/langflow:core-latest-dev \
+          ${{ env.CONTAINER_RUNTIME }} build -t langflowai/langflow:base-latest-dev \
             -f docker/build_and_push.Dockerfile \
-            --target core \
+            --target base \
             .
 
-      - name: Test core image
+      - name: Test base image
         run: |
-          expected_version=$(grep '^version = ' src/langflow-core/pyproject.toml | head -n 1 | cut -d '"' -f 2)
-          version=$(${{ env.CONTAINER_RUNTIME }} run --rm --entrypoint python langflowai/langflow:core-latest-dev -c 'from importlib.metadata import version; print(version("langflow-core"))')
+          expected_version=$(grep '^version = ' src/backend/base/pyproject.toml | head -n 1 | cut -d '"' -f 2)
+          version=$(${{ env.CONTAINER_RUNTIME }} run --rm --entrypoint python langflowai/langflow:base-latest-dev -c 'from importlib.metadata import version; print(version("langflow-base"))')
           if [ "$expected_version" != "$version" ]; then
-            echo "Expected core version: $expected_version"
-            echo "Actual core version: $version"
+            echo "Expected base version: $expected_version"
+            echo "Actual base version: $version"
             exit 1
           fi
 
-          ${{ env.CONTAINER_RUNTIME }} run --rm --entrypoint python langflowai/langflow:core-latest-dev -c '
+          ${{ env.CONTAINER_RUNTIME }} run --rm --entrypoint python langflowai/langflow:base-latest-dev -c '
           import importlib.metadata as metadata
           names = {dist.metadata["Name"].lower() for dist in metadata.distributions()}
-          required = {"langflow-core", "langflow-base", "lfx", "langflow-sdk"}
+          required = {"langflow-base", "lfx", "langflow-sdk"}
           missing = sorted(required - names)
-          forbidden = sorted(name for name in names if name.startswith("lfx-"))
-          assert not missing, f"missing core distributions: {missing}"
+          forbidden = sorted(
+              name for name in names
+              if name.startswith("lfx-") or name in {"langflow-core", "torch", "torchvision"}
+          )
+          assert not missing, f"missing base distributions: {missing}"
           assert not forbidden, f"extension distributions installed: {forbidden}"
           '
 
-          ${{ env.CONTAINER_RUNTIME }} run --rm --entrypoint bash langflowai/langflow:core-latest-dev -c '
+          ${{ env.CONTAINER_RUNTIME }} run --rm --entrypoint bash langflowai/langflow:base-latest-dev -c '
           command -v langflow >/dev/null
-          command -v langflow-core >/dev/null
+          ! command -v langflow-base >/dev/null
           '
 
           container_id=$(${{ env.CONTAINER_RUNTIME }} run -d \
-            -e LANGFLOW_SUPERUSER_PASSWORD=CoreImageTest-2026! \
-            langflowai/langflow:core-latest-dev)
-          cleanup_core_container() {
+            -e LANGFLOW_SUPERUSER_PASSWORD=BaseImageTest-2026! \
+            langflowai/langflow:base-latest-dev)
+          cleanup_base_container() {
             ${{ env.CONTAINER_RUNTIME }} rm -f "$container_id" >/dev/null 2>&1 || true
           }
-          trap cleanup_core_container EXIT
+          trap cleanup_base_container EXIT
 
           healthy=false
           for _ in $(seq 1 60); do
@@ -135,15 +138,15 @@ jobs:
           done
 
           if [ "$healthy" != "true" ]; then
-            echo "Core image did not become healthy"
+            echo "Base image did not become healthy"
             ${{ env.CONTAINER_RUNTIME }} logs "$container_id" || true
             exit 1
           fi
 
-          cleanup_core_container
+          cleanup_base_container
           trap - EXIT
 
-      - name: Cleanup after core image
+      - name: Cleanup after base image
         if: always()
         run: |
           echo "=== Disk usage before cleanup ==="
@@ -152,8 +155,8 @@ jobs:
             if [ -n "$container_id" ]; then
               ${{ env.CONTAINER_RUNTIME }} rm -f "$container_id" 2>/dev/null || true
             fi
-          done < <(${{ env.CONTAINER_RUNTIME }} ps -aq --filter ancestor=langflowai/langflow:core-latest-dev)
-          ${{ env.CONTAINER_RUNTIME }} rmi langflowai/langflow:core-latest-dev || true
+          done < <(${{ env.CONTAINER_RUNTIME }} ps -aq --filter ancestor=langflowai/langflow:base-latest-dev)
+          ${{ env.CONTAINER_RUNTIME }} rmi langflowai/langflow:base-latest-dev || true
           ${{ env.CONTAINER_RUNTIME }} system prune -af || true
           if command -v docker &> /dev/null; then
             docker buildx prune -af || true

.github/workflows/docker-nightly-build.yml

@@ -107,11 +107,11 @@ jobs:
         run: |
           echo "PWD: $(pwd)"
           find . -name "pypi_nightly_tag.py"
-      - name: Generate shared nightly tag (main == core == base, lockstep)
+      - name: Generate shared nightly tag (main == base, lockstep)
         id: generate_shared_tag
         run: |
-          # langflow -> langflow-core -> langflow-base uses exact nightly dev pins,
-          # so all three versions MUST be identical. Compute from one PyPI snapshot.
+          # langflow -> langflow-base uses an exact nightly dev pin, so both
+          # versions MUST be identical. Compute from one PyPI snapshot.
           # NOTE: This outputs the tag with the `v` prefix.
           TAGS_OUTPUT="$(uv run ./scripts/ci/pypi_nightly_tag.py both)"
           RELEASE_TAG="$(printf '%s\n' "$TAGS_OUTPUT" | sed -n '1p')"
@@ -164,13 +164,13 @@ jobs:
           uv run --no-sync ./scripts/ci/update_sdk_version.py $SDK_TAG
           echo "Updating LFX project version to $LFX_TAG"
           uv run --no-sync ./scripts/ci/update_lfx_version.py $LFX_TAG $SDK_TAG
-          echo "Updating base/core/main project versions to the shared nightly tag"
+          echo "Updating base/main project versions to the shared nightly tag"
           uv run --no-sync ./scripts/ci/update_pyproject_combined.py main $RELEASE_TAG $BASE_TAG $LFX_TAG
 
           uv lock
           cd src/lfx && uv lock && cd ../..
 
-          git add pyproject.toml src/langflow-core/pyproject.toml src/backend/base/pyproject.toml src/lfx/pyproject.toml \
+          git add pyproject.toml src/backend/base/pyproject.toml src/lfx/pyproject.toml \
             src/lfx/src/lfx/_assets/component_index.json src/sdk/pyproject.toml uv.lock
           # The nightly keeps canonical package names and the stable `lfx-*` bundles
           # are not modified (see src/bundles/NIGHTLY.md), so no bundle pyprojects ride this commit.

.github/workflows/docker_test.yml

@@ -204,27 +204,27 @@ jobs:
           cache-dependency-glob: "uv.lock"
           python-version: ${{ matrix.python-version }}
           prune-cache: false
-          # This job intentionally exits before invoking uv when langflow-core
+          # This job intentionally exits before invoking uv when langflow-base
           # has not been published yet (including its first release).
           ignore-nothing-to-cache: true
 
       - name: Check Version
         id: check-version
-        # The main wheel resolves its direct langflow-core dependency from PyPI.
-        # Skip until the source core version (stable or canonical nightly) exists.
+        # The main wheel resolves its direct langflow-base dependency from PyPI.
+        # Skip until the source base version (stable or canonical nightly) exists.
         run: |
-          version=$(python -c "import pathlib, tomllib; print(tomllib.loads(pathlib.Path('src/langflow-core/pyproject.toml').read_text())['project']['version'])")
-          url="https://pypi.org/pypi/langflow-core/json"
+          version=$(python -c "import pathlib, tomllib; print(tomllib.loads(pathlib.Path('src/backend/base/pyproject.toml').read_text())['project']['version'])")
+          url="https://pypi.org/pypi/langflow-base/json"
 
-          status=$(curl -sS -o "$RUNNER_TEMP/langflow-core-pypi.json" -w "%{http_code}" "$url")
+          status=$(curl -sS -o "$RUNNER_TEMP/langflow-base-pypi.json" -w "%{http_code}" "$url")
           if [ "$status" = "404" ]; then
             last_released_version=""
           elif [ "$status" != "200" ]; then
-            echo "Failed to fetch langflow-core releases: HTTP $status"
-            cat "$RUNNER_TEMP/langflow-core-pypi.json"
+            echo "Failed to fetch langflow-base releases: HTTP $status"
+            cat "$RUNNER_TEMP/langflow-base-pypi.json"
             exit 1
           else
-            last_released_version=$(jq -r '.releases | keys[]' "$RUNNER_TEMP/langflow-core-pypi.json" | sort -V | tail -n 1)
+            last_released_version=$(jq -r '.releases | keys[]' "$RUNNER_TEMP/langflow-base-pypi.json" | sort -V | tail -n 1)
           fi
 
           if [ "$version" != "$last_released_version" ]; then