@@ -295,11 +295,11 @@ async def perform_synthetic_queries_one_cycle(self):
295
295
296
296
async def perform_synthetic_queries (self ):
297
297
while True :
298
- # if not self.is_cycle_end():
299
- # await asyncio.sleep(12)
300
- # continue
301
- # self.set_up_next_block_to_wait()
302
- await asyncio .sleep (432 )
298
+ if not self .is_cycle_end ():
299
+ await asyncio .sleep (12 )
300
+ continue
301
+ self .set_up_next_block_to_wait ()
302
+ # await asyncio.sleep(432)
303
303
self .loop .create_task (self .perform_synthetic_queries_one_cycle ())
304
304
305
305
def pop_synthetic_tasks_max_100_per_miner (self , synthetic_tasks ):
@@ -394,15 +394,15 @@ async def set_weights(self, scores):
394
394
self .moving_average_scores = alpha * scores + (1 - alpha ) * self .moving_average_scores
395
395
bt .logging .info (f"Updated moving average of weights: { self .moving_average_scores } " )
396
396
start_time = time .time ()
397
- self .subtensor .set_weights (
397
+ success , msg = self .subtensor .set_weights (
398
398
netuid = self .config .netuid ,
399
399
wallet = self .wallet ,
400
400
uids = self .metagraph .uids ,
401
401
weights = self .moving_average_scores ,
402
402
wait_for_inclusion = True ,
403
403
version_key = cortext .__weights_version__ ,
404
404
)
405
- bt .logging .success (f"Successfully included weights in block . { time .time () - start_time } elaspsed for updating weights." )
405
+ bt .logging .info (f"done setting weights: { success } , { msg } . { time .time () - start_time } elaspsed for updating weights." )
406
406
407
407
def blacklist_prompt (self , synapse : StreamPrompting ) -> Tuple [bool , str ]:
408
408
blacklist = self .base_blacklist (synapse , cortext .PROMPT_BLACKLIST_STAKE )
0 commit comments