class SocketHandler(tornado.websocket.WebSocketHandler): connections = [] def open(self): self.__class__.connections.append(self) @classmethod def get_connections(cls): return cls.connections
и celery таск, который должен отправлять сообщения клиентам:
from handlers import SocketHandler @celery.task def send_msg(msg): for conn in SocketHandler.get_connections(): conn.write_message(msg)
Но список полученный путем SocketHandler.get_connections() в файле с celery тасками оказывается пустым.
tornado сервер запускаю так:
(venv)$ python app.py
(venv)$ celery -A tasks worker
Подскажите, пожалуйста, что я делаю не так и как мне получить список с соединениями в функции для celery