metric #82

Merged
emmatveev merged 17 commits from metric into master 2025-07-17 23:32:44 +03:00
Showing only changes of commit 72c5823ccd - Show all commits

View File

@ -13,14 +13,15 @@ else:
QUEUES_URL = 'http://queues:1239' QUEUES_URL = 'http://queues:1239'
executor = ThreadPoolExecutor(max_workers=4)
class QueuesException(Exception): class QueuesException(Exception):
... ...
class TasksHandlerMixin: class TasksHandlerMixin:
def __init__(self, *args, **kwargs):
super().__init__(*args, **kwargs)
self.executor = ThreadPoolExecutor(max_workers=4)
def _send_metric(self, start: datetime.datetime, end: datetime.datetime, success: bool): def _send_metric(self, start: datetime.datetime, end: datetime.datetime, success: bool):
try: try:
resp = requests.post('http://monitoring:1237/api/v1/metrics/task', json={ resp = requests.post('http://monitoring:1237/api/v1/metrics/task', json={
@ -39,10 +40,6 @@ class TasksHandlerMixin:
except Exception as e: except Exception as e:
print(f"Error sending metric: {e}") 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)
def poll(self): def poll(self):
while True: while True:
try: try:
@ -70,7 +67,7 @@ class TasksHandlerMixin:
raise QueuesException raise QueuesException
except: except:
print(f'Failed to finish task id={task["id"]}') print(f'Failed to finish task id={task["id"]}')
self.send_metric(start, end, success) self.executor.submit(self._send_metric, start, end, success)
@property @property
def queue_name(self): def queue_name(self):