From cf423b03065a45dc49e17c120700557971e9ed08 Mon Sep 17 00:00:00 2001 From: Thykof Date: Tue, 2 Dec 2025 16:28:34 +0100 Subject: [PATCH 1/3] fix schedule --- neurons/validator.py | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/neurons/validator.py b/neurons/validator.py index aff415a..6804712 100644 --- a/neurons/validator.py +++ b/neurons/validator.py @@ -124,16 +124,6 @@ def schedule_cycle( ) delay = (next_cycle - get_current_time()).total_seconds() - # Schedule the launch of high frequency prompt - high_frequency_launch = datetime( - 2025, 12, 2, 18, 0, 0, tzinfo=timezone.utc - ) - if ( - prompt_config.label == HIGH_FREQUENCY.label - and get_current_time() <= high_frequency_launch - ): - return - bt.logging.info( f"Scheduling next {prompt_config.label} frequency cycle for asset {asset} in {delay} seconds" ) @@ -167,6 +157,15 @@ def cycle_low_frequency(self, asset: str): def cycle_high_frequency(self, asset: str): cycle_start_time = get_current_time() + + # Schedule the launch of high frequency prompt + high_frequency_launch = datetime( + 2025, 12, 2, 18, 0, 0, tzinfo=timezone.utc + ) + if cycle_start_time <= high_frequency_launch: + self.schedule_cycle(cycle_start_time, HIGH_FREQUENCY) + return + self.forward_prompt(asset, HIGH_FREQUENCY) current_time = get_current_time() From a22e8d6482575a861ffb78cb4c2b8565408f0a44 Mon Sep 17 00:00:00 2001 From: Thykof Date: Tue, 2 Dec 2025 16:28:53 +0100 Subject: [PATCH 2/3] fix scores len with sync and save state --- neurons/validator.py | 2 +- synth/base/neuron.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/neurons/validator.py b/neurons/validator.py index 6804712..f4d92e6 100644 --- a/neurons/validator.py +++ b/neurons/validator.py @@ -144,7 +144,6 @@ def cycle_low_frequency(self, asset: str): bt.logging.info(f"starting the {LOW_FREQUENCY.label} frequency cycle") cycle_start_time = get_current_time() - self.sync() # update the miners, also for the high frequency prompt that will use the same list self.miner_uids = get_available_miners_and_update_metagraph_history( base_neuron=self, @@ -153,6 +152,7 @@ def cycle_low_frequency(self, asset: str): self.forward_prompt(asset, LOW_FREQUENCY) self.forward_score_low_frequency() # self.cleanup_history() + self.sync() self.schedule_cycle(cycle_start_time, LOW_FREQUENCY) def cycle_high_frequency(self, asset: str): diff --git a/synth/base/neuron.py b/synth/base/neuron.py index 8613c65..57e2c23 100644 --- a/synth/base/neuron.py +++ b/synth/base/neuron.py @@ -127,7 +127,7 @@ def sync(self): # in the run() method. This to save to database the result of the set_weights. # Always save state. - # self.save_state() + self.save_state() def check_registered(self): # --- Check for registration. From 535cbedf90f7b588619b8458a6e4572304b21581 Mon Sep 17 00:00:00 2001 From: Thykof Date: Tue, 2 Dec 2025 16:29:02 +0100 Subject: [PATCH 3/3] silent dendrite --- synth/base/dendrite.py | 3 ++- synth/base/dendrite_multiprocess.py | 12 ++++++------ 2 files changed, 8 insertions(+), 7 deletions(-) diff --git a/synth/base/dendrite.py b/synth/base/dendrite.py index 748c0c9..ee7f5d0 100644 --- a/synth/base/dendrite.py +++ b/synth/base/dendrite.py @@ -265,7 +265,8 @@ def log_exception(exception: Exception): ValidationError, ), ): - bt.logging.trace(f"{error_type}#{error_id}: {exception}") + # bt.logging.trace(f"{error_type}#{error_id}: {exception}") + pass else: bt.logging.error(f"{error_type}#{error_id}: {exception}") traceback.print_exc(file=sys.stderr) diff --git a/synth/base/dendrite_multiprocess.py b/synth/base/dendrite_multiprocess.py index 6cb75d1..3550910 100644 --- a/synth/base/dendrite_multiprocess.py +++ b/synth/base/dendrite_multiprocess.py @@ -169,9 +169,9 @@ async def call( synapse.dendrite.signature = signature try: - bt.logging.trace( - f"dendrite | --> | {synapse.get_total_size()} B | {synapse.name} | {synapse.axon.hotkey} | {synapse.axon.ip}:{str(synapse.axon.port)} | 0 | Success" - ) + # bt.logging.trace( + # f"dendrite | --> | {synapse.get_total_size()} B | {synapse.name} | {synapse.axon.hotkey} | {synapse.axon.ip}:{str(synapse.axon.port)} | 0 | Success" + # ) response = await client.post( url=url, headers=synapse.to_headers(), @@ -189,9 +189,9 @@ async def call( synapse = process_error_message(synapse, REQUEST_NAME, e) finally: - bt.logging.trace( - f"dendrite | <-- | {synapse.get_total_size()} B | {synapse.name} | {synapse.axon.hotkey} | {synapse.axon.ip}:{str(synapse.axon.port)} | {synapse.dendrite.status_code} | {synapse.dendrite.status_message}" - ) + # bt.logging.trace( + # f"dendrite | <-- | {synapse.get_total_size()} B | {synapse.name} | {synapse.axon.hotkey} | {synapse.axon.ip}:{str(synapse.axon.port)} | {synapse.dendrite.status_code} | {synapse.dendrite.status_message}" + # ) return [synapse.simulation_output, synapse.dendrite.process_time]