From 24a111db947c73186e9651d4be8b837760a4d90e Mon Sep 17 00:00:00 2001 From: maaktweluit <10008353+maaktweluit@users.noreply.github.com> Date: Wed, 13 Oct 2021 12:52:47 +0200 Subject: [PATCH] Reduce timeout for collect_offers from 5 -> 1 (#552) Co-authored-by: maaktweluit Co-authored-by: Kuba Mazurek --- goth/runner/probe/mixin.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/goth/runner/probe/mixin.py b/goth/runner/probe/mixin.py index 4a7ff3f7..182d2976 100644 --- a/goth/runner/probe/mixin.py +++ b/goth/runner/probe/mixin.py @@ -75,7 +75,7 @@ async def collect_results( while len(results) < num_results: results = await self.api.activity.control.get_exec_batch_results( - activity_id, batch_id + activity_id, batch_id, timeout=1 ) await asyncio.sleep(1.0) return results @@ -197,7 +197,9 @@ async def wait_for_proposals( provider_ids = {p.address for p in providers} while len(proposals) < len(provider_ids): - collected_offers = await self.api.market.collect_offers(subscription_id) + collected_offers = await self.api.market.collect_offers( + subscription_id, timeout=1 + ) if collected_offers: logger.debug( "collect_offers(%s). collected_offers=%r",