starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-09-07 08:02:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

avoid caching binary on cloud

Browse Source
This commit is contained in:
Ruben Fiszel
2024-03-17 19:13:51 +01:00
parent dd56e8a212
commit 4788c393e9
1 changed files with 14 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/go_executor.rs
+14 -11
View File
@@ -12,6 +12,7 @@ use windmill_common::{
error::{self, Error},
jobs::QueuedJob,
utils::calculate_hash,
worker::CLOUD_HOSTED,
};
use windmill_parser_go::{parse_go_imports, REQUIRE_PARSE};
use windmill_queue::{append_logs, CanceledBy};
@@ -61,7 +62,7 @@ pub async fn handle_go_job(
.unwrap_or_default()
))
);
let bin_exists = tokio::fs::metadata(&bin_path).await.is_ok();
let bin_exists = !*CLOUD_HOSTED && tokio::fs::metadata(&bin_path).await.is_ok();
let (skip_go_mod, skip_tidy) = if bin_exists {
create_dir(job_dir).await?;
@@ -208,16 +209,18 @@ func Run(req Req) (interface{{}}, error){{
)
.await?;
create_dir(&bin_path).await?;
let target = format!("{bin_path}/main");
tokio::fs::copy(format!("{job_dir}/main"), &target).await?;
append_logs(
job.id.clone(),
job.workspace_id.to_string(),
format!("write cached binary: {}\n", bin_path),
db,
)
.await;
if !*CLOUD_HOSTED {
create_dir(&bin_path).await?;
let target = format!("{bin_path}/main");
tokio::fs::copy(format!("{job_dir}/main"), &target).await?;
append_logs(
job.id.clone(),
job.workspace_id.to_string(),
format!("write cached binary: {}\n", bin_path),
db,
)
.await;
}
} else {
let path = format!("{bin_path}/main");
let mut logs2 = "".to_string();