diff --git a/src/invidious/jobs/notification_job.cr b/src/invidious/jobs/notification_job.cr index 48e4eec2..72b526d7 100644 --- a/src/invidious/jobs/notification_job.cr +++ b/src/invidious/jobs/notification_job.cr @@ -35,7 +35,7 @@ class Invidious::Jobs::NotificationJob < Invidious::Jobs::BaseJob PG.connect_listen(pg_url, "notifications") do |event| connections.each do |channel| channel.send(event) - rescue Channel::ClosedError + rescue ::Channel::ClosedError # Notification stream was closed. end end