Toloka documentation

PoolStatusObserver | Source code

    toloka_client: Union[TolokaClient, AsyncTolokaClient],
    pool_id: str,
    name: Optional[str] = None

Observer for pool status change.

For usage with Pipeline.

Allow to register callbacks using the following methods: * on_open * on_closed * on_archieved * on_locked * on_status_change

The Pool object will be passed to the triggered callbacks.

Parameters Description

Parameters Type Description
toloka_client AsyncInterfaceWrapper[Union[TolokaClient, AsyncTolokaClient]]

TolokaClient instance or async wrapper around it.

pool_id str

Pool ID.


Bind to the pool's close to make some aggregations.

def call_this_on_close(pool: Pool) -> None:
    assignments = client.get_assignments_df(, status=['APPROVED'])
observer = PoolStatusObserver(toloka_client, pool_id='123')

Call something at any status change.

observer.on_status_change(lambda pool: ...)

Methods Summary

Method Description
inject None
on_archieved None
on_closed None
on_locked None
on_open None
on_status_change None
register_callback Register given callable for pool status change to given value.