diff options
| author | Samantaz Fox <coding@samantaz.fr> | 2022-01-09 22:04:10 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-01-09 22:04:10 +0100 |
| commit | 790b7afccaeb880e8b77c1df6a4cc6654c222006 (patch) | |
| tree | b9f21585f0a46c99652458a5c2aa9ebee4cbf217 | |
| parent | 67cb8b7107682e451fa86c574c691f707e902e8c (diff) | |
| download | invidious-790b7afccaeb880e8b77c1df6a4cc6654c222006.tar.gz invidious-790b7afccaeb880e8b77c1df6a4cc6654c222006.tar.bz2 invidious-790b7afccaeb880e8b77c1df6a4cc6654c222006.zip | |
Fix indefinitely growing database
| -rw-r--r-- | src/invidious/jobs/refresh_channels_job.cr | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/invidious/jobs/refresh_channels_job.cr b/src/invidious/jobs/refresh_channels_job.cr index c224c745..941089c1 100644 --- a/src/invidious/jobs/refresh_channels_job.cr +++ b/src/invidious/jobs/refresh_channels_job.cr @@ -13,7 +13,7 @@ class Invidious::Jobs::RefreshChannelsJob < Invidious::Jobs::BaseJob loop do 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 id = rs.read(String) @@ -30,7 +30,7 @@ class Invidious::Jobs::RefreshChannelsJob < Invidious::Jobs::BaseJob spawn do begin 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 |