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

This commit is contained in:
Egor Matveev
2025-06-15 17:13:54 +03:00
parent 7b9d264ef9
commit 33901b0a82
5 changed files with 11 additions and 44 deletions

View File

@@ -1,3 +1,4 @@
from concurrent.futures import ThreadPoolExecutor
import datetime
import json
import os
@@ -19,9 +20,13 @@ class QueuesException(Exception):
class TasksHandlerMixin:
def __init__(self, *args, **kwargs):
super().__init__(*args, **kwargs)
self.executor = ThreadPoolExecutor(max_workers=1)
def _send_metric(self, start: datetime.datetime, end: datetime.datetime, success: bool):
with open(f'/usr/src/{uuid.uuid4()}.json', 'w') as fp:
fp.write(json.dumps({
def send():
requests.post(f'{QUEUES_URL}/api/v1/metric', json={
'service': 'botalka',
'queue': self.queue_name,
'success': success,
@@ -29,7 +34,9 @@ class TasksHandlerMixin:
"success": success,
"execution_time_ms": (end - start).microseconds // 1000,
"environment": stage,
}))
})
self.executor.submit(send)
def poll(self):
while True: