Immediately release agreement after service instance finishes

golemfactory · Jun 1, 2021 · df60af3 · df60af3
1 parent ec492de
commit df60af3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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()