fix
This commit is contained in:
parent
ec01ab879f
commit
69b37cdd27
@ -4,11 +4,12 @@ from telebot import TeleBot
|
|||||||
from djconfig import config
|
from djconfig import config
|
||||||
|
|
||||||
from config.celery import app
|
from config.celery import app
|
||||||
from feeds.models import Feed
|
|
||||||
|
|
||||||
|
|
||||||
@app.task(base=QueueOnce)
|
@app.task(base=QueueOnce)
|
||||||
def check_feeds():
|
def check_feeds():
|
||||||
|
from feeds.models import Feed
|
||||||
|
|
||||||
feeds = Feed.objects.filter(lock=False)
|
feeds = Feed.objects.filter(lock=False)
|
||||||
for feed in feeds:
|
for feed in feeds:
|
||||||
feed.run_check()
|
feed.run_check()
|
||||||
|
Loading…
Reference in New Issue
Block a user