fix
All checks were successful
Deploy Dev / Build (pull_request) Successful in 5s
Deploy Dev / Push (pull_request) Successful in 8s
Deploy Dev / Deploy dev (pull_request) Successful in 8s

This commit is contained in:
emmatveev 2024-11-30 12:46:22 +03:00
parent e55898663d
commit ebeef5c15f
3 changed files with 16 additions and 0 deletions

View File

@ -8,6 +8,8 @@ services:
environment: environment:
MONGO_HOST: "mongo.develop.sprinthub.ru" MONGO_HOST: "mongo.develop.sprinthub.ru"
MONGO_PASSWORD: $MONGO_PASSWORD_DEV MONGO_PASSWORD: $MONGO_PASSWORD_DEV
networks:
- queues-development
deploy: deploy:
mode: replicated mode: replicated
restart_policy: restart_policy:
@ -15,3 +17,7 @@ services:
update_config: update_config:
parallelism: 1 parallelism: 1
order: start-first order: start-first
networks:
queues-development:
external: true

View File

@ -8,6 +8,8 @@ services:
environment: environment:
MONGO_HOST: "mongo.sprinthub.ru" MONGO_HOST: "mongo.sprinthub.ru"
MONGO_PASSWORD: $MONGO_PASSWORD_PROD MONGO_PASSWORD: $MONGO_PASSWORD_PROD
networks:
- queues
deploy: deploy:
mode: replicated mode: replicated
restart_policy: restart_policy:
@ -15,3 +17,7 @@ services:
update_config: update_config:
parallelism: 1 parallelism: 1
order: start-first order: start-first
networks:
queues:
external: true

4
bot.py
View File

@ -6,6 +6,10 @@ from tools.queues import TasksHandlerMixin, set_task
class Core(TasksHandlerMixin): class Core(TasksHandlerMixin):
@property
def queue_name(self):
return 'roulette_bot_worker'
def process(self, payload): def process(self, payload):
message: Message = Message.de_json(json.dumps(payload)) message: Message = Message.de_json(json.dumps(payload))
self.message = message self.message = message