observers_iter

toloka.streaming.pipeline.Pipeline.observers_iter | Source code

observers_iter(self)

Iterate over registered observers.

• Returns:

  An iterator over all registered observers except deleted ones. Might contain observers scheduled for deletion and not deleted yet.

• Return type:

  Iterator[BaseObserver]