diff --git a/argos/agent.py b/argos/agent.py index 2cca0d6..195ffdc 100644 --- a/argos/agent.py +++ b/argos/agent.py @@ -164,6 +164,7 @@ class ArgosAgent: # pylint: disable-msg=too-many-instance-attributes logger.info("Received %i tasks from the server", len(data)) req_groups = {} + _tasks = [] for _task in data: task = Task(**_task) @@ -187,6 +188,7 @@ class ArgosAgent: # pylint: disable-msg=too-many-instance-attributes "method": task.method, "request_data": task.request_data, } + _tasks.append(_task) requests = [] for group, details in req_groups.items(): @@ -196,7 +198,7 @@ class ArgosAgent: # pylint: disable-msg=too-many-instance-attributes await asyncio.gather(*requests) tasks = [] - for task in data: + for task in _tasks: tasks.append(self._complete_task(task)) if tasks: