.deploy/deploy-dev.yaml

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

.deploy/deploy-prod.yaml

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

bot.py

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