temporarily disable debouncing

This commit is contained in:
Ruben Fiszel
2025-10-24 10:49:38 +00:00
parent 5279bb94f2
commit 1349e03640
2 changed files with 9 additions and 5 deletions
+1 -5
View File
@@ -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
}
+8
View File
@@ -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.