class_docstr: Represents a Reverb replay buffer in a Launchpad program.
class_docstr_tok: ["Represents","a","Reverb","replay","buffer","in","a","Launchpad","program","."]
code: def run(self):
      priority_tables = self._priority_tables_fn()
      if self._checkpoint_ctor is None:
          checkpointer = None
      else:
          checkpointer = self._checkpoint_ctor()
  
      self._server = reverb.Server(
          tables=priority_tables,
          port=lp_address.get_port_from_address(
              self._address.resolve()
          ),
          checkpointer=checkpointer,
      )
  
      if self._checkpoint_time_delta_minutes is not None:
          while not worker_manager_migration.wait_for_stop(
              self._checkpoint_time_delta_minutes * 60
          ):
              self._server.localhost_client().checkpoint()
      else:
          worker_manager_migration.wait_for_stop()
  
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 3 for calling the ReverbNode obj's underlying member method code with example usage: obj.run() without return types