fix
All checks were successful
Deploy Prod / Build (pull_request) Successful in 4s
Deploy Prod / Push (pull_request) Successful in 8s
Deploy Prod / Deploy prod (pull_request) Successful in 10s

This commit is contained in:
Egor Matveev 2025-06-15 03:14:18 +03:00
parent 73c8466a50
commit d45e8c8a35

View File

@ -1,6 +1,7 @@
import datetime import datetime
import os import os
from threading import Thread from threading import Thread
import zoneinfo
import requests import requests
import time import time
@ -50,14 +51,14 @@ class TasksHandlerMixin:
if not task: if not task:
time.sleep(0.2) time.sleep(0.2)
continue continue
start = datetime.datetime.now() start = datetime.datetime.now().astimezone(zoneinfo.ZoneInfo("Europe/Moscow"))
try: try:
self.process(task['payload']) self.process(task['payload'])
success = True success = True
except Exception as exc: except Exception as exc:
print(f'Error processing message id={task["id"]}, payload={task["payload"]}, exc={exc}') print(f'Error processing message id={task["id"]}, payload={task["payload"]}, exc={exc}')
success = False success = False
end = datetime.datetime.now() end = datetime.datetime.now().astimezone(zoneinfo.ZoneInfo("Europe/Moscow"))
try: try:
resp = requests.post(f'{QUEUES_URL}/api/v1/finish', json={'id': task['id']}) resp = requests.post(f'{QUEUES_URL}/api/v1/finish', json={'id': task['id']})
if resp.status_code != 202: if resp.status_code != 202: