chore(main): release 1.630.2 (#7897 )

* chore(main): release 1.630.2 * Apply automatic changes --------- Co-authored-by: rubenfiszel <275584+rubenfiszel@users.noreply.github.com>
bump rust to 1.93.0
2026-09-19 00:02:28 +00:00 · 2026-02-11 00:29:42 +00:00 · 2026-02-11 00:02:24 +00:00 · 2026-02-10 23:55:36 +00:00 · 2026-02-10 23:45:51 +00:00 · 2026-02-10 23:34:15 +00:00
272 changed files with 11084 additions and 3139 deletions
@@ -23,7 +23,7 @@ jobs:
      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
          cache: false
-          toolchain: 1.90.0
+          toolchain: 1.93.0
      - name: cargo check
        working-directory: ./backend
        timeout-minutes: 16
@@ -39,12 +39,12 @@ jobs:
      - name: install xmlsec1 and gssapi
        run: |
          sudo apt-get update
-          sudo apt-get install -y libxml2-dev libxmlsec1-dev libkrb5-dev libsasl2-dev mold clang
+          sudo apt-get install -y libxml2-dev libxmlsec1-dev libkrb5-dev libsasl2-dev libcurl4-openssl-dev mold clang

      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
          cache: false
-          toolchain: 1.90.0
+          toolchain: 1.93.0
      - name: cargo check
        working-directory: ./backend
        timeout-minutes: 16
@@ -81,7 +81,7 @@ jobs:
      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
          cache: false
-          toolchain: 1.90.0
+          toolchain: 1.93.0
      - name: cargo check
        working-directory: ./backend
        timeout-minutes: 16
@@ -109,7 +109,7 @@ jobs:
      - name: install xmlsec1 and gssapi
        run: |
          sudo apt-get update
-          sudo apt-get install -y libxml2-dev libxmlsec1-dev libkrb5-dev libsasl2-dev mold clang
+          sudo apt-get install -y libxml2-dev libxmlsec1-dev libkrb5-dev libsasl2-dev libcurl4-openssl-dev mold clang

      - name: Substitute EE code (EE logic is behind feature flag)
        run: |
@@ -118,7 +118,7 @@ jobs:
      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
          cache-workspaces: backend
-          toolchain: 1.90.0
+          toolchain: 1.93.0
      - name: cargo check
        timeout-minutes: 16
        working-directory: ./backend
@@ -72,12 +72,12 @@ jobs:
          bundler-cache: false
      - name: Install PowerShell, mold and clang
        run: |
-          sudo apt-get update && sudo apt-get install -y powershell mold clang
+          sudo apt-get update && sudo apt-get install -y powershell mold clang libcurl4-openssl-dev
        working-directory: /
      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
          cache: false
-          toolchain: 1.90.0
+          toolchain: 1.93.0
      - name: Read EE repo commit hash
        run: |
          echo "ee_repo_ref=$(cat ./ee-repo-ref.txt)" >> "$GITHUB_ENV"
@@ -222,4 +222,4 @@ jobs:
        run: |
          deno --version && bun -v && node --version && go version && python3 --version && php --version && ruby --version && pwsh --version && dotnet --version
          cd windmill-duckdb-ffi-internal && ./build_dev.sh && cd ..
-          DENO_PATH=$(which deno) BUN_PATH=$(which bun) NODE_BIN_PATH=$(which node) GO_PATH=$(which go) UV_PATH=$(which uv) PHP_PATH=$(which php) COMPOSER_PATH=$(which composer) RUBY_PATH=$(which ruby) RUBY_BUNDLE_PATH=$(which bundle) RUBY_GEM_PATH=$(which gem) POWERSHELL_PATH=$(which pwsh) DOTNET_PATH=$(which dotnet) cargo test --features enterprise,deno_core,duckdb,license,python,rust,scoped_cache,parquet,private,private_registry_test,csharp,php,ruby,mysql,quickjs,mcp --all -- --nocapture --test-threads=16
+          DENO_PATH=$(which deno) BUN_PATH=$(which bun) NODE_BIN_PATH=$(which node) GO_PATH=$(which go) UV_PATH=$(which uv) PHP_PATH=$(which php) COMPOSER_PATH=$(which composer) RUBY_PATH=$(which ruby) RUBY_BUNDLE_PATH=$(which bundle) RUBY_GEM_PATH=$(which gem) POWERSHELL_PATH=$(which pwsh) DOTNET_PATH=$(which dotnet) cargo test --features enterprise,deno_core,duckdb,license,python,rust,scoped_cache,parquet,private,private_registry_test,csharp,php,ruby,mysql,quickjs,mcp --all -- --nocapture --test-threads=10
@@ -11,7 +11,7 @@ env:

 jobs:
  cargo_build_windows:
-    runs-on: windows-latest
+    runs-on: blacksmith-16vcpu-windows-2025
    steps:
      - uses: actions/checkout@v4

@@ -30,33 +30,40 @@ jobs:
          token: ${{ secrets.WINDMILL_EE_PRIVATE_ACCESS }}
          fetch-depth: 0

-      - name: Setup Rust
-        uses: actions-rs/toolchain@v1
+      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
-          toolchain: 1.90.0
-          override: true
+          cache-workspaces: backend
+          toolchain: 1.93.0

      - name: Substitute EE code
        shell: bash
        run: |
          ./backend/substitute_ee_code.sh --copy --dir ./windmill-ee-private

+      - name: Cargo check (fail fast on warnings)
+        timeout-minutes: 60
+        env:
+          RUSTFLAGS: "-D warnings"
+        run: |
+          mkdir frontend/build && cd backend
+          New-Item -Path . -Name "windmill-api/openapi-deref.yaml" -ItemType "File" -Force
+          cargo check --features=ee_windows
+
      - name: Cargo build dynamic libraries windows
-        timeout-minutes: 90
+        timeout-minutes: 180
        run: |
          cd backend/windmill-duckdb-ffi-internal
          cargo build --release -p windmill_duckdb_ffi_internal

      - name: Cargo build binary windows
-        timeout-minutes: 90
+        timeout-minutes: 180
        run: |
          vcpkg.exe install openssl-windows:x64-windows
          vcpkg.exe install openssl:x64-windows-static
          vcpkg.exe integrate install
          $env:VCPKGRS_DYNAMIC=1
          $env:OPENSSL_DIR="${Env:VCPKG_INSTALLATION_ROOT}\installed\x64-windows-static"
-          mkdir frontend/build && cd backend
-          New-Item -Path . -Name "windmill-api/openapi-deref.yaml" -ItemType "File" -Force
+          cd backend
          cargo build --release --features=ee_windows
      - name: Rename binary with corresponding architecture
        run: |
@@ -78,18 +78,18 @@ jobs:
      - name: install xmlsec1 and gssapi
        run: |
          sudo apt-get update
-          sudo apt-get install -y libxml2-dev libxmlsec1-dev libkrb5-dev libsasl2-dev
+          sudo apt-get install -y libxml2-dev libxmlsec1-dev libkrb5-dev libsasl2-dev libcurl4-openssl-dev mold clang

      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
          cache-workspaces: backend
-          toolchain: 1.90.0
+          toolchain: 1.93.0

      - name: cargo check
        working-directory: ./backend
        timeout-minutes: 16
        run: |
-          SQLX_OFFLINE=true cargo check --features $(./all_features_oss.sh)
+          SQLX_OFFLINE=true cargo check --features all_sqlx_features

      - name: Run Claude PR Action
        uses: anthropics/claude-code-action@v1
@@ -119,7 +119,7 @@ jobs:
            - Fix all warnings and errors before proceeding

            **Backend Changes:**
-            - Run: \`cargo check --features $(./all_features_oss.sh)\` in the backend directory
+            - Run: \`cargo check --features all_sqlx_features\` in the backend directory
            - Fix all warnings and errors before proceeding

            **Pull Request Creation:**
@@ -62,17 +62,17 @@ jobs:
          path: windmill-ee-private
          token: ${{ secrets.WINDMILL_EE_PRIVATE_ACCESS }}

-      # Cache rust dependencies
-      - uses: dtolnay/rust-toolchain@stable
-      - uses: Swatinem/rust-cache@v2
+      # Setup Rust toolchain
+      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
-          workspaces: "./backend -> target"
+          cache-workspaces: backend
+          toolchain: 1.93.0

      - name: Install xmlsec and gssapi build-time deps
        run: |
          sudo apt-get update
          sudo apt-get install -y --no-install-recommends \
-            pkg-config libxml2-dev libssl-dev libkrb5-dev \
+            pkg-config libxml2-dev libssl-dev libkrb5-dev libsasl2-dev libcurl4-openssl-dev mold clang \
            xmlsec1 libxmlsec1-dev libxmlsec1-openssl

      - name: Run update-sqlx script
@@ -13,7 +13,7 @@ env:

 jobs:
  cargo_build_windows:
-    runs-on: windows-latest
+    runs-on: blacksmith-16vcpu-windows-2025
    steps:
      - uses: actions/checkout@v4

@@ -32,11 +32,10 @@ jobs:
          token: ${{ secrets.WINDMILL_EE_PRIVATE_ACCESS }}
          fetch-depth: 0

-      - name: Setup Rust
-        uses: actions-rs/toolchain@v1
+      - uses: actions-rust-lang/setup-rust-toolchain@v1
        with:
-          toolchain: 1.90.0
-          override: true
+          cache-workspaces: backend
+          toolchain: 1.93.0

      - name: Substitute EE code
        shell: bash
@@ -44,13 +43,13 @@ jobs:
          ./backend/substitute_ee_code.sh --copy --dir ./windmill-ee-private

      - name: Cargo build dynamic libraries windows
-        timeout-minutes: 90
+        timeout-minutes: 180
        run: |
          cd backend/windmill-duckdb-ffi-internal
          cargo build --release -p windmill_duckdb_ffi_internal

      - name: Cargo build windows
-        timeout-minutes: 90
+        timeout-minutes: 180
        run: |
          vcpkg.exe install openssl-windows:x64-windows
          vcpkg.exe install openssl:x64-windows-static
@@ -1,5 +1,73 @@
 # Changelog

+## [1.630.2](https://github.com/windmill-labs/windmill/compare/v1.630.1...v1.630.2) (2026-02-11)
+
+
+### Bug Fixes
+
+* bump rust version from 1.90.0 to 1.93.0 ([1a109a7](https://github.com/windmill-labs/windmill/commit/1a109a7797d1a50a0d85f3fff236d707b2cfb81d))
+
+## [1.630.1](https://github.com/windmill-labs/windmill/compare/v1.630.0...v1.630.1) (2026-02-10)
+
+
+### Bug Fixes
+
+* enforce self-approval check on flow resume owner endpoint ([#7886](https://github.com/windmill-labs/windmill/issues/7886)) ([7147dde](https://github.com/windmill-labs/windmill/commit/7147dde5118d7b3a179e4b310c74b148838b5afe))
+
+## [1.630.0](https://github.com/windmill-labs/windmill/compare/v1.629.1...v1.630.0) (2026-02-10)
+
+
+### Features
+
+* add workspace search and runnable details tools to AI chat modes ([#7874](https://github.com/windmill-labs/windmill/issues/7874)) ([a7e269f](https://github.com/windmill-labs/windmill/commit/a7e269f9f3c82db0d7e6a70e174ac19d3df730d2))
+* **aiagent:** add prompt caching for Anthropic models ([#7878](https://github.com/windmill-labs/windmill/issues/7878)) ([6272cd1](https://github.com/windmill-labs/windmill/commit/6272cd17a4f1300e22e7f0ae27b1a57571deb203))
+* download encrypted usage ([#7804](https://github.com/windmill-labs/windmill/issues/7804)) ([8363ff1](https://github.com/windmill-labs/windmill/commit/8363ff1eeef06f284e6d165fbf2dfb190ead573d))
+* **mcp:** add endpoint tools for scripts, flows, apps, and jobs ([#7859](https://github.com/windmill-labs/windmill/issues/7859)) ([03eb16a](https://github.com/windmill-labs/windmill/commit/03eb16a7c6c3cd9411840814940d09e22ce23305))
+* restriction rulesets for workspaces ([#7879](https://github.com/windmill-labs/windmill/issues/7879)) ([2851b6b](https://github.com/windmill-labs/windmill/commit/2851b6b7caac4a55f5202ace82aba68fd157c52a))
+
+
+### Bug Fixes
+
+* **backend:** correct early return with stream + prevent delta miss ([#7872](https://github.com/windmill-labs/windmill/issues/7872)) ([1150eec](https://github.com/windmill-labs/windmill/commit/1150eec7571d5828d10b295cb61cca8edfbdffe0))
+* gate Permissions import behind #[cfg(unix)] for Windows build ([cf596f3](https://github.com/windmill-labs/windmill/commit/cf596f370ae7cc232ca63f4752d7727a74cd449b))
+* retry js eval up to 3 times on timeout from slow DB ([#7890](https://github.com/windmill-labs/windmill/issues/7890)) ([4c87e7a](https://github.com/windmill-labs/windmill/commit/4c87e7ac2e09ec83cfb998a1cebcb9b9c5ef8027))
+
+## [1.629.1](https://github.com/windmill-labs/windmill/compare/v1.629.0...v1.629.1) (2026-02-10)
+
+
+### Bug Fixes
+
+* remove unecessary drop index on labeled_jobs_on_jobs ([0803164](https://github.com/windmill-labs/windmill/commit/08031640a02ebd5971793942e8534d69f4f71d28))
+
+## [1.629.0](https://github.com/windmill-labs/windmill/compare/v1.628.3...v1.629.0) (2026-02-09)
+
+
+### Features
+
+* customer portal extra workspace stats ([#7841](https://github.com/windmill-labs/windmill/issues/7841)) ([153dd32](https://github.com/windmill-labs/windmill/commit/153dd32187a3e32e3f26ab88b62195a0f9a359b9))
+
+
+### Bug Fixes
+
+* adapt mysql and ruby test assertions ([477832d](https://github.com/windmill-labs/windmill/commit/477832dbeeafb88fd16c174d5d1df8ed042e6f31))
+* add missing :name param to groups/is_owner route ([fa53a87](https://github.com/windmill-labs/windmill/commit/fa53a87107158c9e8a7e5b522242b0076a78ce46))
+* **backend:** prevent sqs hanging ([#7857](https://github.com/windmill-labs/windmill/issues/7857)) ([a3fc27b](https://github.com/windmill-labs/windmill/commit/a3fc27b23224aef2949c19f7c123d28e6cfaf968))
+* box push() future to prevent stack overflow in nested async chains ([67c8aef](https://github.com/windmill-labs/windmill/commit/67c8aef9faea5afe8ce330b477f16b4aed1779a5))
+* **frontend:** reorganize workspace settings ([#7788](https://github.com/windmill-labs/windmill/issues/7788)) ([dd42184](https://github.com/windmill-labs/windmill/commit/dd421845ba148bba70bcbafbc6a39f3012eb037c))
+* improve scheduling reliability in extreme pool contention conditions ([#7825](https://github.com/windmill-labs/windmill/issues/7825)) ([bbb397b](https://github.com/windmill-labs/windmill/commit/bbb397b6ad954052f0bd33cc4ff8897eed66e4db))
+* improve tracing behavior with NO_PROXY ([4cce13f](https://github.com/windmill-labs/windmill/commit/4cce13f5228a05da1bbce43bed7e856ce0bcf979))
+* incorrect raw app public workspaceStore derived ([edb0d4a](https://github.com/windmill-labs/windmill/commit/edb0d4a05da567b3b0be5d94c9b2856d68ecb0ff))
+* increase test thread stack size to 8MB in CI ([5548098](https://github.com/windmill-labs/windmill/commit/5548098e083af76a0b7d6f645a5458592d9c8ddc))
+* install mold+clang in Docker for cargo linker config ([99bc383](https://github.com/windmill-labs/windmill/commit/99bc383f9e94a415ff1dcef1c45ccc4c8dab1a9e))
+* make V8 runtime init idempotent and auto-initialize before isolate creation ([aa9f3da](https://github.com/windmill-labs/windmill/commit/aa9f3da429da92a059aaabb28481d33b8dacd37b))
+* parse Python datetime.datetime and datetime.date type annotations ([#7856](https://github.com/windmill-labs/windmill/issues/7856)) ([ff70a4e](https://github.com/windmill-labs/windmill/commit/ff70a4e9d105cac58c0fb0aba8fbec9875533aa4))
+* prevent V8 SIGSEGV by serializing isolate creation and fixing use-after-free ([05106d7](https://github.com/windmill-labs/windmill/commit/05106d7deeda92b7ae0e1708554f6dcb088c4a08))
+* reduce DB pool contention by eliminating dual-connection patterns ([#7861](https://github.com/windmill-labs/windmill/issues/7861)) ([4343b73](https://github.com/windmill-labs/windmill/commit/4343b73485843c3b482c21e60052f171ada9b843))
+* remove mold linker config that breaks Docker builds ([fea0954](https://github.com/windmill-labs/windmill/commit/fea0954f20f9f7c5a43b25b23df530faeac94999))
+* restart after empty branchone + improve UI ([#7838](https://github.com/windmill-labs/windmill/issues/7838)) ([b1d6ac9](https://github.com/windmill-labs/windmill/commit/b1d6ac91bd3af073feac0b31d97f7b4414d8786e))
+* use unprotected V8 platform to prevent SIGSEGV on x86_64 Linux ([90d0103](https://github.com/windmill-labs/windmill/commit/90d010347c65086b17f9802dd9a7d2da90dc68eb))
+* wmill workspace list to list local profiles ([#7843](https://github.com/windmill-labs/windmill/issues/7843)) ([f924a82](https://github.com/windmill-labs/windmill/commit/f924a8268461c49a0fec26e3216ec9546601b8de))
+
 ## [1.628.3](https://github.com/windmill-labs/windmill/compare/v1.628.2...v1.628.3) (2026-02-06)


@@ -1,5 +1,5 @@
 ARG DEBIAN_IMAGE=debian:bookworm-slim
-ARG RUST_IMAGE=rust:1.90-slim-bookworm
+ARG RUST_IMAGE=rust:1.93-slim-bookworm

 FROM debian:bookworm-slim AS nsjail

@@ -97,7 +97,7 @@ ARG features=""

 COPY --from=planner /windmill/recipe.json recipe.json

-RUN apt-get update && apt-get install -y libxml2-dev=2.9.* libxmlsec1-dev=1.2.* libkrb5-dev libsasl2-dev clang=1:14.0-55.* libclang-dev=1:14.0-55.* cmake=3.25.* && \
+RUN apt-get update && apt-get install -y libxml2-dev=2.9.* libxmlsec1-dev=1.2.* libkrb5-dev libsasl2-dev libcurl4-openssl-dev clang=1:14.0-55.* libclang-dev=1:14.0-55.* cmake=3.25.* && \
    apt-get clean && \
    rm -rf /var/lib/apt/lists/*

@@ -12,8 +12,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -17,8 +17,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -30,8 +30,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,21 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        INSERT INTO email_trigger (\n            path, local_part, workspaced_local_part, script_path,\n            is_flow, workspace_id, edited_by, email\n        )\n        VALUES ($1, $2, $3, $4, $5, $6, $7, $8)\n        ",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Varchar",
+        "Varchar",
+        "Bool",
+        "Varchar",
+        "Bool",
+        "Varchar",
+        "Varchar",
+        "Varchar"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "1074c6c98e6a0c83ac04172a39abea21c793f58947051d39931d4da0868a1d77"
+}
@@ -122,8 +122,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -40,8 +40,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -1,6 +1,6 @@
 {
  "db_name": "PostgreSQL",
-  "query": "\n        WITH job_info AS (\n            SELECT id, kind::text AS kind, parent_job\n            FROM v2_job\n            WHERE id = $1\n        )\n        SELECT\n            q.id AS \"id!\",\n            s.flow_status,\n            q.suspend AS \"suspend!\",\n            j.runnable_path AS script_path,\n            (ji.kind IN ('flow', 'flowpreview')) AS \"is_flow_level!\"\n        FROM job_info ji\n        JOIN v2_job_queue q ON q.id = CASE\n            WHEN ji.kind IN ('flow', 'flowpreview') THEN ji.id\n            ELSE ji.parent_job\n        END\n        JOIN v2_job j ON j.id = q.id\n        JOIN v2_job_status s ON s.id = q.id\n        FOR UPDATE OF q\n        ",
+  "query": "\n        WITH job_info AS (\n            SELECT id, kind::text AS kind, parent_job\n            FROM v2_job\n            WHERE id = $1\n        )\n        SELECT\n            q.id AS \"id!\",\n            s.flow_status,\n            q.suspend AS \"suspend!\",\n            j.runnable_path AS script_path,\n            j.permissioned_as_email AS email,\n            (ji.kind IN ('flow', 'flowpreview')) AS \"is_flow_level!\"\n        FROM job_info ji\n        JOIN v2_job_queue q ON q.id = CASE\n            WHEN ji.kind IN ('flow', 'flowpreview') THEN ji.id\n            ELSE ji.parent_job\n        END\n        JOIN v2_job j ON j.id = q.id\n        JOIN v2_job_status s ON s.id = q.id\n        FOR UPDATE OF q\n        ",
  "describe": {
    "columns": [
      {
@@ -25,6 +25,11 @@
      },
      {
        "ordinal": 4,
+        "name": "email",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 5,
        "name": "is_flow_level!",
        "type_info": "Bool"
      }
@@ -39,8 +44,9 @@
      true,
      false,
      true,
+      false,
      null
    ]
  },
-  "hash": "66e66da2ed6eace5d7ec2a41a7b11ae255f5dc212d1ff41c2905b303c8c13b18"
+  "hash": "1a0ab65bbf2751f702fc696c1e32a7dd9524cdd806be1ad8e9ab88d4c88d3f82"
 }
@@ -1,15 +0,0 @@
-{
-  "db_name": "PostgreSQL",
-  "query": "WITH inserted_concurrency_counter AS (\n                INSERT INTO concurrency_counter (concurrency_id, job_uuids) \n                VALUES ($1, '{}'::jsonb)\n                ON CONFLICT DO NOTHING\n            )\n            INSERT INTO concurrency_key(key, job_id) VALUES ($1, $2)",
-  "describe": {
-    "columns": [],
-    "parameters": {
-      "Left": [
-        "Varchar",
-        "Uuid"
-      ]
-    },
-    "nullable": []
-  },
-  "hash": "1bceaf6e9f25745b7f70128054ca81d68f3d56d4782e99e05b4f1cb362683514"
-}
@@ -0,0 +1,17 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "UPDATE email_trigger SET script_path = $1, local_part = $2 WHERE workspace_id = $3 AND path = $4",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Varchar",
+        "Varchar",
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "2031c5138a785367e5127180ccb6734efa41ee6cb3b4819c1c517798b2b23e4a"
+}
@@ -1,6 +1,6 @@
 {
  "db_name": "PostgreSQL",
-  "query": "\n                                SELECT\n                                    flow_version.id AS version,\n                                    flow_version.value->>'early_return' as early_return, \n                                    flow_version.value->>'preprocessor_module' IS NOT NULL as has_preprocessor, \n                                    (flow_version.value->>'chat_input_enabled')::boolean as chat_input_enabled, \n                                    flow.tag, \n                                    flow.dedicated_worker, \n                                    flow.on_behalf_of_email, \n                                    flow.edited_by\n                                FROM \n                                    flow_version\n                                INNER JOIN flow\n                                    ON flow.path = flow_version.path AND\n                                       flow.workspace_id = flow_version.workspace_id\n                                WHERE \n                                    flow_version.workspace_id = $1 AND\n                                    flow_version.path = $2 AND\n                                    flow_version.id = $3\n                            ",
+  "query": "\n                                SELECT\n                                    flow_version.id AS version,\n                                    flow_version.value->>'early_return' as early_return,\n                                    flow_version.value->>'preprocessor_module' IS NOT NULL as has_preprocessor,\n                                    (flow_version.value->>'chat_input_enabled')::boolean as chat_input_enabled,\n                                    flow.tag,\n                                    flow.dedicated_worker,\n                                    flow.on_behalf_of_email,\n                                    flow.edited_by\n                                FROM\n                                    flow_version\n                                INNER JOIN flow\n                                    ON flow.path = flow_version.path AND\n                                       flow.workspace_id = flow_version.workspace_id\n                                WHERE\n                                    flow_version.workspace_id = $1 AND\n                                    flow_version.path = $2 AND\n                                    flow_version.id = $3\n                            ",
  "describe": {
    "columns": [
      {
@@ -62,5 +62,5 @@
      false
    ]
  },
-  "hash": "a7468e9054beed88636786c5495ac3b9d9a6086ae6212ad9237b39a0346d7d26"
+  "hash": "209dc4c1b91eeab1c12ffcd9f9e16f315c689ca772c736b333dcdf07c8086087"
 }
@@ -0,0 +1,85 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n            SELECT id, runnable_path, trigger_kind AS \"trigger_kind: String\",\n                   args AS \"args: sqlx::types::Json<serde_json::Value>\"\n            FROM v2_job\n            WHERE runnable_path = $1\n              AND trigger_kind = $2::job_trigger_kind\n            ORDER BY created_at DESC\n            LIMIT 1\n            ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "id",
+        "type_info": "Uuid"
+      },
+      {
+        "ordinal": 1,
+        "name": "runnable_path",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 2,
+        "name": "trigger_kind: String",
+        "type_info": {
+          "Custom": {
+            "name": "job_trigger_kind",
+            "kind": {
+              "Enum": [
+                "webhook",
+                "http",
+                "websocket",
+                "kafka",
+                "email",
+                "nats",
+                "schedule",
+                "app",
+                "ui",
+                "postgres",
+                "sqs",
+                "gcp",
+                "mqtt",
+                "nextcloud"
+              ]
+            }
+          }
+        }
+      },
+      {
+        "ordinal": 3,
+        "name": "args: sqlx::types::Json<serde_json::Value>",
+        "type_info": "Jsonb"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        {
+          "Custom": {
+            "name": "job_trigger_kind",
+            "kind": {
+              "Enum": [
+                "webhook",
+                "http",
+                "websocket",
+                "kafka",
+                "email",
+                "nats",
+                "schedule",
+                "app",
+                "ui",
+                "postgres",
+                "sqs",
+                "gcp",
+                "mqtt",
+                "nextcloud"
+              ]
+            }
+          }
+        }
+      ]
+    },
+    "nullable": [
+      false,
+      true,
+      true,
+      true
+    ]
+  },
+  "hash": "212553c83e4dcdc6d045eb2fe2dadbb2860ce52d37a56b2861de1215260ecff8"
+}
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -40,8 +40,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -16,8 +16,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -11,8 +11,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -11,8 +11,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -15,8 +15,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -12,8 +12,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,23 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT value FROM variable WHERE workspace_id = $1 AND path = $2 AND is_secret = true",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "value",
+        "type_info": "Varchar"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      false
+    ]
+  },
+  "hash": "302bc55d0c227c5b12458ccde6569c4b531ff494d1ede0a655872ae05215f8a6"
+}
@@ -0,0 +1,16 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "UPDATE variable SET value = $1 WHERE workspace_id = $2 AND path = $3 AND is_secret = true",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Varchar",
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "33fff66efe810ad7e92b36ca9b287938437182d7817387707e800519d9f5bafc"
+}
@@ -1,6 +1,6 @@
 {
  "db_name": "PostgreSQL",
-  "query": "DELETE FROM raw_app WHERE path = $1 AND workspace_id = $2",
+  "query": "DELETE FROM mqtt_trigger WHERE workspace_id = $1 AND path = $2",
  "describe": {
    "columns": [],
    "parameters": {
@@ -11,5 +11,5 @@
    },
    "nullable": []
  },
-  "hash": "b2b2b7251be2b80207f47b10eeff78d61c84161caaf16b8fd25d82b97aac1186"
+  "hash": "3481e65196e500ad914f10b87884c19d8a3636ae955788c3366365194fe2ef57"
 }
@@ -12,8 +12,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -16,8 +16,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -52,8 +51,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,15 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "DELETE FROM email_trigger WHERE workspace_id = $1 AND path = $2",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "40971d637c5b4d2af8e67872722880058cc067fca5e807ab3e1ed17d180cb7f7"
+}
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -30,8 +30,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,20 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "DELETE FROM job_result_stream_v2\n         WHERE job_id NOT IN (SELECT id FROM v2_job_queue)\n           AND job_id NOT IN (\n               SELECT id FROM v2_job_completed\n               WHERE completed_at > NOW() - INTERVAL '60 seconds'\n           )\n         RETURNING job_id",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "job_id",
+        "type_info": "Uuid"
+      }
+    ],
+    "parameters": {
+      "Left": []
+    },
+    "nullable": [
+      false
+    ]
+  },
+  "hash": "454a611a5a162b2ace137c139bd5383bc7fe142c515dac3edd47991839485e51"
+}
@@ -0,0 +1,46 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n            SELECT\n                workspace_id,\n                name,\n                rules as \"rules: ProtectionRules\",\n                bypass_groups,\n                bypass_users\n            FROM workspace_protection_rule\n            WHERE workspace_id = $1\n            ORDER BY name\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "workspace_id",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 1,
+        "name": "name",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 2,
+        "name": "rules: ProtectionRules",
+        "type_info": "Int4"
+      },
+      {
+        "ordinal": 3,
+        "name": "bypass_groups",
+        "type_info": "TextArray"
+      },
+      {
+        "ordinal": 4,
+        "name": "bypass_users",
+        "type_info": "TextArray"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text"
+      ]
+    },
+    "nullable": [
+      false,
+      false,
+      false,
+      false,
+      false
+    ]
+  },
+  "hash": "4cfb35e423a75ca2701f03d5a30a7c0778af5e548254f3e0f29004d7f2058eef"
+}
@@ -37,8 +37,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -32,8 +32,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -71,8 +70,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -16,8 +16,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,15 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "WITH inserted_concurrency_counter AS (\n                INSERT INTO concurrency_counter (concurrency_id, job_uuids)\n                VALUES ($1, '{}'::jsonb)\n                ON CONFLICT DO NOTHING\n            )\n            INSERT INTO concurrency_key(key, job_id) VALUES ($1, $2)",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Varchar",
+        "Uuid"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "5a9cf9cc229f7b7ddbee2485cda4e9f7a91240a00f10d24d3f28d5b722f68768"
+}
@@ -245,8 +245,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -1,6 +1,6 @@
 {
  "db_name": "PostgreSQL",
-  "query": "\n            SELECT j.id AS \"id!\", COALESCE(s.flow_status, s.workflow_as_code_status) as flow_status, q.suspend AS \"suspend!\", j.runnable_path as script_path\n            FROM v2_job_queue q JOIN v2_job j USING (id) LEFT JOIN v2_job_status s USING (id)\n            WHERE j.id = $1\n            ",
+  "query": "\n            SELECT j.id AS \"id!\", COALESCE(s.flow_status, s.workflow_as_code_status) as flow_status, q.suspend AS \"suspend!\", j.runnable_path as script_path, j.permissioned_as_email as email\n            FROM v2_job_queue q JOIN v2_job j USING (id) LEFT JOIN v2_job_status s USING (id)\n            WHERE j.id = $1\n            ",
  "describe": {
    "columns": [
      {
@@ -22,6 +22,11 @@
        "ordinal": 3,
        "name": "script_path",
        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 4,
+        "name": "email",
+        "type_info": "Varchar"
      }
    ],
    "parameters": {
@@ -33,8 +38,9 @@
      false,
      null,
      false,
-      true
+      true,
+      false
    ]
  },
-  "hash": "485dc289a61a06595acae28d4968f3b6b2aeb6a8aee863dc999d6c8d58397814"
+  "hash": "5c6e158aee5db3c4bf41a0aedfa5d6c73f5e04ebfd8703dc631bc49f2e797dd4"
 }
@@ -0,0 +1,39 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT delivery_type AS \"delivery_type: String\",\n               delivery_config\n        FROM gcp_trigger\n        WHERE workspace_id = $1 AND path = $2\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "delivery_type: String",
+        "type_info": {
+          "Custom": {
+            "name": "delivery_mode",
+            "kind": {
+              "Enum": [
+                "push",
+                "pull"
+              ]
+            }
+          }
+        }
+      },
+      {
+        "ordinal": 1,
+        "name": "delivery_config",
+        "type_info": "Jsonb"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      false,
+      true
+    ]
+  },
+  "hash": "60a666a7cffce2d7631682095ccfd31e99997e88374496d4800eaa7b5152a464"
+}
@@ -0,0 +1,18 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n            UPDATE workspace_protection_rule\n            SET rules = $1, bypass_groups = $2, bypass_users = $3\n            WHERE workspace_id = $4 AND name = $5\n        ",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Int4",
+        "TextArray",
+        "TextArray",
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "65b12bed9438900518b20dc268d71a2dba6ec66aee2971faef76b6ed56a05b6f"
+}
@@ -35,8 +35,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -29,8 +29,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -40,8 +40,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,15 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "DELETE FROM workspace_protection_rule WHERE workspace_id = $1 AND name = $2",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "7ddc2c3f1ce74f9b7acdd51b94431386e7782c52251cf094e06ddb198a958b43"
+}
@@ -27,8 +27,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,29 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT script_path, local_part FROM email_trigger WHERE workspace_id = $1 AND path = $2",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "script_path",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 1,
+        "name": "local_part",
+        "type_info": "Varchar"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      false,
+      false
+    ]
+  },
+  "hash": "8002f7f1521846056278f18e8b003fe48a4d3d827ac8b212e0f3d3bc2ed42f37"
+}
@@ -0,0 +1,23 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT COUNT(*) FROM email_trigger WHERE workspace_id = $1 AND path = $2",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "count",
+        "type_info": "Int8"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      null
+    ]
+  },
+  "hash": "8364505b9a4d0d6f7406e4a5425360682ac2295bbf6746c7641141ed7bf47bf6"
+}
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -1,17 +0,0 @@
-{
-  "db_name": "PostgreSQL",
-  "query": "INSERT INTO raw_app\n            (workspace_id, path, summary, extra_perms, data)\n            VALUES ($1, $2, $3, '{}', $4)",
-  "describe": {
-    "columns": [],
-    "parameters": {
-      "Left": [
-        "Varchar",
-        "Varchar",
-        "Varchar",
-        "Text"
-      ]
-    },
-    "nullable": []
-  },
-  "hash": "84bbd11f7bb0c65dcfb2e12038b8a9cb51d303480ac3c5f8a5e833a53c40ed9b"
-}
@@ -35,8 +35,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,62 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT mqtt_resource_path, client_version AS \"client_version: String\",\n               script_path, mode AS \"mode: String\"\n        FROM mqtt_trigger\n        WHERE workspace_id = $1 AND path = $2\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "mqtt_resource_path",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 1,
+        "name": "client_version: String",
+        "type_info": {
+          "Custom": {
+            "name": "mqtt_client_version",
+            "kind": {
+              "Enum": [
+                "v3",
+                "v5"
+              ]
+            }
+          }
+        }
+      },
+      {
+        "ordinal": 2,
+        "name": "script_path",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 3,
+        "name": "mode: String",
+        "type_info": {
+          "Custom": {
+            "name": "trigger_mode",
+            "kind": {
+              "Enum": [
+                "enabled",
+                "disabled",
+                "suspended"
+              ]
+            }
+          }
+        }
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      false,
+      false,
+      false,
+      false
+    ]
+  },
+  "hash": "899a162192d93c7fb7d47d38f4fb0fadcafc2bb0c61efa8ee496af7252d18270"
+}
@@ -0,0 +1,22 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        INSERT INTO kafka_trigger (\n            path, kafka_resource_path, topics, group_id,\n            script_path, is_flow, workspace_id, edited_by, email\n        )\n        VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)\n        ",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Varchar",
+        "Varchar",
+        "VarcharArray",
+        "Varchar",
+        "Varchar",
+        "Bool",
+        "Varchar",
+        "Varchar",
+        "Varchar"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "8c3cc09c1bbb6209467c75723dd02e97dddb99789422012e85e86c3151a9f2e9"
+}
@@ -17,8 +17,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -17,8 +17,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -32,8 +32,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -30,8 +30,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,23 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "SELECT script_path FROM mqtt_trigger WHERE workspace_id = $1 AND path = $2",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "script_path",
+        "type_info": "Varchar"
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      false
+    ]
+  },
+  "hash": "a086a5fa28dcff80911c7e5de73f204fc42625e58b967b0376ff7b382e38fa11"
+}
@@ -155,8 +155,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -185,8 +185,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,84 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT gcp_resource_path, topic_id, subscription_id,\n               delivery_type AS \"delivery_type: String\",\n               subscription_mode AS \"subscription_mode: String\",\n               mode AS \"mode: String\"\n        FROM gcp_trigger\n        WHERE workspace_id = $1 AND path = $2\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "gcp_resource_path",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 1,
+        "name": "topic_id",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 2,
+        "name": "subscription_id",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 3,
+        "name": "delivery_type: String",
+        "type_info": {
+          "Custom": {
+            "name": "delivery_mode",
+            "kind": {
+              "Enum": [
+                "push",
+                "pull"
+              ]
+            }
+          }
+        }
+      },
+      {
+        "ordinal": 4,
+        "name": "subscription_mode: String",
+        "type_info": {
+          "Custom": {
+            "name": "gcp_subscription_mode",
+            "kind": {
+              "Enum": [
+                "create_update",
+                "existing"
+              ]
+            }
+          }
+        }
+      },
+      {
+        "ordinal": 5,
+        "name": "mode: String",
+        "type_info": {
+          "Custom": {
+            "name": "trigger_mode",
+            "kind": {
+              "Enum": [
+                "enabled",
+                "disabled",
+                "suspended"
+              ]
+            }
+          }
+        }
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      false,
+      false,
+      false,
+      false,
+      false,
+      false
+    ]
+  },
+  "hash": "a80a17cda8ad722a97f16526d8576b76c7377066a06dba98a2921a68928aa644"
+}
@@ -1,6 +1,6 @@
 {
  "db_name": "PostgreSQL",
-  "query": "SELECT EXISTS(SELECT 1 FROM raw_app WHERE path = $1 AND workspace_id = $2)",
+  "query": "SELECT EXISTS(SELECT 1 FROM workspace_protection_rule WHERE workspace_id = $1 AND name = $2)",
  "describe": {
    "columns": [
      {
@@ -19,5 +19,5 @@
      null
    ]
  },
-  "hash": "c4b3ab3d87f158b20f0557f78c6307c50620425aeb43636e19931c142b5ce0d7"
+  "hash": "b1b26cb02dcc0748c63411c933e5e6bdfe82466134ba28408a530e22c66656de"
 }
@@ -160,8 +160,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -18,8 +18,8 @@
      "Left": []
    },
    "nullable": [
-      false,
-      true
+      true,
+      false
    ]
  },
  "hash": "b3dbdfb50ee8118bdaed3164b210cb549a34b96554ae1872355b90304f5dcb76"
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -59,7 +59,9 @@
                "failure",
                "command",
                "approval",
-                "preprocessor"
+                "preprocessor",
+                "schedule_handler_old",
+                "dynamic_skip"
              ]
            }
          }
@@ -21,8 +21,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -72,8 +71,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -1,14 +0,0 @@
-{
-  "db_name": "PostgreSQL",
-  "query": "DELETE FROM job_result_stream_v2 WHERE job_id = $1",
-  "describe": {
-    "columns": [],
-    "parameters": {
-      "Left": [
-        "Uuid"
-      ]
-    },
-    "nullable": []
-  },
-  "hash": "bb46e5dcf5490ef3511faa131ad5693dedf34366e51044ddf30695995d194090"
-}
@@ -105,8 +105,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -31,8 +31,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -0,0 +1,20 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "DELETE FROM job_perms\nWHERE job_id NOT IN (SELECT id FROM v2_job_queue)\nRETURNING job_id",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "job_id",
+        "type_info": "Uuid"
+      }
+    ],
+    "parameters": {
+      "Left": []
+    },
+    "nullable": [
+      false
+    ]
+  },
+  "hash": "c825fa5c6e287068aeaad994c0b42b8ad59b9129f032c6b918c27426ab304f2b"
+}
@@ -0,0 +1,52 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        SELECT local_part, workspaced_local_part, script_path,\n               mode AS \"mode: String\"\n        FROM email_trigger\n        WHERE workspace_id = $1 AND path = $2\n        ",
+  "describe": {
+    "columns": [
+      {
+        "ordinal": 0,
+        "name": "local_part",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 1,
+        "name": "workspaced_local_part",
+        "type_info": "Bool"
+      },
+      {
+        "ordinal": 2,
+        "name": "script_path",
+        "type_info": "Varchar"
+      },
+      {
+        "ordinal": 3,
+        "name": "mode: String",
+        "type_info": {
+          "Custom": {
+            "name": "trigger_mode",
+            "kind": {
+              "Enum": [
+                "enabled",
+                "disabled",
+                "suspended"
+              ]
+            }
+          }
+        }
+      }
+    ],
+    "parameters": {
+      "Left": [
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": [
+      false,
+      false,
+      false,
+      false
+    ]
+  },
+  "hash": "cabef30aa1e308bc656660c4ac0d3e77b020de05465f81a4fb4b0c07bd0d7439"
+}
@@ -11,8 +11,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -12,8 +12,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -105,8 +105,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -25,8 +25,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -1,6 +1,6 @@
 {
  "db_name": "PostgreSQL",
-  "query": "SELECT COUNT(*) as count FROM variable WHERE is_secret = true AND value != 'CLEARED'",
+  "query": "SELECT COUNT(*) FROM variable WHERE is_secret = true",
  "describe": {
    "columns": [
      {
@@ -16,5 +16,5 @@
      null
    ]
  },
-  "hash": "052d42b46d5faba6b41f1fdcbf6a012db51b9e5a255ec0da9a8a0999d668d336"
+  "hash": "d7d11b2c288fa0282539edde0c5450e4b5f8355821617b6c1ce3db64f6ceaf69"
 }
@@ -0,0 +1,18 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n            INSERT INTO workspace_protection_rule (workspace_id, name, rules, bypass_groups, bypass_users)\n            VALUES ($1, $2, $3, $4, $5)\n        ",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Varchar",
+        "Varchar",
+        "Int4",
+        "TextArray",
+        "TextArray"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "dbf2982f43577999dec0c488dfb67f56e5bd0e5fbf8da5132f6fc5a282d2b0e1"
+}
@@ -0,0 +1,21 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "\n        INSERT INTO websocket_trigger (\n            path, url, script_path, is_flow, workspace_id,\n            edited_by, email, initial_messages\n        )\n        VALUES ($1, $2, $3, $4, $5, $6, $7, $8)\n        ",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Varchar",
+        "Varchar",
+        "Varchar",
+        "Bool",
+        "Varchar",
+        "Varchar",
+        "Varchar",
+        "JsonbArray"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "e485c82978d10379c6d1b7cd850f3bf764e6c5bf775f3d710ba36a79f5e424eb"
+}
@@ -185,8 +185,7 @@
                "sqs",
                "gcp",
                "mqtt",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -31,8 +31,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -21,8 +21,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -72,8 +71,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -24,8 +24,7 @@
                "mqtt",
                "gcp",
                "default_email",
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -21,8 +21,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -72,8 +71,7 @@
            "name": "native_trigger_service",
            "kind": {
              "Enum": [
-                "nextcloud",
-                "google"
+                "nextcloud"
              ]
            }
          }
@@ -1,6 +1,6 @@
 {
  "db_name": "PostgreSQL",
-  "query": "VACUUM v2_job, v2_job_completed, job_result_stream_v2, job_stats, job_logs, concurrency_key, log_file, metrics",
+  "query": "VACUUM v2_job, v2_job_completed, job_result_stream_v2, job_stats, job_logs, job_perms, concurrency_key, log_file, metrics",
  "describe": {
    "columns": [],
    "parameters": {
@@ -8,5 +8,5 @@
    },
    "nullable": []
  },
-  "hash": "f8ac5379ecfbff7b8ae75c821680737b249a64c8d9e8f7dbcc46fce98e874571"
+  "hash": "f0070b36f7c4fc84dc9c23bb6c73d8ba80993a28b2c2e5df70968acf6d7cebe4"
 }
@@ -0,0 +1,16 @@
+{
+  "db_name": "PostgreSQL",
+  "query": "UPDATE mqtt_trigger SET script_path = $1 WHERE workspace_id = $2 AND path = $3",
+  "describe": {
+    "columns": [],
+    "parameters": {
+      "Left": [
+        "Varchar",
+        "Text",
+        "Text"
+      ]
+    },
+    "nullable": []
+  },
+  "hash": "f0eb9d49021668673880aa20227c24a130cada07fba3f43e32d904fde97106d3"
+}
@@ -1,6 +1,6 @@
 {
  "db_name": "PostgreSQL",
-  "query": "SELECT COUNT(*) FROM raw_app WHERE workspace_id = $1",
+  "query": "SELECT COUNT(*) FROM mqtt_trigger WHERE workspace_id = $1 AND path = $2",
  "describe": {
    "columns": [
      {
@@ -11,6 +11,7 @@
    ],
    "parameters": {
      "Left": [
+        "Text",
        "Text"
      ]
    },
@@ -18,5 +19,5 @@
      null
    ]
  },
-  "hash": "3b5295a7c4b99aefa52c9a8ae1e0dd12bf4a0be1bf755caf7a1fa863e7950562"
+  "hash": "f149d740301a65a62664fd407abe89c972e50837b6c54ac7a3ccd5f60ca05d3c"
 }
@@ -1,6 +1,6 @@
 [package]
 name = "windmill"
-version = "1.628.3"
+version = "1.630.2"
 authors.workspace = true
 edition.workspace = true

@@ -59,7 +59,7 @@ members = [
 exclude = ["./windmill-duckdb-ffi-internal"]

 [workspace.package]
-version = "1.628.3"
+version = "1.630.2"
 authors = ["Ruben Fiszel <ruben@windmill.dev>"]
 edition = "2021"

@@ -229,6 +229,12 @@ axum.workspace = true
 serde.workspace = true
 windmill-api-client.workspace = true
 tempfile.workspace = true
+rumqttc.workspace = true
+rdkafka.workspace = true
+async-nats.workspace = true
+aws-sdk-sqs.workspace = true
+aws-config.workspace = true
+aws-credential-types.workspace = true


 [workspace.dependencies]
@@ -413,7 +419,7 @@ const_format = { version = "0.2.35", features = ["rust_1_64", "rust_1_51"] }
 const-str = "0.5"
 constant_time_eq = "0.3.1"
 rsa = "^0"
-aes-gcm = "^0"
+aes-gcm = "0.10.3"
 async_zip = { version = "0.0.17", features = ["tokio", "tokio-fs", "deflate", "chrono"] }
 once_cell = "1.17.1"
 dashmap = "6.1.0"
@@ -463,7 +469,7 @@ nkeys = "0.4.4"
 nu-parser = { version = "0.101.0", default-features = false }
 globset = "0.4.16"
 croner = "2.2.0"
-rmcp = { version = "^0", features = ["client", "transport-streamable-http-client", "transport-streamable-http-client-reqwest"] }
+rmcp = { version = "=0.15.0", features = ["client", "transport-streamable-http-client", "transport-streamable-http-client-reqwest"] }
 rquickjs = { version = "0.8", features = ["futures", "parallel", "macro"] }
 process-wrap = { version = "8.2.1", features = ["tokio1"] }

@@ -1,21 +0,0 @@
-#!/bin/bash
-
-# This script outputs all features except private. Usage :
-#  > cargo build --features $(./all_features_oss.sh)
-
-# Path to the Cargo.toml file
-CARGO_TOML_PATH="./Cargo.toml"
-
-# Extract features from Cargo.toml and output them separated by commas
-if [[ -f "$CARGO_TOML_PATH" ]]; then
-    grep -A 100 '\[features\]' "$CARGO_TOML_PATH" | \
-    sed -n '/\[features\]/,/^\[/p' | \
-    grep -E '^[a-zA-Z0-9_-]+' | \
-    grep -v 'private' | \
-    grep -v 'benchmark' | \
-    cut -d' ' -f1 | \
-    paste -sd ',' -
-else
-    echo "Cargo.toml not found at $CARGO_TOML_PATH"
-    exit 1
-fi
@@ -1 +1 @@
-cd2713671bc7ac5762302704ee4ecb81e023301f
+de9ff0d258f5a1a3739d9693531bad3972ddfd22
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Ruben Fiszelandrubenfiszel	0ad4f0232e	chore(main): release 1.630.2 (#7897 ) * chore(main): release 1.630.2 * Apply automatic changes --------- Co-authored-by: rubenfiszel <275584+rubenfiszel@users.noreply.github.com>	2026-02-11 00:29:42 +00:00
Ruben Fiszel	02f4359ba4	bump rust to 1.93.0	2026-02-11 00:02:24 +00:00
Ruben Fiszel	1a109a7797	fix: bump rust version from 1.90.0 to 1.93.0	2026-02-10 23:55:36 +00:00
Ruben Fiszelandrubenfiszel	3d888c8135	chore(main): release 1.630.1 (#7896 ) * chore(main): release 1.630.1 * Apply automatic changes --------- Co-authored-by: rubenfiszel <275584+rubenfiszel@users.noreply.github.com>	2026-02-10 23:45:51 +00:00
Ruben Fiszel	1c4a15bc26	fix compile	2026-02-10 23:34:15 +00:00
Alexander Petric	7147dde511	fix: enforce self-approval check on flow resume owner endpoint (#7886 ) * fix: enforce self-approval check on flow resume owner endpoint * sqlx * fix test * fix mcp fields * test self aproval allowed + other user approves flow	2026-02-10 23:14:40 +00:00
centdix	3b1b4051eb	adapt for rmcp update (#7895 )	2026-02-10 23:11:19 +00:00
centdix	c3be7376fb	internal: fix git actions (#7892 ) * fix git actions * fix * rm	2026-02-10 23:11:03 +00:00
Ruben Fiszelandrubenfiszel	2bafaca40d	chore(main): release 1.630.0 (#7867 ) * chore(main): release 1.630.0 * Apply automatic changes --------- Co-authored-by: rubenfiszel <275584+rubenfiszel@users.noreply.github.com>	2026-02-10 17:58:58 +00:00
Alexander PetricandRuben Fiszel	1037932608	restore worker-hours occupancy calculation for CU billing (#7887 ) * fix: restore worker-hours occupancy calculation for CU billing * ee ref --------- Co-authored-by: Ruben Fiszel <ruben@windmill.dev>	2026-02-10 17:50:55 +00:00
Ruben Fiszel Claude Opus 4.6 Alexander Petric	4c87e7ac2e	fix: retry js eval up to 3 times on timeout from slow DB (#7890 ) When eval_timeout_quickjs hits the timeout (typically due to slow DB result retrieval), retry up to 2 more times with a 5s interval between attempts. Non-timeout errors are returned immediately without retry. Also extract the eval timeout duration as EVAL_TIMEOUT_MS const (set to 20000ms, up from 10000ms) in windmill-jseval. Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com> Co-authored-by: Alexander Petric <alpetric@users.noreply.github.com>	2026-02-10 17:50:41 +00:00
centdixandClaude Opus 4.5	6272cd17a4	feat(aiagent): add prompt caching for Anthropic models (#7878 ) * feat: add prompt caching support for Anthropic API Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * exclude vertex --------- Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>	2026-02-10 17:42:49 +00:00
wendrul	6b10416eba	add test for protection rulesets (#7889 )	2026-02-10 17:35:38 +00:00
Diego Imbert	8a96c90e4b	Fix AgGrid modal event handlers + openedModalRow output (#7888 ) * Fix broken event handlers in AgGrid Modal buttons * Add openedModalRow output in AgGrid * clear openedModalRow	2026-02-10 17:35:26 +00:00
hugocasa	1150eec757	fix(backend): correct early return with stream + prevent delta miss (#7872 )	2026-02-10 17:20:14 +00:00
Tammo Ippen	5d29124d9f	Add 'on_behalf_of_email' to flow inputs schema (#7854 )	2026-02-10 17:00:09 +00:00
wendrul	2851b6b7ca	feat: restriction rulesets for workspaces (#7879 )	2026-02-10 16:49:25 +00:00
wendrul	25255f9526	Fix nix flake (missing curl for compiling all features) (#7881 )	2026-02-10 16:46:06 +00:00
centdixandClaude Opus 4.6	a7e269f9f3	feat: add workspace search and runnable details tools to AI chat modes (#7874 ) * feat: add workspace search and runnable details tools to navigator mode Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * fix: correct uFuzzy search result indexing in workspace search uFuzzy.search() returns [idxs, info, order] where order contains indices into idxs, not into the original haystack. The code was using order values directly as array indices, returning wrong results. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * refactor: mutualize search_workspace and get_runnable_details tools - Move search_workspace tool def + implementation into shared.ts as createSearchWorkspaceTool() factory, used by navigator and flow modes - Move get_runnable_details tool into shared.ts as createGetRunnableDetailsTool() factory, used by navigator, flow, and script modes - Replace flow mode's scripts-only search_scripts with search_workspace that searches both scripts and flows - Add search_workspace and get_runnable_details to script mode - Remove duplicated WorkspaceScriptsSearch class from flow/core.ts Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * fix: add get_runnable_details to flow mode system prompt Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * fix: add hard limit on runnable content passed to AI context Truncate script content and flow value at 20k chars in get_runnable_details to avoid flooding the context window. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * fix: make search_workspace type param required for strict schema OpenAI strict mode requires all properties in required array. Make type a required enum ('all', 'scripts', 'flows') instead of optional. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * cleaning * nit * cleaning * refactor: use shared createSearchWorkspaceTool in app mode Replace app mode's local list_workspace_runnables tool with the shared createSearchWorkspaceTool() factory, consistent with navigator, flow, and script modes. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * search by keyword * cleaning * fix: document search_workspace and get_runnable_details in script mode system prompt Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * fix: add get_runnable_details tool to app mode Without it, the AI can find scripts/flows but can't inspect their schema/content when configuring backend runnables with correct inputs. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * fix: race condition in WorkspaceRunnablesSearch workspace caching Track scriptsWorkspace and flowsWorkspace separately instead of a single shared workspace field. Previously, initScripts could update the shared workspace field, causing initFlows to skip re-fetching when the workspace changed (it saw the workspace already matched), returning stale data. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-10 16:44:07 +00:00
Ruben FiszelandClaude Opus 4.6	af02e200a5	add benchmark variants and fix db pool connection starvation (#7884 ) Add new BENCHMARK_KIND variants (sequentialflow, scriptlogs, concurrencylimit, concurrencykey, mixed, mixed_no_cc) for targeted performance testing. Fix shared iteration counting across workers using a global atomic counter. Add job_perms inserts and queue diagnostics for benchmark mode. Move db connection setup to dedicated module and drop the initial connection pool before creating the main one, preventing connection starvation when PostgreSQL max_connections is low. Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-10 16:41:47 +00:00
wendrul	40096e45e3	fix typing of app value for npm check (#7883 )	2026-02-10 16:28:50 +00:00
Diego Imbert	fdd7d63311	Fix crash on invalid AI provider (#7880 ) * Fix crash on invalid AI provider * nit handle null	2026-02-10 16:27:48 +00:00
centdix Claude Opus 4.5 Ruben Fiszel	03eb16a7c6	feat(mcp): add endpoint tools for scripts, flows, apps, and jobs (#7859 ) * add endpoints * feat: add MCP tools for script/flow/app CRUD and run endpoints with field filtering Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * fix: convert enum arrays to description text in MCP tool schemas Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * feat: auto-detect and rename conflicting parameter names across MCP tool schemas Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * fix: use two-pass approach in convert_enums_to_descriptions to preserve dict ordering Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * feat: add MCP instructions to createScript, runScriptByPath, and runFlowByPath Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * feat: add query param exclusion for MCP tools, slim down run endpoints Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * fix: preserve additional top-level keys in allOf schema flattening Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * refactor: replace x-mcp-tool-exclude-query-params with x-mcp-tool-include-query-params Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * fix: replace empty {} schemas with valid JSON Schema draft 2020-12 equivalents Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * fix: revert openapi value:{} changes, sanitize empty schemas in generator instead Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com> Co-authored-by: Ruben Fiszel <ruben@windmill.dev>	2026-02-10 11:30:39 +00:00
Luigi	8e19f9652d	Added serpapi import handling (#7871 ) Added the handling for serpapi import. The name of the Python library to be installed is google-search-results. Source: https://pypi.org/project/google-search-results/	2026-02-10 09:59:35 +00:00
Ruben FiszelandClaude Opus 4.6	45980f0220	resolve Windows build warnings treated as errors (#7870 ) * fix: resolve Windows build warnings treated as errors - Gate UV_PATH import behind #[cfg(unix)] in python_versions.rs - Remove unused tokio::time::sleep import in worker.rs (use fully qualified path) - Fix unused `file` variable warnings in ansible_executor.rs on Windows Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * ci: add Windows cargo check workflow Runs cargo check with ee_windows features on push to backend/** using the blacksmith-16vcpu-windows-2025 runner. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * ci: add cargo check step to Windows build, remove separate check workflow Add a cargo check step with -D warnings before the full build to fail fast on any warnings. Remove the separate windows-check.yml workflow. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-10 09:58:56 +00:00
hugocasa	8363ff1eee	feat: download encrypted usage (#7804 )	2026-02-10 09:50:24 +00:00
Ruben FiszelandClaude Opus 4.6	cf596f370a	fix: gate Permissions import behind #[cfg(unix)] for Windows build Move `use std::fs::Permissions` and `use std::os::unix::fs::PermissionsExt` inside the #[cfg(unix)] block to avoid unused import error on Windows. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-10 09:02:09 +00:00
Ruben Fiszelandrubenfiszel	b12304d834	chore(main): release 1.629.1 (#7862 ) * chore(main): release 1.629.1 * Apply automatic changes --------- Co-authored-by: rubenfiszel <275584+rubenfiszel@users.noreply.github.com>	2026-02-10 08:44:44 +00:00
Ruben FiszelandClaude Opus 4.6	b5f8d931bd	ci: add libcurl4-openssl-dev to backend-test workflow Required by rdkafka-sys 4.10.0 which unconditionally includes curl/curl.h. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-10 08:39:45 +00:00
Ruben FiszelandClaude Opus 4.6	f927c673b5	ci: improve Windows builds with faster runner, caching, and 3h timeout - Switch to blacksmith-16vcpu-windows-2025 runner - Replace deprecated actions-rs/toolchain with actions-rust-lang/setup-rust-toolchain with cargo caching - Increase build timeout from 90min to 180min Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-10 08:31:27 +00:00
Ruben Fiszel	4f653ca957	adapt to libkafka-changes	2026-02-10 08:06:06 +00:00
Ruben Fiszel	08031640a0	fix: remove unecessary drop index on labeled_jobs_on_jobs	2026-02-10 08:02:38 +00:00
Ruben Fiszelandrubenfiszel	244c09fcd7	chore(main): release 1.629.0 (#7844 ) * chore(main): release 1.629.0 * Apply automatic changes --------- Co-authored-by: rubenfiszel <275584+rubenfiszel@users.noreply.github.com>	2026-02-09 23:03:21 +00:00
Ruben Fiszel	1456f73c16	nit test	2026-02-09 22:51:57 +00:00
Ruben Fiszel	4343b73485	fix: reduce DB pool contention by eliminating dual-connection patterns (#7861 )	2026-02-09 22:48:29 +00:00
Ruben FiszelandClaude Opus 4.6	b4b3edb64d	nit test Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-09 21:13:52 +00:00
Ruben Fiszel	4631e58c66	test-thread 10	2026-02-09 20:50:23 +00:00
Ruben FiszelandClaude Opus 4.6	eb827ce5e8	nit backend tests Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-09 18:28:01 +00:00
Guilhem	dd421845ba	fix(frontend): reorganize workspace settings (#7788 ) * Add vertical nav bar to workspace settings * harmonize settings content titles * remove sidebar icons * add background to sidebar * nit user section * EEonly display * Workspace settings general design * Add schema validation and dirty detection * Put critical alerts in a separated tab * separate error success handler * only enable save when there is some changes * Fix dirty detection for deployment UI * Only enable save button when changes for datatables ws storage * Add setting footer component * Use new footer setting for saving configs * nit * apply setting footer * improve save button * nit * nit * nit * make ws app use same pattern as other tabs * Separate scrolling between sidebar and content * Gather error handlers * use universal save button for object storage * Title sentence case * nit * nit * improve dirty config logic * nit * nit * clean dead code * Use settings footer for deployment settings * Git sync settings * move tabs * fix dirty stats of error handlers * nit * nit	2026-02-09 18:22:22 +00:00
hugocasa	b1d6ac91bd	fix: restart after empty branchone + improve UI (#7838 ) * improve flow restart UI * fix: better restart UI + fix restart avec empty branch one	2026-02-09 18:13:18 +00:00
Ruben FiszelandClaude Opus 4.6	894d8a94f8	reuse existing transaction in push to reduce pool pressure (#7858 ) * fix: reuse existing transaction in push instead of acquiring new connection In push_inner, fetch_authed_from_permissioned_as was acquiring a new connection from the pool to fetch job permissions, even though a transaction was already open. Use fetch_authed_from_permissioned_as_conn with the existing transaction instead, reducing pool pressure when many jobs are pushed concurrently. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * improve contention * improve contention --------- Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-09 18:07:33 +00:00
Ruben Fiszel	7d37a83d4f	nit backend tests	2026-02-09 18:05:14 +00:00
Ruben Fiszel	750926d8da	fix form on small screens	2026-02-09 17:57:05 +00:00
Ruben Fiszel	0b0696459e	fix missing overflow on form	2026-02-09 17:53:16 +00:00
hugocasaandwindmill-internal-app[bot]	a3fc27b232	fix(backend): prevent sqs hanging (#7857 ) * fix(backend): prevent sqs hanging * fix dep * chore: update ee-repo-ref to b1916254951d504db136759f4150a40d3a88a638 This commit updates the EE repository reference after PR #410 was merged in windmill-ee-private. Previous ee-repo-ref: a5d74260b942eb208cd4b963bd63d74ad5240931 New ee-repo-ref: b1916254951d504db136759f4150a40d3a88a638 Automated by sync-ee-ref workflow. --------- Co-authored-by: windmill-internal-app[bot] <windmill-internal-app[bot]@users.noreply.github.com>	2026-02-09 16:25:18 +00:00
Ruben FiszelandClaude Opus 4.6	ff70a4e9d1	fix: parse Python datetime.datetime and datetime.date type annotations (#7856 ) * fix: parse Python datetime.datetime and datetime.date type annotations correctly The Python parser only matched ExprKind::Name for type annotations, so `datetime.datetime` (an Attribute expression) silently fell through to Typ::Unknown and no datetime picker was shown in the UI. - Extend parse_expr to resolve `datetime.` attribute access (alongside the existing `wmill.` handling) - Add Typ::Date variant for `datetime.date` → JSON schema format "date" - Update python worker to import and convert `date.fromisoformat()` - Update argSigToJsonSchemaType, AI types, schema validation, and SQL datatype wasm for the new Date variant Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * all * all * all * all --------- Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-09 15:17:26 +00:00
centdixandClaude Opus 4.6	76377a00a6	internal: flake nix devshell clang/mold/openssl compatibility (#7855 ) * fix: flake nix devshell clang/mold/openssl compatibility - Add mold linker to buildInputs - Pin cargo linker to clang 18 (stdenv's clang 21 causes SIGSEGV with mold) - Embed OpenSSL rpath via rustflags instead of LD_LIBRARY_PATH to avoid leaking into git/ssh Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> * more fixes * fix --------- Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-09 14:03:22 +00:00
Ruben FiszelandClaude Opus 4.6	dc5e69481d	test: add end-to-end trigger integration tests and DB CRUD tests Add 7 #[ignore] e2e tests (one per trigger type) that fire real messages to external services and verify job creation in v2_job. Also add 9 DB-level CRUD tests for MQTT, GCP, and Email triggers. Includes helper shell scripts in tests/fixtures/ to start/stop each external service (MQTT, WebSocket, Postgres replication, Kafka, NATS, SQS via LocalStack, GCP Pub/Sub emulator). Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-09 12:28:25 +00:00