parameters: (self, table: str, priority: float, trajectory: Any)
docstring: Enqueue insertion of an item into `table` referencing `trajectory`.
  
      Note! This method does NOT BLOCK and therefore is not impacted by the table
      rate limiter. To prevent unwanted runahead, `flush` must be called.
  
      Before creating an item, `trajectory` is validated.
  
       * Only contain `TrajectoryColumn` objects.
       * All data references must be alive (i.e not yet expired).
       * Data references within a column must have the same dtype and shape.
  
      Args:
        table: Name of the table to insert the item into.
        priority: The priority used for determining the sample probability of the
          new item.
        trajectory: A structure of `TrajectoryColumn` objects. The structure is
          flattened before passed to the C++ writer.
  
      Raises:
        TypeError: If trajectory is invalid.
docstring_summary: Enqueue insertion of an item into `table` referencing `trajectory`.
docstring_tokens: Enqueue insertion of an item into table referencing trajectory .
function: def create_item(self, table: str, priority: float, trajectory: Any):
      """Enqueue insertion of an item into `table` referencing `trajectory`.
  
      Note! This method does NOT BLOCK and therefore is not impacted by the table
      rate limiter. To prevent unwanted runahead, `flush` must be called.
  
      Before creating an item, `trajectory` is validated.
  
       * Only contain `TrajectoryColumn` objects.
       * All data references must be alive (i.e not yet expired).
       * Data references within a column must have the same dtype and shape.
  
      Args:
        table: Name of the table to insert the item into.
        priority: The priority used for determining the sample probability of the
          new item.
        trajectory: A structure of `TrajectoryColumn` objects. The structure is
          flattened before passed to the C++ writer.
  
      Raises:
        TypeError: If trajectory is invalid.
      """
      flat_trajectory = tree.flatten(trajectory)
      if not all(isinstance(col, TrajectoryColumn) for col in flat_trajectory):
        raise TypeError(
            f'All leaves of `trajectory` must be `TrajectoryColumn` but got '
            f'{trajectory}')
  
      # Pass the flatten trajectory to the C++ writer where it will be validated
      # and if successful then the item is created and enqued for the background
      # worker to send to the server.
      self._writer.CreateItem(table, priority,
                              [list(column) for column in flat_trajectory],
                              [column.is_squeezed for column in flat_trajectory])
function_tokens: def create_item ( self , table : str , priority : float , trajectory : Any ) : flat_trajectory = tree . flatten ( trajectory ) if not all ( isinstance ( col , TrajectoryColumn ) for col in flat_trajectory ) : raise TypeError ( f'All leaves of `trajectory` must be `TrajectoryColumn` but got ' f'{trajectory}' ) # Pass the flatten trajectory to the C++ writer where it will be validated # and if successful then the item is created and enqued for the background # worker to send to the server. self . _writer . CreateItem ( table , priority , [ list ( column ) for column in flat_trajectory ] , [ column . is_squeezed for column in flat_trajectory ] )