all

CHANGELOG.md

@@ -1,13 +1,5 @@
 # Changelog
 
-## [1.473.1](https://github.com/windmill-labs/windmill/compare/v1.473.0...v1.473.1) (2025-03-03)
-
-
-### Bug Fixes
-
-* **backend:** copilot info exists_ai_resource ([#5415](https://github.com/windmill-labs/windmill/issues/5415)) ([844edd1](https://github.com/windmill-labs/windmill/commit/844edd1117bc5fdcc108adf53aec3974a7c66384))
-* improve cancel performance ([fba9e7e](https://github.com/windmill-labs/windmill/commit/fba9e7ef03b91d3e2c78ff833ddcc5207b7436d2))
-
 ## [1.473.0](https://github.com/windmill-labs/windmill/compare/v1.472.1...v1.473.0) (2025-03-03)
 
 

backend/Cargo.lock

@@ -4279,9 +4279,9 @@ dependencies = [
 
 [[package]]
 name = "dyn-clone"
-version = "1.0.19"
+version = "1.0.18"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1c7a8fb8a9fbf66c1f703fe16184d10ca0ee9d23be5b4436400408ba54a95005"
+checksum = "feeef44e73baff3a26d371801df019877a9866a8c493d315ab00177843314f35"
 
 [[package]]
 name = "dyn-iter"
@@ -5767,9 +5767,9 @@ dependencies = [
 
 [[package]]
 name = "httparse"
-version = "1.10.1"
+version = "1.10.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6dbf3de79e51f3d586ab4cb9d5c3e2c14aa28ed23d180cf89b4df0454a69cc87"
+checksum = "f2d708df4e7140240a16cd6ab0ab65c972d7433ab77819ea693fde9c43811e2a"
 
 [[package]]
 name = "httpdate"
@@ -6686,7 +6686,7 @@ checksum = "c0ff37bd590ca25063e35af745c343cb7a0271906fb7b37e4813e8f79f00268d"
 dependencies = [
  "bitflags 2.9.0",
  "libc",
- "redox_syscall 0.5.10",
+ "redox_syscall 0.5.9",
 ]
 
 [[package]]
@@ -8128,7 +8128,7 @@ checksum = "1e401f977ab385c9e4e3ab30627d6f26d00e2c73eef317493c4ec6d468726cf8"
 dependencies = [
  "cfg-if",
  "libc",
- "redox_syscall 0.5.10",
+ "redox_syscall 0.5.9",
  "smallvec",
  "windows-targets 0.52.6",
 ]
@@ -8346,18 +8346,18 @@ dependencies = [
 
 [[package]]
 name = "pin-project"
-version = "1.1.10"
+version = "1.1.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "677f1add503faace112b9f1373e43e9e054bfdd22ff1a63c1bc485eaec6a6a8a"
+checksum = "dfe2e71e1471fe07709406bf725f710b02927c9c54b2b5b2ec0e8087d97c327d"
 dependencies = [
  "pin-project-internal",
 ]
 
 [[package]]
 name = "pin-project-internal"
-version = "1.1.10"
+version = "1.1.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6e918e4ff8c4549eb882f14b3a4bc8c8bc93de829416eacf579f1207a8fbf861"
+checksum = "f6e859e6e5bd50440ab63c47e3ebabc90f26251f7c73c3d3e837b74a1cc3fa67"
 dependencies = [
  "proc-macro2",
  "quote",
@@ -9203,9 +9203,9 @@ dependencies = [
 
 [[package]]
 name = "redox_syscall"
-version = "0.5.10"
+version = "0.5.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0b8c0c260b63a8219631167be35e6a988e9554dbd323f8bd08439c8ed1302bd1"
+checksum = "82b568323e98e49e2a0899dcee453dd679fae22d69adf9b11dd508d1549b7e2f"
 dependencies = [
  "bitflags 2.9.0",
 ]
@@ -13453,7 +13453,7 @@ version = "1.5.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "372d5b87f58ec45c384ba03563b03544dc5fadc3983e434b286913f5b4a9bb6d"
 dependencies = [
- "redox_syscall 0.5.10",
+ "redox_syscall 0.5.9",
  "wasite",
  "web-sys",
 ]
@@ -13497,7 +13497,7 @@ checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"
 
 [[package]]
 name = "windmill"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "axum",
@@ -13540,7 +13540,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-api"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "argon2",
@@ -13636,7 +13636,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-api-client"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "base64 0.22.1",
  "chrono",
@@ -13654,7 +13654,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-audit"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "chrono",
  "serde",
@@ -13667,7 +13667,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-autoscaling"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "serde",
@@ -13681,7 +13681,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-common"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "async-stream",
@@ -13742,7 +13742,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-git-sync"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "regex",
  "serde",
@@ -13756,7 +13756,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-indexer"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "bytes",
@@ -13779,7 +13779,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-macros"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "itertools 0.14.0",
  "lazy_static",
@@ -13791,7 +13791,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "convert_case 0.6.0",
  "serde",
@@ -13800,7 +13800,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-bash"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "lazy_static",
@@ -13812,7 +13812,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-csharp"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "serde_json",
@@ -13824,7 +13824,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-go"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "gosyn",
@@ -13836,7 +13836,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-graphql"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "lazy_static",
@@ -13848,7 +13848,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-php"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "itertools 0.14.0",
@@ -13859,7 +13859,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-py"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "itertools 0.14.0",
@@ -13870,7 +13870,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-py-imports"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "async-recursion",
@@ -13890,7 +13890,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-rust"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "convert_case 0.6.0",
@@ -13907,7 +13907,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-sql"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "lazy_static",
@@ -13919,7 +13919,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-ts"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "lazy_static",
@@ -13937,7 +13937,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-wasm"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "getrandom 0.2.15",
@@ -13959,7 +13959,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-parser-yaml"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "serde_json",
@@ -13969,7 +13969,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-queue"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "async-recursion",
@@ -14002,7 +14002,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-sql-datatype-parser-wasm"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "wasm-bindgen",
  "wasm-bindgen-test",
@@ -14012,7 +14012,7 @@ dependencies = [
 
 [[package]]
 name = "windmill-worker"
-version = "1.473.1"
+version = "1.473.0"
 dependencies = [
  "anyhow",
  "async-recursion",

backend/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "windmill"
-version = "1.473.1"
+version = "1.473.0"
 authors.workspace = true
 edition.workspace = true
 
@@ -30,7 +30,7 @@ members = [
 ]
 
 [workspace.package]
-version = "1.473.1"
+version = "1.473.0"
 authors = ["Ruben Fiszel <ruben@windmill.dev>"]
 edition = "2021"
 
@@ -59,7 +59,7 @@ flow_testing = ["windmill-worker/flow_testing"]
 openidconnect = ["windmill-api/openidconnect"]
 cloud = ["windmill-queue/cloud", "windmill-worker/cloud"]
 jemalloc = ["windmill-common/jemalloc", "dep:tikv-jemallocator", "dep:tikv-jemalloc-sys", "dep:tikv-jemalloc-ctl"]
-tantivy = ["dep:windmill-indexer", "windmill-api/tantivy", "windmill-indexer/enterprise", "windmill-indexer/parquet", "enterprise", "parquet"]
+tantivy = ["dep:windmill-indexer", "windmill-api/tantivy", "windmill-indexer/enterprise", "windmill-indexer/parquet", "windmill-common/tantivy", "enterprise", "parquet"]
 sqlx = ["windmill-worker/sqlx"]
 deno_core = ["windmill-worker/deno_core", "dep:deno_core", "dep:v8"]
 kafka = ["windmill-api/kafka"]

backend/src/main.rs

@@ -44,7 +44,7 @@ use windmill_common::{
     },
     scripts::ScriptLang,
     stats_ee::schedule_stats,
-    utils::{hostname, rd_string, Mode, GIT_VERSION},
+    utils::{hostname, rd_string, Mode, GIT_VERSION, MODE_AND_ADDONS},
     worker::{reload_custom_tags_setting, HUB_CACHE_DIR, TMP_DIR, TMP_LOGS_DIR, WORKER_GROUP},
     DB, METRICS_ENABLED,
 };
@@ -238,63 +238,12 @@ async fn windmill_main() -> anyhow::Result<()> {
 
     let hostname = hostname();
 
-    let mut enable_standalone_indexer: bool = false;
+    let mode_and_addons = MODE_AND_ADDONS.clone();
+    let mode = mode_and_addons.mode;
 
-    let mode = std::env::var("MODE")
-        .map(|x| x.to_lowercase())
-        .map(|x| {
-            if &x == "server" {
-                println!("Binary is in 'server' mode");
-                Mode::Server
-            } else if &x == "worker" {
-                tracing::info!("Binary is in 'worker' mode");
-                #[cfg(windows)]
-                {
-                    println!("It is highly recommended to use the agent mode instead on windows (MODE=agent) and to pass a BASE_INTERNAL_URL");
-                }
-                Mode::Worker
-            } else if &x == "agent" {
-                println!("Binary is in 'agent' mode");
-                if std::env::var("BASE_INTERNAL_URL").is_err() {
-                    panic!("BASE_INTERNAL_URL is required in agent mode")
-                }
-                if std::env::var("JOB_TOKEN").is_err() {
-                    println!("JOB_TOKEN is not passed, hence workers will still need to create permissions for each job and the DATABASE_URL needs to be of a role that can INSERT into the job_perms table")
-                }
-
-                #[cfg(not(feature = "enterprise"))]
-                {
-                    panic!("Agent mode is only available in the EE, ignoring...");
-                }
-                #[cfg(feature = "enterprise")]
-                Mode::Agent
-            } else if &x == "indexer" {
-                tracing::info!("Binary is in 'indexer' mode");
-                #[cfg(not(feature = "tantivy"))]
-                {
-                    eprintln!("Cannot start the indexer because tantivy is not included in this binary/image. Make sure you are using the EE image if you want to access the full text search features.");
-                    panic!("Indexer mode requires compiling with the tantivy feature flag.");
-                }
-                #[cfg(feature = "tantivy")]
-                Mode::Indexer
-            } else if &x == "standalone+search"{
-                    enable_standalone_indexer = true;
-                    println!("Binary is in 'standalone' mode with search enabled");
-                    Mode::Standalone
-            }
-            else {
-                if &x != "standalone" {
-                    eprintln!("mode not recognized, defaulting to standalone: {x}");
-                } else {
-                    println!("Binary is in 'standalone' mode");
-                }
-                Mode::Standalone
-            }
-        })
-        .unwrap_or_else(|_| {
-            tracing::info!("Mode not specified, defaulting to standalone");
-            Mode::Standalone
-        });
+    if mode == Mode::Standalone {
+        println!("Running in standalone mode");
+    }
 
     #[cfg(all(not(target_env = "msvc"), feature = "jemalloc"))]
     println!("jemalloc enabled");
@@ -537,8 +486,7 @@ Windmill Community Edition {GIT_VERSION}
             .expect("could not create initial server dir");
 
         #[cfg(feature = "tantivy")]
-        let should_index_jobs =
-            mode == Mode::Indexer || (enable_standalone_indexer && mode == Mode::Standalone);
+        let should_index_jobs = mode == Mode::Indexer || mode_and_addons.indexer;
 
         reload_indexer_config(&db).await;
 

backend/windmill-api/openapi.yaml

@@ -1,7 +1,7 @@
 openapi: "3.0.3"
 
 info:
-  version: 1.473.1
+  version: 1.473.0
   title: Windmill API
 
   contact:

backend/windmill-api/src/scripts.rs

@@ -18,7 +18,6 @@ use crate::{
     webhook_util::{WebhookMessage, WebhookShared},
     HTTP_CLIENT,
 };
-#[cfg(all(feature = "enterprise", feature = "parquet"))]
 use axum::extract::Multipart;
 
 use axum::{
@@ -42,7 +41,6 @@ use std::{
 use windmill_audit::audit_ee::audit_log;
 use windmill_audit::ActionKind;
 
-#[cfg(all(feature = "enterprise", feature = "parquet"))]
 use windmill_common::error::to_anyhow;
 
 use windmill_common::{
@@ -358,12 +356,6 @@ fn hash_script(ns: &NewScript) -> i64 {
     dh.finish() as i64
 }
 
-#[cfg(not(all(feature = "enterprise", feature = "parquet")))]
-async fn create_snapshot_script() -> Result<(StatusCode, String)> {
-    Err(Error::BadRequest("Upgrade to EE to use bundle".to_string()))
-}
-
-#[cfg(all(feature = "enterprise", feature = "parquet"))]
 async fn create_snapshot_script(
     authed: ApiAuthed,
     Extension(user_db): Extension<UserDB>,
@@ -404,12 +396,35 @@ async fn create_snapshot_script(
             })?;
 
             uploaded = true;
+            let path = windmill_common::s3_helpers::bundle(&w_id, &hash);
+
+            if &windmill_common::utils::MODE_AND_ADDONS.mode
+                == &windmill_common::utils::Mode::Standalone
+            {
+                std::fs::create_dir_all(format!(
+                    "{}/script_bundle/{}",
+                    windmill_common::worker::ROOT_CACHE_NOMOUNT_DIR,
+                    w_id
+                ))?;
+                windmill_common::worker::write_file(
+                    windmill_common::worker::ROOT_CACHE_NOMOUNT_DIR,
+                    &path,
+                    &String::from_utf8_lossy(&data),
+                )?;
+                return Ok((StatusCode::CREATED, format!("{}", script_hash.unwrap())));
+            }
+
+            #[cfg(not(all(feature = "enterprise", feature = "parquet")))]
+            {
+                return Err(Error::ExecutionErr("codebase is an EE feature".to_string()));
+            }
+
+            #[cfg(all(feature = "enterprise", feature = "parquet"))]
             if let Some(os) = windmill_common::s3_helpers::OBJECT_STORE_CACHE_SETTINGS
                 .read()
                 .await
                 .clone()
             {
-                let path = windmill_common::s3_helpers::bundle(&w_id, &hash);
                 if let Err(e) = os
                     .put(&object_store::path::Path::from(path.clone()), data.into())
                     .await

backend/windmill-api/src/workspaces.rs

@@ -796,7 +796,7 @@ async fn get_copilot_info(
 
     let (ai_provider, exists_ai_resource) = if let Some(ai_resource) = record.ai_resource {
         let ai_resource = serde_json::from_value::<AIResource>(ai_resource)?;
-        (Some(ai_resource.provider), ai_resource.path.is_some())
+        (Some(ai_resource.provider), true)
     } else {
         (None, false)
     };

backend/windmill-common/Cargo.toml

@@ -8,6 +8,7 @@ edition.workspace = true
 default = []
 enterprise = []
 jemalloc = ["dep:tikv-jemalloc-ctl"]
+tantivy = []
 prometheus = ["dep:prometheus"]
 loki = ["dep:tracing-loki"]
 benchmark = []

backend/windmill-common/src/utils.rs

@@ -53,6 +53,76 @@ lazy_static::lazy_static! {
             GIT_VERSION
         }
     ).unwrap_or(Version::new(0, 1, 0));
+
+
+    pub static ref MODE_AND_ADDONS: ModeAndAddons = {
+        let mut search_addon = false;
+        let mode = std::env::var("MODE")
+        .map(|x| x.to_lowercase())
+        .map(|x| {
+            if &x == "server" {
+                println!("Binary is in 'server' mode");
+                Mode::Server
+            } else if &x == "worker" {
+                tracing::info!("Binary is in 'worker' mode");
+                #[cfg(windows)]
+                {
+                    println!("It is highly recommended to use the agent mode instead on windows (MODE=agent) and to pass a BASE_INTERNAL_URL");
+                }
+                Mode::Worker
+            } else if &x == "agent" {
+                println!("Binary is in 'agent' mode");
+                if std::env::var("BASE_INTERNAL_URL").is_err() {
+                    panic!("BASE_INTERNAL_URL is required in agent mode")
+                }
+                if std::env::var("JOB_TOKEN").is_err() {
+                    println!("JOB_TOKEN is not passed, hence workers will still need to create permissions for each job and the DATABASE_URL needs to be of a role that can INSERT into the job_perms table")
+                }
+
+                #[cfg(not(feature = "enterprise"))]
+                {
+                    panic!("Agent mode is only available in the EE, ignoring...");
+                }
+                #[cfg(feature = "enterprise")]
+                Mode::Agent
+            } else if &x == "indexer" {
+                tracing::info!("Binary is in 'indexer' mode");
+                #[cfg(not(feature = "tantivy"))]
+                {
+                    eprintln!("Cannot start the indexer because tantivy is not included in this binary/image. Make sure you are using the EE image if you want to access the full text search features.");
+                    panic!("Indexer mode requires compiling with the tantivy feature flag.");
+                }
+                #[cfg(feature = "tantivy")]
+                Mode::Indexer
+            } else if &x == "standalone+search"{
+                search_addon = true;
+                    println!("Binary is in 'standalone' mode with search enabled");
+                    Mode::Standalone
+            }
+            else {
+                if &x != "standalone" {
+                    eprintln!("mode not recognized, defaulting to standalone: {x}");
+                } else {
+                    println!("Binary is in 'standalone' mode");
+                }
+                Mode::Standalone
+            }
+        })
+        .unwrap_or_else(|_| {
+            tracing::info!("Mode not specified, defaulting to standalone");
+            Mode::Standalone
+        });
+        ModeAndAddons {
+            indexer: search_addon,
+            mode,
+        }
+    };
+}
+
+#[derive(Clone)]
+pub struct ModeAndAddons {
+    pub indexer: bool,
+    pub mode: Mode,
 }
 
 #[derive(Deserialize, Clone)]

backend/windmill-common/src/worker.rs

@@ -104,6 +104,7 @@ lazy_static::lazy_static! {
     pub static ref DISABLE_FLOW_SCRIPT: bool = std::env::var("DISABLE_FLOW_SCRIPT").ok().is_some_and(|x| x == "1" || x == "true");
 }
 
+pub const ROOT_CACHE_NOMOUNT_DIR: &str = concatcp!(TMP_DIR, "/cache_nomount/");
 pub static MIN_VERSION_IS_LATEST: AtomicBool = AtomicBool::new(false);
 
 fn format_pull_query(peek: String) -> String {

backend/windmill-worker/src/bun_executor.rs

@@ -579,20 +579,22 @@ pub async fn generate_bun_bundle(
     Ok(())
 }
 
-#[cfg(all(feature = "enterprise", feature = "parquet"))]
 pub async fn pull_codebase(w_id: &str, id: &str, job_dir: &str) -> Result<()> {
     use crate::global_cache::extract_tar;
 
     let path = windmill_common::s3_helpers::bundle(&w_id, &id);
-    let bun_cache_path = format!("{}/{}", crate::ROOT_CACHE_NOMOUNT_DIR, path);
+    let bun_cache_path = format!(
+        "{}/{}",
+        windmill_common::worker::ROOT_CACHE_NOMOUNT_DIR,
+        path
+    );
     let is_tar = id.ends_with(".tar");
 
     let dst = format!(
         "{job_dir}/{}",
         if is_tar { "codebase.tar" } else { "main.js" }
     );
-    let dirs_splitted = bun_cache_path.split("/").collect_vec();
-    tokio::fs::create_dir_all(dirs_splitted[..dirs_splitted.len() - 1].join("/")).await?;
+
     if tokio::fs::metadata(&bun_cache_path).await.is_ok() {
         tracing::info!("loading {bun_cache_path} from cache");
         if is_tar {
@@ -604,35 +606,47 @@ pub async fn pull_codebase(w_id: &str, id: &str, job_dir: &str) -> Result<()> {
             #[cfg(windows)]
             std::os::windows::fs::symlink_dir(&bun_cache_path, &dst)?;
         }
-    } else if let Some(os) = windmill_common::s3_helpers::OBJECT_STORE_CACHE_SETTINGS
-        .read()
-        .await
-        .clone()
-    {
-        let bytes = attempt_fetch_bytes(os, &path).await?;
-
-        tokio::fs::write(&bun_cache_path, &bytes).await?;
-        if is_tar {
-            extract_tar(bytes, job_dir).await?;
-        } else {
-            #[cfg(unix)]
-            tokio::fs::symlink(bun_cache_path, dst).await?;
-
-            #[cfg(windows)]
-            std::os::windows::fs::symlink_dir(&bun_cache_path, &dst)?;
+    } else {
+        #[cfg(not(all(feature = "enterprise", feature = "parquet")))]
+        {
+            if &windmill_common::utils::MODE_AND_ADDONS.mode
+                == &windmill_common::utils::Mode::Standalone
+            {
+                return Err(error::Error::ExecutionErr(format!(
+                    "(standalone bundle test mode) could not find codebase at {bun_cache_path}"
+                )));
+            } else {
+                return Err(error::Error::ExecutionErr(
+                    "codebase is an EE feature".to_string(),
+                ));
+            }
         }
 
-        // extract_tar(bytes, job_dir).await?;
+        #[cfg(all(feature = "enterprise", feature = "parquet"))]
+        if let Some(os) = windmill_common::s3_helpers::OBJECT_STORE_CACHE_SETTINGS
+            .read()
+            .await
+            .clone()
+        {
+            let dirs_splitted = bun_cache_path.split("/").collect_vec();
+            tokio::fs::create_dir_all(dirs_splitted[..dirs_splitted.len() - 1].join("/")).await?;
+
+            let bytes = attempt_fetch_bytes(os, &path).await?;
+
+            tokio::fs::write(&bun_cache_path, &bytes).await?;
+            if is_tar {
+                extract_tar(bytes, job_dir).await?;
+            } else {
+                #[cfg(unix)]
+                tokio::fs::symlink(bun_cache_path, dst).await?;
+
+                #[cfg(windows)]
+                std::os::windows::fs::symlink_dir(&bun_cache_path, &dst)?;
+            }
+        }
     }
 
-    return Ok(());
-}
-
-#[cfg(not(all(feature = "enterprise", feature = "parquet")))]
-pub async fn pull_codebase(_w_id: &str, _id: &str, _job_dir: &str) -> Result<()> {
-    return Err(error::Error::ExecutionErr(
-        "codebase is an EE feature".to_string(),
-    ));
+    Ok(())
 }
 
 pub async fn prebundle_bun_script(
@@ -837,13 +851,6 @@ pub async fn handle_bun_job(
     let main_override = job.script_entrypoint_override.as_deref();
     let apply_preprocessor = !job.is_flow_step && job.preprocessed == Some(false);
 
-    #[cfg(not(feature = "enterprise"))]
-    if annotation.nodejs || annotation.npm {
-        return Err(error::Error::ExecutionErr(
-            "Nodejs / npm mode is an EE feature".to_string(),
-        ));
-    }
-
     if has_bundle_cache {
         let target;
         let symlink;

backend/windmill-worker/src/global_cache.rs

@@ -1,15 +1,12 @@
 // #[cfg(feature = "enterprise")]
 // use rand::Rng;
 
-#[cfg(all(feature = "enterprise", feature = "parquet"))]
 use tokio::time::Instant;
+use windmill_common::error;
 
 #[cfg(all(feature = "enterprise", feature = "parquet", unix))]
 use object_store::ObjectStore;
 
-#[cfg(all(feature = "enterprise", feature = "parquet"))]
-use windmill_common::error;
-
 #[cfg(all(feature = "enterprise", feature = "parquet", unix))]
 use std::sync::Arc;
 
@@ -109,7 +106,6 @@ pub async fn pull_from_tar(
     Ok(())
 }
 
-#[cfg(all(feature = "enterprise", feature = "parquet"))]
 pub async fn extract_tar(tar: bytes::Bytes, folder: &str) -> error::Result<()> {
     use bytes::Buf;
     use tokio::fs::{self};

backend/windmill-worker/src/python_executor.rs

@@ -96,23 +96,19 @@ pub enum PyVersion {
 }
 
 impl PyVersion {
-    pub async fn from_instance_version(job_id: &Uuid, w_id: &str, db: &Pool<Postgres>) -> Self {
-        let mut err = None;
-        let pyv = match INSTANCE_PYTHON_VERSION.read().await.clone() {
+    pub async fn from_instance_version() -> Self {
+        match INSTANCE_PYTHON_VERSION.read().await.clone() {
             Some(v) => PyVersion::from_string_with_dots(&v).unwrap_or_else(|| {
                 let v = PyVersion::default();
-                err = Some(format!("\nCannot parse INSTANCE_PYTHON_VERSION ({:?}), fallback to latest_stable ({v:?})", *INSTANCE_PYTHON_VERSION));
+                tracing::error!(
+                "Cannot parse INSTANCE_PYTHON_VERSION ({:?}), fallback to latest_stable ({v:?})",
+                *INSTANCE_PYTHON_VERSION
+            );
                 v
             }),
             // Use latest stable
             None => PyVersion::default(),
-        };
-
-        if let Some(msg) = err {
-            append_logs(job_id, w_id, &msg, db).await;
-            tracing::error!(msg);
         }
-        pyv
     }
     /// e.g.: `/tmp/windmill/cache/python_3xy`
     pub fn to_cache_dir(&self) -> String {
@@ -227,18 +223,9 @@ impl PyVersion {
 
         if let Err(ref e) = res {
             tracing::error!(
-                "worker_name: {worker_name}, w_id: {w_id}, job_id: {job_id}\n
+                "worker_name: {worker_name}, w_id: {w_id}, job_id: {job_id}\n 
                 Error while getting python from uv, falling back to system python: {e:?}"
             );
-            append_logs(
-                job_id,
-                w_id,
-                format!(
-                    "\nError while getting python from uv, falling back to system python: {e:?}"
-                ),
-                db,
-            )
-            .await;
         }
         res
     }
@@ -1443,7 +1430,7 @@ async fn handle_python_deps(
     let mut annotated_pyv = None;
     let mut annotated_pyv_numeric = None;
     let is_deployed = requirements_o.is_some();
-    let instance_pyv = PyVersion::from_instance_version(job_id, w_id, db).await;
+    let instance_pyv = PyVersion::from_instance_version().await;
     let annotations = windmill_common::worker::PythonAnnotations::parse(inner_content);
     let requirements = match requirements_o {
         Some(r) => r,

backend/windmill-worker/src/worker.rs

@@ -18,7 +18,7 @@ use windmill_common::{
     utils::WarnAfterExt,
     worker::{
         get_memory, get_vcpus, get_windmill_memory_usage, get_worker_memory_usage, write_file,
-        ROOT_CACHE_DIR, TMP_DIR,
+        ROOT_CACHE_DIR, ROOT_CACHE_NOMOUNT_DIR, TMP_DIR,
     },
 };
 
@@ -250,8 +250,6 @@ pub async fn create_token_for_owner(
     Ok(format!("jwt_{}", token))
 }
 
-pub const ROOT_CACHE_NOMOUNT_DIR: &str = concatcp!(TMP_DIR, "/cache_nomount/");
-
 pub const PY310_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "python_310");
 pub const PY311_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "python_311");
 pub const PY312_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "python_312");
@@ -274,6 +272,7 @@ pub const RUST_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "rust");
 pub const CSHARP_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "csharp");
 pub const BUN_CACHE_DIR: &str = concatcp!(ROOT_CACHE_NOMOUNT_DIR, "bun");
 pub const BUN_BUNDLE_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "bun");
+pub const BUN_CODEBASE_BUNDLE_CACHE_DIR: &str = concatcp!(ROOT_CACHE_NOMOUNT_DIR, "script_bundle");
 
 pub const GO_BIN_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "gobin");
 pub const POWERSHELL_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "powershell");
@@ -773,7 +772,7 @@ pub async fn run_worker(
             worker_dir.clone(),
         );
         tokio::spawn(async move {
-            if let Err(e) = PyVersion::from_instance_version(&Uuid::nil(), "", &db)
+            if let Err(e) = PyVersion::from_instance_version()
                 .await
                 .get_python(&Uuid::nil(), &mut 0, &db, &worker_name, "", &mut None)
                 .await

backend/windmill-worker/src/worker_lockfiles.rs

@@ -1701,7 +1701,7 @@ async fn python_dep(
 
     let final_version = annotated_pyv_numeric
         .and_then(|pyv| PyVersion::from_numeric(pyv))
-        .unwrap_or(PyVersion::from_instance_version(job_id, w_id, db).await);
+        .unwrap_or(PyVersion::from_instance_version().await);
 
     let req: std::result::Result<String, Error> = uv_pip_compile(
         job_id,

benchmarks/lib.ts

@@ -2,7 +2,7 @@ import { sleep } from "https://deno.land/x/sleep@v1.2.1/mod.ts";
 import * as windmill from "https://deno.land/x/windmill@v1.174.0/mod.ts";
 import * as api from "https://deno.land/x/windmill@v1.174.0/windmill-api/index.ts";
 
-export const VERSION = "v1.473.1";
+export const VERSION = "v1.473.0";
 
 export async function login(email: string, password: string): Promise<string> {
   return await windmill.UserService.login({

cli/main.ts

@@ -62,7 +62,7 @@ export {
 //   }
 // });
 
-export const VERSION = "1.473.1";
+export const VERSION = "1.473.0";
 
 const command = new Command()
   .name("wmill")

frontend/package-lock.json

@@ -1,12 +1,12 @@
 {
 	"name": "windmill-components",
-	"version": "1.473.1",
+	"version": "1.473.0",
 	"lockfileVersion": 3,
 	"requires": true,
 	"packages": {
 		"": {
 			"name": "windmill-components",
-			"version": "1.473.1",
+			"version": "1.473.0",
 			"license": "AGPL-3.0",
 			"dependencies": {
 				"@anthropic-ai/sdk": "^0.37.0",

frontend/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "windmill-components",
-	"version": "1.473.1",
+	"version": "1.473.0",
 	"scripts": {
 		"dev": "vite dev",
 		"build": "vite build",

lsp/Pipfile

@@ -4,8 +4,8 @@ verify_ssl = true
 name = "pypi"
 
 [packages]
-wmill = ">=1.473.1"
-wmill_pg = ">=1.473.1"
+wmill = ">=1.473.0"
+wmill_pg = ">=1.473.0"
 sendgrid = "*"
 mysql-connector-python = "*"
 pymongo = "*"

openflow.openapi.yaml

@@ -1,7 +1,7 @@
 openapi: "3.0.3"
 
 info:
-  version: 1.473.1
+  version: 1.473.0
   title: OpenFlow Spec
   contact:
     name: Ruben Fiszel

powershell-client/WindmillClient/WindmillClient.psd1

@@ -12,7 +12,7 @@
     RootModule        = 'WindmillClient.psm1'
 
     # Version number of this module.
-    ModuleVersion     = '1.473.1'
+    ModuleVersion     = '1.473.0'
 
     # Supported PSEditions
     # CompatiblePSEditions = @()

python-client/wmill/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "wmill"
-version = "1.473.1"
+version = "1.473.0"
 description = "A client library for accessing Windmill server wrapping the Windmill client API"
 license = "Apache-2.0"
 homepage = "https://windmill.dev"

python-client/wmill_pg/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "wmill-pg"
-version = "1.473.1"
+version = "1.473.0"
 description = "An extension client for the wmill client library focused on pg"
 license = "Apache-2.0"
 homepage = "https://windmill.dev"

typescript-client/jsr.json

@@ -1,6 +1,6 @@
 {
   "name": "@windmill/windmill",
-  "version": "1.473.1",
+  "version": "1.473.0",
   "exports": "./src/index.ts",
   "publish": {
     "exclude": ["!src", "./s3Types.ts", "./client.ts"]

typescript-client/package.json

@@ -1,7 +1,7 @@
 {
   "name": "windmill-client",
   "description": "Windmill SDK client for browsers and Node.js",
-  "version": "1.473.1",
+  "version": "1.473.0",
   "author": "Ruben Fiszel",
   "license": "Apache 2.0",
   "devDependencies": {

version.txt

@@ -1 +1 @@
-1.473.1
+1.473.0