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