diff --git a/src/invidious/jobs.cr b/src/invidious/jobs.cr index 54749f87..a217c1af 100644 --- a/src/invidious/jobs.cr +++ b/src/invidious/jobs.cr @@ -106,7 +106,7 @@ def subscribe_to_feeds(db, logger, key, config) if config.use_pubsub_feeds spawn do loop do - db.query_all("SELECT id FROM channels WHERE CURRENT_TIMESTAMP - subscribed > '4 days'") do |rs| + db.query_all("SELECT id FROM channels WHERE CURRENT_TIMESTAMP - subscribed > '4 days' OR subscribed IS NULL") do |rs| rs.each do ucid = rs.read(String) response = subscribe_pubsub(ucid, key, config)