update_queued in crontab only

This commit is contained in:
j 2023-08-25 00:09:38 +02:00
parent c0c76f2ed5
commit e4099d642d

View file

@ -14,11 +14,12 @@ import annotation.models
import text.models import text.models
@app.task(queue='encoding') @app.task(ignore_results=True, queue='encoding')
def cron(**kwargs): def cron(**kwargs):
update_double_imdb() update_double_imdb()
outofcopyright() outofcopyright()
update_keywords() update_keywords()
update_queued()
def outofcopyright(): def outofcopyright():
@ -56,7 +57,7 @@ def update_keywords():
t.save() t.save()
@app.task(queue='encoding') @app.task(ignore_results=True, queue='encoding')
def update_queued(): def update_queued():
import archive.models import archive.models
l = itemlist.models.List.get('j:Queued') l = itemlist.models.List.get('j:Queued')
@ -77,5 +78,4 @@ def update_queued():
@app.on_after_finalize.connect @app.on_after_finalize.connect
def setup_periodic_tasks(sender, **kwargs): def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(crontab(hour=6, minute=0), cron.s()) sender.add_periodic_task(crontab(hour=6, minute=0), cron.s())
sender.add_periodic_task(crontab(minute=0), update_queued.s())