toloka.streaming.observer.PoolStatusObserver | Source code
PoolStatusObserver( self, 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:
The Pool object will be passed to the triggered callbacks.
| Parameters | Type | Description |
|---|---|---|
toloka_client | AsyncInterfaceWrapper[Union[TolokaClient, AsyncTolokaClient]] | TolokaClient instance or async wrapper around it. |
pool_id | str | Pool ID. |
Examples:
Bind to the pool's close to make some aggregations.
def call_this_on_close(pool: Pool) -> None: assignments = client.get_assignments_df(pool_id=pool.id, status=['APPROVED']) do_some_aggregation(assignments)observer = PoolStatusObserver(toloka_client, pool_id='123')observer.on_close(call_this_on_close)Call something at any status change.
observer.on_status_change(lambda pool: ...)| Method | Description |
|---|---|
| get_unique_key | None |
| 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. |
Last updated: August 28, 2023