Explicitly ignore expired messages in the scheduler loop.

This commit is contained in:
Antony 2025-03-27 20:09:12 +13:00
parent 1b8f1b5c45
commit 98542a9592

View File

@ -674,6 +674,8 @@ pub async fn get_schedulable_queue_items(limit: usize) -> Result<Vec<MulticastGr
and (
$2 - make_interval(secs => g.stats_interval_secs * 2) <= g.last_seen_at
)
-- ignore expired messages
and not (qi.expires_at < $2)
order by
qi.created_at
limit $1