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

fix dedicated worker dependency jobs

Browse Source
This commit is contained in:
Ruben Fiszel
2023-11-10 18:38:10 +01:00
parent aee35d6d51
commit 5662c86bf0
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/worker.rs
+4 -3
View File
@@ -1464,6 +1464,7 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
{
if dedi_path.workspace_id == job.workspace_id
&& Some(&dedi_path.path) == job.script_path.as_ref()
&& matches!(job.job_kind, JobKind::Script | JobKind::Preview)
{
#[cfg(feature = "benchmark")]
main_duration
@@ -1865,9 +1866,9 @@ pub async fn process_completed_job<R: rsmq_async::RsmqConnection + Send + Sync +
logs.to_string(),
mem_peak.to_owned(),
canceled_by,
serde_json::from_str(result.get()).unwrap_or_else(|_| {
json!({ "message": format!("Non serializable error: {}", result.get()) })
}),
serde_json::from_str(result.get()).unwrap_or_else(
|_| json!({ "message": format!("Non serializable error: {}", result.get()) }),
),
rsmq.clone(),
worker_name,
)