telegram_bots/feeds/tasks.py
2019-01-11 22:16:02 +03:00

25 lines
570 B
Python

from django.utils import timezone
from telebot import TeleBot
from config.celery import app
@app.task()
def execute_feed(feed_pk):
from feeds.models import Feed
try:
feed = Feed.objects.get(pk=feed_pk)
if not feed.lock:
feed.lock = True
feed.save()
bot = TeleBot('450146961:AAFcb9tyIiKAi6BHR1ZYfWuTEkYjhO3xEFE')
feed.last_id = feed.config.execute(bot, feed.chat_id, feed.last_id)
feed.last_check = timezone.now()
feed.save()
finally:
feed.lock = False
feed.save()