queues #15

Merged
emmatveev merged 11 commits from queues into prod 2024-11-25 00:07:15 +03:00
Showing only changes of commit c3886433ac - Show all commits

View File

@ -28,7 +28,7 @@ class TasksHandlerMixin:
print(f'Error processing message id={data["id"]}, payload={data["payload"]}, exc={exc}')
continue
try:
resp = requests.post(f'{QUEUES_URL}/api/v1/finish', json={'id': data['id']}, headers={'X-Queues-Token': token})
resp = requests.post(f'{QUEUES_URL}/api/v1/finish', json={'id': data['id']})
if resp.status_code != 202:
raise QueuesException
except: