AssignmentCursor
toloka.streaming.cursor.AssignmentCursor
| Source code
AssignmentCursor(
self,
toloka_client: Union[TolokaClient, AsyncTolokaClient],
event_type: Any,
status: Union[str, Assignment.Status, List[Union[str, Assignment.Status]], None] = None,
task_id: Optional[str] = None,
task_suite_id: Optional[str] = None,
pool_id: Optional[str] = None,
user_id: Optional[str] = None,
id_lt: Optional[str] = None,
id_lte: Optional[str] = None,
id_gt: Optional[str] = None,
id_gte: Optional[str] = None,
created_lt: Optional[datetime] = None,
created_lte: Optional[datetime] = None,
created_gt: Optional[datetime] = None,
created_gte: Optional[datetime] = None,
submitted_lt: Optional[datetime] = None,
submitted_lte: Optional[datetime] = None,
submitted_gt: Optional[datetime] = None,
submitted_gte: Optional[datetime] = None,
accepted_lt: Optional[datetime] = None,
accepted_lte: Optional[datetime] = None,
accepted_gt: Optional[datetime] = None,
accepted_gte: Optional[datetime] = None,
rejected_lt: Optional[datetime] = None,
rejected_lte: Optional[datetime] = None,
rejected_gt: Optional[datetime] = None,
rejected_gte: Optional[datetime] = None,
skipped_lt: Optional[datetime] = None,
skipped_lte: Optional[datetime] = None,
skipped_gt: Optional[datetime] = None,
skipped_gte: Optional[datetime] = None,
expired_lt: Optional[datetime] = None,
expired_lte: Optional[datetime] = None,
expired_gt: Optional[datetime] = None,
expired_gte: Optional[datetime] = None
)
Iterator over Assignment objects of seleted AssignmentEventType.
Parameters Description
Parameters | Type | Description |
---|---|---|
toloka_client |
Union[TolokaClient, AsyncTolokaClient] | TolokaClient object that is being used to search assignments. |
request |
AssignmentSearchRequest | Base request to search assignments by. |
event_type |
Any | Assignments event's type to search. |
Examples:
Iterate over assignment acceptances events.
it = AssignmentCursor(pool_id='123', event_type='ACCEPTED', toloka_client=toloka_client)
current_events = list(it)
new_events = list(it) # Contains only new events, occured since the previous call.