|
|
@ -13,7 +13,7 @@ class Invidious::Jobs::RefreshChannelsJob < Invidious::Jobs::BaseJob
|
|
|
|
|
|
|
|
|
|
|
|
loop do
|
|
|
|
loop do
|
|
|
|
LOGGER.debug("RefreshChannelsJob: Refreshing all channels")
|
|
|
|
LOGGER.debug("RefreshChannelsJob: Refreshing all channels")
|
|
|
|
db.query("SELECT id FROM channels ORDER BY updated") do |rs|
|
|
|
|
PG_DB.query("SELECT id FROM channels ORDER BY updated") do |rs|
|
|
|
|
rs.each do
|
|
|
|
rs.each do
|
|
|
|
id = rs.read(String)
|
|
|
|
id = rs.read(String)
|
|
|
|
|
|
|
|
|
|
|
@ -30,7 +30,7 @@ class Invidious::Jobs::RefreshChannelsJob < Invidious::Jobs::BaseJob
|
|
|
|
spawn do
|
|
|
|
spawn do
|
|
|
|
begin
|
|
|
|
begin
|
|
|
|
LOGGER.trace("RefreshChannelsJob: #{id} fiber : Fetching channel")
|
|
|
|
LOGGER.trace("RefreshChannelsJob: #{id} fiber : Fetching channel")
|
|
|
|
channel = fetch_channel(id, db, CONFIG.full_refresh)
|
|
|
|
channel = fetch_channel(id, CONFIG.full_refresh)
|
|
|
|
|
|
|
|
|
|
|
|
lim_fibers = max_fibers
|
|
|
|
lim_fibers = max_fibers
|
|
|
|
|
|
|
|
|
|
|
|