parameters: (cls,
                             server_address: str,
                             table: str,
                             max_in_flight_samples_per_worker: int,
                             num_workers_per_iterator: int = -1,
                             max_samples_per_stream: int = -1,
                             rate_limiter_timeout_ms: int = -1,
                             get_signature_timeout_secs: Optional[int] = None,
                             max_samples: int = -1)
return_statement: return cls(
          server_address=server_address,
          table=table,
          shapes=shapes,
          dtypes=dtypes,
          max_in_flight_samples_per_worker=max_in_flight_samples_per_worker,
          num_workers_per_iterator=num_workers_per_iterator,
          max_samples_per_stream=max_samples_per_stream,
          rate_limiter_timeout_ms=rate_limiter_timeout_ms,
          max_samples=max_samples)
docstring: Constructs a TimestepDataset using the table's signature to infer specs.
  
      Note: The target `Table` must specify a signature that represents a single
        timestep (as opposed to an entire trajectory). See `Table.__init__`
        (./server.py) for more details.
  
      Args:
        server_address: Address of gRPC ReverbService.
        table: Table to read the signature and sample from.
        max_in_flight_samples_per_worker: See __init__ for details.
        num_workers_per_iterator: See __init__ for details.
        max_samples_per_stream: See __init__ for details.
        rate_limiter_timeout_ms: See __init__ for details.
        get_signature_timeout_secs: Timeout in seconds to wait for server to
          respond when fetching the table signature. By default no timeout is set
          and the call will block indefinitely if the server does not respond.
        max_samples: See __init__ for details.
  
      Returns:
        TimestepDataset using the specs defined by the table signature to build
          `shapes` and `dtypes`.
  
      Raises:
        ValueError: If `table` does not exist on server at `server_address`.
        ValueError: If `table` does not have a signature.
        errors.DeadlineExceededError: If `get_signature_timeout_secs` provided and
          exceeded.
        ValueError: See __init__.
docstring_summary: Constructs a TimestepDataset using the table's signature to infer specs.
docstring_tokens: Constructs a TimestepDataset using the table s signature to infer specs .
function: def from_table_signature(cls,
                             server_address: str,
                             table: str,
                             max_in_flight_samples_per_worker: int,
                             num_workers_per_iterator: int = -1,
                             max_samples_per_stream: int = -1,
                             rate_limiter_timeout_ms: int = -1,
                             get_signature_timeout_secs: Optional[int] = None,
                             max_samples: int = -1):
      """Constructs a TimestepDataset using the table's signature to infer specs.
  
      Note: The target `Table` must specify a signature that represents a single
        timestep (as opposed to an entire trajectory). See `Table.__init__`
        (./server.py) for more details.
  
      Args:
        server_address: Address of gRPC ReverbService.
        table: Table to read the signature and sample from.
        max_in_flight_samples_per_worker: See __init__ for details.
        num_workers_per_iterator: See __init__ for details.
        max_samples_per_stream: See __init__ for details.
        rate_limiter_timeout_ms: See __init__ for details.
        get_signature_timeout_secs: Timeout in seconds to wait for server to
          respond when fetching the table signature. By default no timeout is set
          and the call will block indefinitely if the server does not respond.
        max_samples: See __init__ for details.
  
      Returns:
        TimestepDataset using the specs defined by the table signature to build
          `shapes` and `dtypes`.
  
      Raises:
        ValueError: If `table` does not exist on server at `server_address`.
        ValueError: If `table` does not have a signature.
        errors.DeadlineExceededError: If `get_signature_timeout_secs` provided and
          exceeded.
        ValueError: See __init__.
      """
      client = reverb_client.Client(server_address)
      info = client.server_info(get_signature_timeout_secs)
      if table not in info:
        raise ValueError(
            f'Server at {server_address} does not contain any table named '
            f'{table}. Found: {", ".join(sorted(info.keys()))}.')
  
      if not info[table].signature:
        raise ValueError(
            f'Table {table} at {server_address} does not have a signature.')
  
      shapes = tree.map_structure(lambda x: x.shape, info[table].signature)
      dtypes = tree.map_structure(lambda x: x.dtype, info[table].signature)
  
      return cls(
          server_address=server_address,
          table=table,
          shapes=shapes,
          dtypes=dtypes,
          max_in_flight_samples_per_worker=max_in_flight_samples_per_worker,
          num_workers_per_iterator=num_workers_per_iterator,
          max_samples_per_stream=max_samples_per_stream,
          rate_limiter_timeout_ms=rate_limiter_timeout_ms,
          max_samples=max_samples)
function_tokens: def from_table_signature ( cls , server_address : str , table : str , max_in_flight_samples_per_worker : int , num_workers_per_iterator : int = - 1 , max_samples_per_stream : int = - 1 , rate_limiter_timeout_ms : int = - 1 , get_signature_timeout_secs : Optional [ int ] = None , max_samples : int = - 1 ) : client = reverb_client . Client ( server_address ) info = client . server_info ( get_signature_timeout_secs ) if table not in info : raise ValueError ( f'Server at {server_address} does not contain any table named ' f'{table}. Found: {", ".join(sorted(info.keys()))}.' ) if not info [ table ] . signature : raise ValueError ( f'Table {table} at {server_address} does not have a signature.' ) shapes = tree . map_structure ( lambda x : x . shape , info [ table ] . signature ) dtypes = tree . map_structure ( lambda x : x . dtype , info [ table ] . signature ) return cls ( server_address = server_address , table = table , shapes = shapes , dtypes = dtypes , max_in_flight_samples_per_worker = max_in_flight_samples_per_worker , num_workers_per_iterator = num_workers_per_iterator , max_samples_per_stream = max_samples_per_stream , rate_limiter_timeout_ms = rate_limiter_timeout_ms , max_samples = max_samples )