fix
This commit is contained in:
parent
2d292dfc46
commit
0cab3e52cb
@ -66,6 +66,7 @@ class TasksHandlerMixin:
|
|||||||
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:
|
||||||
raise QueuesException
|
raise QueuesException
|
||||||
|
print(f'finish task with id {task["id"]}')
|
||||||
except:
|
except:
|
||||||
print(f'Failed to finish task id={task["id"]}')
|
print(f'Failed to finish task id={task["id"]}')
|
||||||
self.executor.submit(self._send_metric, start, end, success)
|
self.executor.submit(self._send_metric, start, end, success)
|
||||||
|
Loading…
Reference in New Issue
Block a user