diff options
| author | Omar Roth <omarroth@hotmail.com> | 2019-03-05 14:41:38 -0600 |
|---|---|---|
| committer | Omar Roth <omarroth@hotmail.com> | 2019-03-05 14:41:38 -0600 |
| commit | 99d9c3a9003d98a34575b49c56cb26ac913f428a (patch) | |
| tree | 7e80c9801499a2d2afe51142d475e7ae06fd72b8 | |
| parent | e4dc430c740870399504a9641a0fb10ffced79f5 (diff) | |
| download | invidious-99d9c3a9003d98a34575b49c56cb26ac913f428a.tar.gz invidious-99d9c3a9003d98a34575b49c56cb26ac913f428a.tar.bz2 invidious-99d9c3a9003d98a34575b49c56cb26ac913f428a.zip | |
Fix rows for subscribe job
| -rw-r--r-- | src/invidious/jobs.cr | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/invidious/jobs.cr b/src/invidious/jobs.cr index 49745aba..50374601 100644 --- a/src/invidious/jobs.cr +++ b/src/invidious/jobs.cr @@ -158,11 +158,13 @@ def subscribe_to_feeds(db, logger, key, config) spawn do loop do db.query_all("SELECT id FROM channels WHERE CURRENT_TIMESTAMP - subscribed > '4 days'") do |rs| - ucid = rs.read(String) - response = subscribe_pubsub(ucid, key, config) + rs.each do + ucid = rs.read(String) + response = subscribe_pubsub(ucid, key, config) - if response.status_code >= 400 - logger.write("#{ucid} : #{response.body}\n") + if response.status_code >= 400 + logger.write("#{ucid} : #{response.body}\n") + end end end |