diff --git a/yapapi/executor/services.py b/yapapi/executor/services.py index 9be8de4a5..3fb775e70 100644 --- a/yapapi/executor/services.py +++ b/yapapi/executor/services.py @@ -453,6 +453,7 @@ async def start_worker(agreement: rest.market.Agreement, node_info: NodeInfo) -> raise finally: await self._engine.accept_payments_for_agreement(agreement.id) + await self._job.agreements_pool.release_agreement(agreement.id, False) loop = asyncio.get_event_loop()