diff --git a/backend/windmill-common/src/worker.rs b/backend/windmill-common/src/worker.rs index f2e5da5057..2a346ea2b3 100644 --- a/backend/windmill-common/src/worker.rs +++ b/backend/windmill-common/src/worker.rs @@ -409,10 +409,6 @@ fn format_pull_query(peek: String) -> String { raw_flow, script_entrypoint_override, preprocessed FROM v2_job WHERE id = (SELECT id FROM peek) - ), delete_debounce AS NOT MATERIALIZED ( - DELETE FROM debounce_key - USING j - WHERE j.kind::text != 'flowdependencies' AND j.kind::text != 'appdependencies' AND j.kind::text != 'dependencies' AND debounce_key.job_id = j.id ) SELECT j.id, j.workspace_id, j.parent_job, j.created_by, started_at, scheduled_for, j.runnable_id, j.runnable_path, j.args, canceled_by, canceled_reason, j.kind, j.trigger, j.trigger_kind, j.permissioned_as, @@ -430,7 +426,7 @@ fn format_pull_query(peek: String) -> String { ", peek ); - // tracing::debug!("pull query: {}", r); + tracing::debug!("pull query: {}", r); r } diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs index acf0b5df76..977ba0dfba 100644 --- a/backend/windmill-queue/src/jobs.rs +++ b/backend/windmill-queue/src/jobs.rs @@ -4391,6 +4391,14 @@ pub async fn push<'c, 'd>( ), }; + if debounce_key.is_some() { + tracing::warn!("debouncing has been disabled temporarily, ignoring debounce_key"); + custom_debounce_key = None; + } + if debounce_delay_s.is_some() { + tracing::warn!("debouncing has been disabled temporarily, ignoring debounce_delay_s"); + custom_debounce_delay_s = None; + } // Enforce concurrency limit on all dependency jobs. // TODO: We can ignore this for scripts djobs. The main reason we need all djobs to be sequential is because we have // nodes_to_relock and we need all locks whose corresponding steps aren't in nodes_to_relock be already present.