class_docstr: Represents a Reverb replay buffer in a Launchpad program.
class_docstr_tok: ["Represents","a","Reverb","replay","buffer","in","a","Launchpad","program","."]
docstr: Initialize a ReverbNode.
  
  Args:
    priority_tables_fn: A function that returns a sequence of tables to host
      on the server.
    checkpoint_ctor: Constructor for the checkpointer to be used. Passing None
      uses Reverb's default checkpointer.
    checkpoint_time_delta_minutes: Time between async (non-blocking)
      checkpointing calls.
docstr_tok: ["Initialize","a","ReverbNode",".","Args",":","priority_tables_fn",":","A","function","that","returns","a","sequence","of","tables","to","host","on","the","server",".","checkpoint_ctor",":","Constructor","for","the","checkpointer","to","be","used",".","Passing","None","uses","Reverb","'s","default","checkpointer",".","checkpoint_time_delta_minutes",":","Time","between","async","(","non-blocking",")","checkpointing","calls","."]
code: def __init__(
      self,
      priority_tables_fn: PriorityTablesFactory,
      checkpoint_ctor: Optional[CheckpointerFactory] = None,
      checkpoint_time_delta_minutes: Optional[int] = None,
  ):
      """Initialize a ReverbNode.
  
      Args:
        priority_tables_fn: A function that returns a sequence of tables to host
          on the server.
        checkpoint_ctor: Constructor for the checkpointer to be used. Passing None
          uses Reverb's default checkpointer.
        checkpoint_time_delta_minutes: Time between async (non-blocking)
          checkpointing calls.
      """
      super().__init__(self.run)
      self._priority_tables_fn = priority_tables_fn
      self._checkpoint_ctor = checkpoint_ctor
      self._checkpoint_time_delta_minutes = (
          checkpoint_time_delta_minutes
      )
      self._address = lp_address.Address(REVERB_PORT_NAME)
      self.allocate_address(self._address)
  
      if (
          self._checkpoint_time_delta_minutes is not None
          and self._checkpoint_time_delta_minutes <= 0
      ):
          raise ValueError(
              "Replay checkpoint time delta must be positive when specified."
          )
  
file_path: launchpad/launchpad/nodes/reverb/node.py
imports: from typing import Any, Callable, Optional, Sequence
  from absl import logging
  from launchpad import address
  from launchpad import context
  from launchpad.launch import worker_manager_migration
  from launchpad.nodes import base
  from launchpad.nodes.python import node
  import reverb
label_desc: Use image node_id 1 to create a new ReverbNode object from inherited base classes: python with example: obj = ReverbNode(priority_tables_fn, checkpoint_ctor, checkpoint_time_delta_minutes)