mirrors/invidious
1
0
Fork 0
mirror of https://github.com/iv-org/invidious.git synced 2025-08-23 13:08:31 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

remove db arg passed to refresh channels job

Browse Source
This commit is contained in:
matthewmcgarvey 2022-01-22 09:54:09 -06:00
parent 7e25ad5e4e
commit 314f49b687
3 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/invidious.cr
View File

@ -132,7 +132,7 @@ end
# Start jobs # Start jobs
if CONFIG.channel_threads > 0 if CONFIG.channel_threads > 0
Invidious::Jobs.register Invidious::Jobs::RefreshChannelsJob.new(PG_DB) Invidious::Jobs.register Invidious::Jobs::RefreshChannelsJob.new
end end
if CONFIG.feed_threads > 0 if CONFIG.feed_threads > 0

2
src/invidious/database/channels.cr
View File

@ -82,7 +82,7 @@ module Invidious::Database::Channels
SELECT * FROM channels SELECT * FROM channels
SQL SQL
return PG_DB.query_all(rqeuest, as: InvidiousChannel) return PG_DB.query_all(request, as: InvidiousChannel)
end end
end end

5
src/invidious/jobs/refresh_channels_job.cr
View File

@ -1,9 +1,4 @@
class Invidious::Jobs::RefreshChannelsJob < Invidious::Jobs::BaseJob class Invidious::Jobs::RefreshChannelsJob < Invidious::Jobs::BaseJob
private getter db : DB::Database
def initialize(@db)
end
def begin def begin
max_fibers = CONFIG.channel_threads max_fibers = CONFIG.channel_threads
lim_fibers = max_fibers lim_fibers = max_fibers