From ae219eb3be49c560217e3966d841a20f63e6db68 Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Tue, 4 Apr 2023 09:29:08 +0200 Subject: [PATCH] create the first dirs properly --- backend/windmill-worker/src/worker.rs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs index dc97ed8e4f..2285ebe391 100644 --- a/backend/windmill-worker/src/worker.rs +++ b/backend/windmill-worker/src/worker.rs @@ -92,7 +92,10 @@ async fn copy_cache_from_bucket(bucket: &str, tx: Option>) { elapsed.elapsed().as_secs() ); - for x in [PIP_CACHE_DIR, DENO_CACHE_DIR, GO_CACHE_DIR] { + for x in + if !tx_is_some + { [PIP_CACHE_DIR, DENO_CACHE_DIR, GO_CACHE_DIR] } + else { [PIP_TMP_CACHE_DIR, DENO_TMP_CACHE_DIR, GO_TMP_CACHE_DIR] } { DirBuilder::new() .recursive(true) .create(x) @@ -295,6 +298,9 @@ const ROOT_TMP_CACHE_DIR: &str = "/tmp/windmill/tmpcache/"; const PIP_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "pip"); const DENO_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "deno"); const GO_CACHE_DIR: &str = concatcp!(ROOT_CACHE_DIR, "go"); +const PIP_TMP_CACHE_DIR: &str = concatcp!(ROOT_TMP_CACHE_DIR, "pip"); +const DENO_TMP_CACHE_DIR: &str = concatcp!(ROOT_TMP_CACHE_DIR, "deno"); +const GO_TMP_CACHE_DIR: &str = concatcp!(ROOT_TMP_CACHE_DIR, "go"); const NUM_SECS_PING: u64 = 5; const NUM_SECS_SYNC: u64 = 60 * 10;