Index
Methods
- async add_batch_of_requests(requests, *, forefront): AddRequestsResponse
Parameters
requests: Sequence[Request]
optionalkeyword-onlyforefront: bool = False
Returns AddRequestsResponse
- async drop(): None
Returns None
- async fetch_next_request(): Request | None
Returns Request | None
- async get_metadata(): RequestQueueMetadata
- async get_request(unique_key): Request | None
Parameters
unique_key: str
Returns Request | None
- async is_empty(): bool
Returns bool
- async mark_request_as_handled(request): ProcessedRequest | None
Parameters
request: Request
Returns ProcessedRequest | None
- async purge(): None
Returns None
- async reclaim_request(request, *, forefront): ProcessedRequest | None
Parameters
request: Request
optionalkeyword-onlyforefront: bool = False
Returns ProcessedRequest | None