Skip to content

nit: better logs for debouncing [merge-ee-first] #7501

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
rubenfiszel merged 7 commits into from
Jan 6, 2026
Merged

nit: better logs for debouncing [merge-ee-first] #7501

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
b0ce255
nit: better logs for debouncing
pyranota Jan 6, 2026
2fa7540
Merge branch 'main' into debouncing-logs
pyranota Jan 6, 2026
08b497d
ee ref
pyranota Jan 6, 2026
af057b1
Merge branch 'debouncing-logs' of github.com:windmill-labs/windmill i…
pyranota Jan 6, 2026
7853acd
ee ref
pyranota Jan 6, 2026
57efa22
remove default featrues
pyranota Jan 6, 2026
03e6c77
chore: update ee-repo-ref to ea468d0b673257c694203517b0c5df52d9cb70dd
windmill-internal-app[bot] Jan 6, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion backend/ee-repo-ref.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
a86e292dc3627d695e5dfc986a32fe01a263a83f
ea468d0b673257c694203517b0c5df52d9cb70dd
18 changes: 14 additions & 4 deletions backend/windmill-queue/src/jobs.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2708,13 +2708,23 @@ impl PulledJobResult {
"Accumulated arguments from debounced jobs in batch"
);

let new_value = to_raw_value(&accumulated_arg);

append_logs(
&j_id,
&j.workspace_id,
format!(
"Substituting `{arg_name_to_accumulate}` with: {}\n\n",
&new_value
),
&(db.into()),
)
.await;

j.args
.get_or_insert(Json(Default::default()))
.as_mut()
.insert(
arg_name_to_accumulate.to_owned(),
to_raw_value(&accumulated_arg),
);
.insert(arg_name_to_accumulate.to_owned(), new_value);
}

// Handle dependency job debouncing cleanup when a job is pulled for execution
Expand Down
Loading