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: