From e0e7564fcc21c19654fbf48763ded277eb793214 Mon Sep 17 00:00:00 2001 From: Egor Matveev Date: Sun, 15 Jun 2025 05:27:31 +0300 Subject: [PATCH] fix --- utils/queues.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/utils/queues.py b/utils/queues.py index a571358..a69857d 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -13,7 +13,7 @@ else: QUEUES_URL = 'http://queues:1239' -executor = ThreadPoolExecutor(max_workers=1) +executor = ThreadPoolExecutor(max_workers=4) class QueuesException(Exception): @@ -40,8 +40,8 @@ class TasksHandlerMixin: print(f"Error sending metric: {e}") def send_metric(self, start: datetime.datetime, end: datetime.datetime, success: bool): - # executor.submit(self._send_metric, start, end, success) - self._send_metric(start, end, success) + executor.submit(self._send_metric, start, end, success) + # self._send_metric(start, end, success) def poll(self): while True: