diff --git a/utils/queues.py b/utils/queues.py index 9b77c8e..12b38df 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -66,6 +66,7 @@ class TasksHandlerMixin: resp = requests.post(f'{QUEUES_URL}/api/v1/finish', json={'id': task['id']}) if resp.status_code != 202: raise QueuesException + print(f'finish task with id {task["id"]}') except: print(f'Failed to finish task id={task["id"]}') self.executor.submit(self._send_metric, start, end, success)