kalugin66/windmill
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix codebase & bundles on EE

Browse Source
This commit is contained in:
Ruben Fiszel
2025-03-04 18:53:06 +01:00
parent 2cb3e5741c
commit 6504540fb7
1 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
backend/windmill-worker/src/bun_executor.rs
View File

@@ -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)?;
}
}
}