@@ -262,7 +262,7 @@ async def score(self):
262
262
except Exception as e :
263
263
bt .logging .error (f"Error storing results to database: { e } " )
264
264
265
- async def synthensize_task (self , session :int , task_index :int ):
265
+ async def synthensize_task (self , session :int , task_number :int ):
266
266
try :
267
267
with self .lock :
268
268
if len (self .synthetic_tasks ) > MAX_SYNTHETIC_TASK_SIZE :
@@ -276,7 +276,7 @@ async def synthensize_task(self, session:int, task_index:int):
276
276
weights = [weight for _ , weight in self .task_generators ],
277
277
)[0 ]
278
278
279
- task , synapse = await task_generator .generate_task (session = session , task_index = task_index )
279
+ task , synapse = await task_generator .generate_task (session = session , task_number = task_number )
280
280
with self .lock :
281
281
self .synthetic_tasks .append ((task , synapse ))
282
282
@@ -286,36 +286,36 @@ async def synthensize_task(self, session:int, task_index:int):
286
286
bt .logging .error (f"Error in synthensize_task: { e } " )
287
287
raise e
288
288
289
- def get_seed (self , session : int , task_index : int , hash_cache : dict = {}) -> int :
289
+ def get_seed (self , session : int , task_number : int , hash_cache : dict = {}) -> int :
290
290
if session not in hash_cache :
291
291
session_start_block = session * SESSION_WINDOW_BLOCKS
292
292
subtensor = self .neuron .subtensor
293
293
block_hash = subtensor .get_block_hash (session_start_block )
294
294
hash_cache [session ] = int (block_hash [- 15 :], 16 )
295
- return int (hash_cache [session ] + task_index )
295
+ return int (hash_cache [session ] + task_number )
296
296
297
297
async def forward (self ):
298
298
try :
299
299
with self .lock :
300
300
session = self .neuron .session
301
301
if self .neuron .score_manager .current_session != session :
302
- task_index = 0
302
+ task_number = 0
303
303
else :
304
- task_index = self .neuron .score_manager .number_of_tasks
304
+ task_number = self .neuron .score_manager .number_of_tasks
305
305
306
- if task_index >= MAX_NUMBER_OF_TASKS_PER_SESSION :
306
+ if task_number >= MAX_NUMBER_OF_TASKS_PER_SESSION :
307
307
return
308
308
309
- bt .logging .info (f"Forwarding task #{ task_index } in session #{ session } " )
310
- # seed = self.get_seed(session, task_index )
309
+ bt .logging .info (f"Forwarding task #{ task_number } in session #{ session } " )
310
+ # seed = self.get_seed(session, task_number )
311
311
312
312
# bt.logging.info(f"Init random with seed: {seed}")
313
313
# random.seed(seed)
314
314
# set_seed(seed)
315
315
316
316
try :
317
- task , synapse = await self .synthensize_task (session , task_index )
318
- task .task_id = f"{ session } _{ task_index } "
317
+ task , synapse = await self .synthensize_task (session , task_number )
318
+ task .task_id = f"{ session } _{ task_number } "
319
319
synapse .task_id = task .task_id
320
320
except Exception as e :
321
321
bt .logging .error (
0 commit comments