diff --git a/backend/windmill-worker/src/bun_executor.rs b/backend/windmill-worker/src/bun_executor.rs index 094755cdb0..6b54576a0c 100644 --- a/backend/windmill-worker/src/bun_executor.rs +++ b/backend/windmill-worker/src/bun_executor.rs @@ -625,21 +625,22 @@ pub async fn pull_codebase(w_id: &str, id: &str, job_dir: &str) -> Result<()> { ))); } } else { + #[cfg(not(all(feature = "enterprise", feature = "parquet")))] return Err(error::Error::ExecutionErr( "codebase is an EE feature".to_string(), )); - } - #[cfg(all(feature = "enterprise", feature = "parquet"))] - if let Some(os) = object_store { - let dirs_splitted = bun_cache_path.split("/").collect_vec(); - std::fs::create_dir_all(dirs_splitted[..dirs_splitted.len() - 1].join("/"))?; + #[cfg(all(feature = "enterprise", feature = "parquet"))] + if let Some(os) = object_store { + let dirs_splitted = bun_cache_path.split("/").collect_vec(); + std::fs::create_dir_all(dirs_splitted[..dirs_splitted.len() - 1].join("/"))?; - let bytes = attempt_fetch_bytes(os, &path).await?; - tracing::info!("loading {bun_cache_path} from object store"); + let bytes = attempt_fetch_bytes(os, &path).await?; + tracing::info!("loading {bun_cache_path} from object store"); - std::fs::write(&bun_cache_path, &bytes)?; - extract_saved_codebase(job_dir, &bun_cache_path, is_tar, &dst, false)?; + std::fs::write(&bun_cache_path, &bytes)?; + extract_saved_codebase(job_dir, &bun_cache_path, is_tar, &dst, false)?; + } } }