diff --git a/cortext/dendrite.py b/cortext/dendrite.py index 8bc1ad50..b06d0526 100644 --- a/cortext/dendrite.py +++ b/cortext/dendrite.py @@ -47,11 +47,11 @@ 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: - while max_try < 3: + while max_try < 2: async with session.post( url, headers=synapse.to_headers(), 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...")