mirror of
https://github.com/windmill-labs/windmill.git
synced 2026-09-09 00:04:10 +00:00
allow ce to run codebase bundles preview
This commit is contained in:
@@ -4453,8 +4453,8 @@ async fn run_bundle_preview_script(
|
||||
path: preview.path,
|
||||
language: preview.language.unwrap_or(ScriptLang::Deno),
|
||||
lock: preview.lock,
|
||||
concurrent_limit: None, // TODO(gbouv): once I find out how to store limits in the content of a script, should be easy to plug limits here
|
||||
concurrency_time_window_s: None, // TODO(gbouv): same as above
|
||||
concurrent_limit: None,
|
||||
concurrency_time_window_s: None,
|
||||
cache_ttl: None,
|
||||
dedicated_worker: preview.dedicated_worker,
|
||||
custom_concurrency_key: None,
|
||||
|
||||
@@ -2028,10 +2028,16 @@ async fn handle_queued_job(
|
||||
| JobKind::FlowPreview
|
||||
| JobKind::Flow
|
||||
| JobKind::FlowDependencies,
|
||||
None,
|
||||
) => Some(cache::job::fetch_preview(db, &job.id, raw_lock, raw_code, raw_flow).await?),
|
||||
x,
|
||||
) => match x.map(|x| x.0) {
|
||||
None | Some(PREVIEW_IS_CODEBASE_HASH) | Some(PREVIEW_IS_TAR_CODEBASE_HASH) => {
|
||||
Some(cache::job::fetch_preview(db, &job.id, raw_lock, raw_code, raw_flow).await?)
|
||||
}
|
||||
_ => None,
|
||||
},
|
||||
_ => None,
|
||||
};
|
||||
|
||||
let cached_res_path = if job.cache_ttl.is_some() {
|
||||
Some(cached_result_path(db, &client.get_authed().await, &job, preview_data.as_ref()).await)
|
||||
} else {
|
||||
|
||||
Reference in New Issue
Block a user