We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5323f67 commit 86c0fb6Copy full SHA for 86c0fb6
trinity/buffer/storage/queue.py
@@ -302,7 +302,7 @@ def __init__(self, config: StorageConfig) -> None:
302
self.logger = get_logger(f"queue_{config.name}", in_ray_actor=True)
303
self.config = config
304
self.capacity = config.capacity
305
- self.staleness_limit = config.max_staleness # Optional[int]
+ self.staleness_limit = config.staleness_limit # Optional[int]
306
self.max_model_version = 0 # max model version that queue has seen so far
307
self.queue = QueueBuffer.get_queue(config)
308
st_config = deepcopy(config)
0 commit comments