From f9371fd8d9ef4225ee1e1503a46906528ca17b89 Mon Sep 17 00:00:00 2001 From: azawlocki Date: Tue, 1 Jun 2021 11:07:35 +0200 Subject: [PATCH] Immediately release agreement after service instance finishes --- yapapi/executor/services.py | 1 + 1 file changed, 1 insertion(+) 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()