(
        self, block: bool = True, timeout: Optional[float] = None
    )
return self.manifest.expect(node_id)
Get a node off the inner priority queue. By default, this blocks.

        This takes the lock, but only for part of it.

        :param block: If True, block until the inner queue has data
        :param timeout: If set, block for timeout seconds waiting for data.
        :return: The node as present in the manifest.

        See `queue.PriorityQueue` for more information on `get()` behavior and
        exceptions.
Get a node off the inner priority queue. By default, this blocks.
Get a node off the inner priority queue . By default this blocks .
def get(
        self, block: bool = True, timeout: Optional[float] = None
    ) -> GraphMemberNode:
        """Get a node off the inner priority queue. By default, this blocks.

        This takes the lock, but only for part of it.

        :param block: If True, block until the inner queue has data
        :param timeout: If set, block for timeout seconds waiting for data.
        :return: The node as present in the manifest.

        See `queue.PriorityQueue` for more information on `get()` behavior and
        exceptions.
        """
        _, node_id = self.inner.get(block=block, timeout=timeout)
        with self.lock:
            self._mark_in_progress(node_id)
        return self.manifest.expect(node_id)
def get ( self , block : bool = True , timeout : Optional [ float ] = None ) -> GraphMemberNode : _ , node_id = self . inner . get ( block = block , timeout = timeout ) with self . lock : self . _mark_in_progress ( node_id ) return self . manifest . expect ( node_id )