trinity.buffer.storage package

Submodules

• trinity.buffer.storage.file module
  • FileStorage
    • FileStorage.__init__()
    • FileStorage.get_wrapper()
    • FileStorage.write()
    • FileStorage.read()
    • FileStorage.acquire()
    • FileStorage.release()
• trinity.buffer.storage.queue module
  • is_database_url()
  • is_json_file()
  • PriorityFunction
    • PriorityFunction.default_config()
  • LinearDecayPriority
    • LinearDecayPriority.__init__()
    • LinearDecayPriority.default_config()
  • LinearDecayUseCountControlPriority
    • LinearDecayUseCountControlPriority.__init__()
    • LinearDecayUseCountControlPriority.default_config()
  • QueueBuffer
    • QueueBuffer.set_min_model_version()
    • QueueBuffer.put()
    • QueueBuffer.get()
    • QueueBuffer.qsize()
    • QueueBuffer.close()
    • QueueBuffer.stopped()
    • QueueBuffer.get_queue()
  • AsyncQueue
    • AsyncQueue.__init__()
    • AsyncQueue.put()
    • AsyncQueue.get()
    • AsyncQueue.close()
    • AsyncQueue.stopped()
  • AsyncPriorityQueue
    • AsyncPriorityQueue.capacity
    • AsyncPriorityQueue.reuse_cooldown_time
    • AsyncPriorityQueue.priority_fn
    • AsyncPriorityQueue.priority_groups
    • AsyncPriorityQueue.__init__()
    • AsyncPriorityQueue.put()
    • AsyncPriorityQueue.get()
    • AsyncPriorityQueue.qsize()
    • AsyncPriorityQueue.close()
    • AsyncPriorityQueue.stopped()
  • QueueStorage
    • QueueStorage.__init__()
    • QueueStorage.acquire()
    • QueueStorage.release()
    • QueueStorage.length()
    • QueueStorage.put_batch()
    • QueueStorage.get_batch()
    • QueueStorage.get_wrapper()
• trinity.buffer.storage.sql module
  • SQLStorage
    • SQLStorage.__init__()
    • SQLStorage.get_wrapper()
    • SQLStorage.write()
    • SQLStorage.read()
    • SQLStorage.acquire()
    • SQLStorage.release()
  • SQLExperienceStorage
    • SQLExperienceStorage.__init__()
    • SQLExperienceStorage.write()
    • SQLExperienceStorage.read()
    • SQLExperienceStorage.load_from_dataset()
  • SQLTaskStorage
    • SQLTaskStorage.__init__()
    • SQLTaskStorage.write()
    • SQLTaskStorage.read()
    • SQLTaskStorage.load_from_dataset()

Module contents

class trinity.buffer.storage.PriorityFunction

Bases: ABC

Each priority_fn,

Args:

item: List[Experience], assume that all experiences in it have the same model_version and use_count priority_fn_args: Dict, the arguments for priority_fn

Returns:

priority: float put_into_queue: bool, decide whether to put item into queue

Note that put_into_queue takes effect both for new item from the explorer and for item sampled from the buffer.

abstract classmethod default_config() → Dict

Return the default config.