self/botalka
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix
All checks were successful
Deploy Dev / Build (pull_request) Successful in 6s
Details
Deploy Dev / Push (pull_request) Successful in 9s
Details
Deploy Dev / Deploy dev (pull_request) Successful in 12s
Details

Browse Source
This commit is contained in:
Egor Matveev 2025-06-15 05:27:31 +03:00
parent 2bff8983b5
commit e0e7564fcc
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
utils/queues.py
View File

@ -13,7 +13,7 @@ else:
QUEUES_URL = 'http://queues:1239' QUEUES_URL = 'http://queues:1239'
executor = ThreadPoolExecutor(max_workers=1) executor = ThreadPoolExecutor(max_workers=4)
class QueuesException(Exception): class QueuesException(Exception):
@ -40,8 +40,8 @@ class TasksHandlerMixin:
print(f"Error sending metric: {e}") print(f"Error sending metric: {e}")
def send_metric(self, start: datetime.datetime, end: datetime.datetime, success: bool): def send_metric(self, start: datetime.datetime, end: datetime.datetime, success: bool):
# executor.submit(self._send_metric, start, end, success) executor.submit(self._send_metric, start, end, success)
self._send_metric(start, end, success) # self._send_metric(start, end, success)
def poll(self): def poll(self):
while True: while True: