register

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

register(self, observer: BaseObserver)
Copy text

Register given observer.

Parameters description

• Returns:

  The same observer object. It's usable to write one-liners.

• Return type:

  BaseObserver

Examples:

Register observer.

observer = SomeObserver(pool_id='123')
observer.do_some_preparations(...)
toloka_loop.register(observer)
Copy text

One-line version.

toloka_loop.register(SomeObserver(pool_id='123')).do_some_preparations(...)
Copy text

Last updated: August 28, 2023