diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs index 9399d7f8dc..89233a999b 100644 --- a/backend/windmill-worker/src/worker.rs +++ b/backend/windmill-worker/src/worker.rs @@ -268,6 +268,20 @@ async fn copy_cache_from_bucket_as_tar(bucket: &str) -> bool { return r; } +async fn check_if_bucket_syncable(bucket: &str) -> bool { + match Command::new("rclone") + .arg("lsf") + .arg(format!(":s3,env_auth=true:{bucket}/NOSYNC")) + + .arg("-vv") + .arg("--fast-list") + .stdin(Stdio::null()) + .stdout(Stdio::null()) + .output() + .await; + return true; +} + async fn move_tmp_cache_to_cache() -> Result<()> { tokio::fs::remove_dir_all(ROOT_CACHE_DIR).await?; tokio::fs::rename(ROOT_TMP_CACHE_DIR, ROOT_CACHE_DIR).await?; diff --git a/frontend/src/lib/components/ScriptBuilder.svelte b/frontend/src/lib/components/ScriptBuilder.svelte index 8c6d7fb62d..8f557462ab 100644 --- a/frontend/src/lib/components/ScriptBuilder.svelte +++ b/frontend/src/lib/components/ScriptBuilder.svelte @@ -31,6 +31,7 @@ let advancedOpen = false let editor: Editor | undefined = undefined + let scriptEditor: ScriptEditor | undefined = undefined export function setCode(code: string): void { editor?.setCode(code) @@ -79,6 +80,7 @@ template: 'pgsql' | 'mysql' | 'script' ) { script.content = initialCode(language, kind, template) + scriptEditor?.inferSchema(script.content, language) } async function editScript(leave: boolean): Promise { @@ -331,6 +333,7 @@ { @@ -78,7 +78,7 @@ }) try { - await inferArgs(lang, code, schema) + await inferArgs(nlang ?? lang, code, schema) validCode = true } catch (e) { validCode = false @@ -146,12 +146,7 @@ -
{ - inferSchema(code) - }} - > +
{#key lang}