toloka.streaming.observer.AssignmentsObserver | Source code
AssignmentsObserver( self, toloka_client: Union[TolokaClient, AsyncTolokaClient], pool_id: str, cursor_time_lag: timedelta = ..., *, name: Optional[str] = None)Observer for the pool's assignment events.
For usage with Pipeline.
Allow to register callbacks using the following methods:
Corresponding assignment events 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. |
cursor_time_lag | timedelta | Time lag for cursor. This controls time lag between assignments being added and them being seen by this observer. See BaseCursor.time_lag for details and reasoning behind this. |
Examples:
Send submitted assignments for verification.
def handle_submitted(evets: List[AssignmentEvent]) -> None: verification_tasks = [create_veridication_task(item.assignment) for item in evets] toloka_client.create_tasks(verification_tasks, open_pool=True)observer = AssignmentsObserver(toloka_client, pool_id='123')observer.on_submitted(handle_submitted)| Method | Description |
|---|---|
| get_unique_key | None |
| inject | None |
| on_accepted | None |
| on_any_event | None |
| on_created | None |
| on_expired | None |
| on_rejected | None |
| on_skipped | None |
| on_submitted | None |
| register_callback | Register given callable for given event type. |
Last updated: August 28, 2023