diff --git a/utils/queues.py b/utils/queues.py index 603e981..030bf34 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -29,7 +29,7 @@ class TasksHandlerMixin: print(f'Error processing message id={task["id"]}, payload={task["payload"]}, exc={exc}') continue try: - resp = requests.post(f'{QUEUES_URL}/api/v1/finish', json={'id': data['id']}) + resp = requests.post(f'{QUEUES_URL}/api/v1/finish', json={'id': task['id']}) if resp.status_code != 202: raise QueuesException except: