From 7e91415cbd48b900469902ce6fda68c7370cf218 Mon Sep 17 00:00:00 2001 From: acer-king Date: Wed, 6 Nov 2024 08:33:51 -0800 Subject: [PATCH 1/3] change total timeout to dendrite timeout --- cortext/dendrite.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cortext/dendrite.py b/cortext/dendrite.py index 8bc1ad50..25f3f9b4 100644 --- a/cortext/dendrite.py +++ b/cortext/dendrite.py @@ -47,7 +47,7 @@ async def call_stream( # Preprocess synapse for making a request synapse: StreamPrompting = self.preprocess_synapse_for_request(target_axon, synapse, timeout) # type: ignore max_try = 0 - timeout = aiohttp.ClientTimeout(total=100, connect=timeout, sock_connect=timeout, sock_read=timeout) + timeout = aiohttp.ClientTimeout(total=timeout, connect=10, sock_connect=10, sock_read=10) connector = aiohttp.TCPConnector(limit=200) session = aiohttp.ClientSession(timeout=timeout, connector=connector) try: From 999e2de3424c112fb465bc0ac5e16700bfde7977 Mon Sep 17 00:00:00 2001 From: acer-king Date: Wed, 6 Nov 2024 08:44:49 -0800 Subject: [PATCH 2/3] decrease retry to 2 --- cortext/dendrite.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cortext/dendrite.py b/cortext/dendrite.py index 25f3f9b4..b06d0526 100644 --- a/cortext/dendrite.py +++ b/cortext/dendrite.py @@ -51,7 +51,7 @@ async def call_stream( connector = aiohttp.TCPConnector(limit=200) session = aiohttp.ClientSession(timeout=timeout, connector=connector) try: - while max_try < 3: + while max_try < 2: async with session.post( url, headers=synapse.to_headers(), From 0d3ead03ae48dc1e14e5321ac0261a300157c9f5 Mon Sep 17 00:00:00 2001 From: acer-king Date: Wed, 6 Nov 2024 08:56:27 -0800 Subject: [PATCH 3/3] start scoring process without waiting for completion of synthetic tasks --- validators/weight_setter.py | 3 --- 1 file changed, 3 deletions(-) diff --git a/validators/weight_setter.py b/validators/weight_setter.py index 8d2e4ad6..8a610e12 100644 --- a/validators/weight_setter.py +++ b/validators/weight_setter.py @@ -599,9 +599,6 @@ async def process_queries_from_database(self): if not self.is_epoch_end(): bt.logging.debug("no end of epoch. so continue...") continue - if not self.synthetic_task_done: - bt.logging.debug("wait for synthetic tasks to complete.") - continue bt.logging.info(f"start scoring process...")