diff --git a/src/invidious/jobs/refresh_channels_job.cr b/src/invidious/jobs/refresh_channels_job.cr index 80812a63..5c5ecc83 100644 --- a/src/invidious/jobs/refresh_channels_job.cr +++ b/src/invidious/jobs/refresh_channels_job.cr @@ -36,6 +36,11 @@ class Invidious::Jobs::RefreshChannelsJob < Invidious::Jobs::BaseJob LOGGER.trace("RefreshChannelsJob: #{id} fiber : Updating DB") Invidious::Database::Channels.update_author(id, channel.author) + + if backoff > 2.minutes + backoff /= 2 + LOGGER.debug("RefreshChannelsJob: #{id} fiber : decreasing backoff to #{backoff}s") + end rescue ex LOGGER.error("RefreshChannelsJob: #{id} : #{ex.message}") if ex.message == "Deleted or invalid channel"