From 7c757b68f64bf3cf770cd080c5025f202d40201c Mon Sep 17 00:00:00 2001 From: hugocasa Date: Mon, 6 Oct 2025 15:35:59 +0200 Subject: [PATCH] fix(backend): use correct ai tool job dir (#6757) --- backend/windmill-worker/src/ai_executor.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/backend/windmill-worker/src/ai_executor.rs b/backend/windmill-worker/src/ai_executor.rs index 08c8ede63a..c927c09354 100644 --- a/backend/windmill-worker/src/ai_executor.rs +++ b/backend/windmill-worker/src/ai_executor.rs @@ -871,8 +871,6 @@ pub async fn run_agent( let tool_job = Arc::new(tool_job); - let job_dir = create_job_dir(&worker_dir, job.id).await; - let (inner_job_completed_tx, inner_job_completed_rx) = JobCompletedSender::new(&conn, 1); @@ -891,7 +889,6 @@ pub async fn run_agent( let hostname_spawn = hostname.to_string(); let worker_name_spawn = worker_name.to_string(); let worker_dir_spawn = worker_dir.to_string(); - let job_dir_spawn = job_dir.clone(); let base_internal_url_spawn = base_internal_url.to_string(); let inner_job_completed_tx_spawn = inner_job_completed_tx.clone(); let mut occupancy_metrics_spawn = occupancy_metrics.clone(); @@ -903,6 +900,9 @@ pub async fn run_agent( let mut bench_spawn = windmill_common::bench::BenchmarkIter::new(); + let job_dir = + create_job_dir(&worker_dir_spawn, tool_job_spawn.id).await; + let result = handle_queued_job( tool_job_spawn, None, @@ -914,7 +914,7 @@ pub async fn run_agent( &hostname_spawn, &worker_name_spawn, &worker_dir_spawn, - &job_dir_spawn, + &job_dir, None, &base_internal_url_spawn, inner_job_completed_tx_spawn,