From 83cfc6e91bd3303b31d333733c2b5a67bf218bea Mon Sep 17 00:00:00 2001 From: Amaan Qureshi Date: Tue, 13 Oct 2026 13:42:22 -0400 Subject: [PATCH] common: wake listeners after every pg LISTEN subscribe --- crates/common/src/pg_notify.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/crates/common/src/pg_notify.rs b/crates/common/src/pg_notify.rs index 471a1101..07d796ab 100644 --- a/crates/common/src/pg_notify.rs +++ b/crates/common/src/pg_notify.rs @@ -80,6 +80,7 @@ async fn listen_loop( }; tracing::info!(channels = ?channels, "PG LISTEN subscribed"); + wakeup.notify_one(); while rx.recv().await.is_some() { // notify_one deposits a permit so notifications arriving while the daemon