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