commit
989f7026ad
@ -5,7 +5,7 @@ from daemons import base
|
|||||||
from utils import queues
|
from utils import queues
|
||||||
|
|
||||||
|
|
||||||
class Daemon(base.BaseDaemon, queues.TasksHandlerMixin):
|
class Daemon(base.Daemon, queues.TasksHandlerMixin):
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
super().__init__()
|
super().__init__()
|
||||||
self.bot = telebot.TeleBot(os.getenv("TELEGRAM_TOKEN"))
|
self.bot = telebot.TeleBot(os.getenv("TELEGRAM_TOKEN"))
|
||||||
|
@ -6,7 +6,7 @@ from telebot import types
|
|||||||
from utils import queues
|
from utils import queues
|
||||||
|
|
||||||
|
|
||||||
class Daemon(base.BaseDaemon):
|
class Daemon(base.Daemon):
|
||||||
def execute(self):
|
def execute(self):
|
||||||
bot = telebot.TeleBot(os.getenv("TELEGRAM_TOKEN"))
|
bot = telebot.TeleBot(os.getenv("TELEGRAM_TOKEN"))
|
||||||
@bot.message_handler()
|
@bot.message_handler()
|
||||||
|
@ -5,7 +5,7 @@ import json
|
|||||||
from telebot.types import Message
|
from telebot.types import Message
|
||||||
|
|
||||||
|
|
||||||
class Daemon(base.BaseDaemon, queues.TasksHandlerMixin):
|
class Daemon(base.Daemon, queues.TasksHandlerMixin):
|
||||||
@property
|
@property
|
||||||
def queue_name(self):
|
def queue_name(self):
|
||||||
return 'ruz_bot_worker'
|
return 'ruz_bot_worker'
|
||||||
|
Loading…
Reference in New Issue
Block a user