yr.fnruntime.Consumer.ack

Consumer.ack(self, int element_id: int) → None

After the consumer finishes using the element identified by element_id, it must acknowledge (ack) the element. This allows all workers to determine whether all consumers have finished processing the data. Once a page has been fully consumed, internal memory reclamation may be triggered.

Parameters:

element_id (int) – The ID of the element to acknowledge.

Raises:

RuntimeError – If acknowledging the element fails.

Returns:

None.