RequestQueueClient

Subclient for manipulating a single request queue.

Hierarchy

• BaseRequestQueueClient
  • RequestQueueClient

Index

Methods

• __init__
• add_request
• batch_add_requests
• batch_delete_requests
• delete
• delete_request
• delete_request_lock
• get
• get_request
• list_and_lock_head
• list_head
• prolong_request_lock
• update
• update_request
• update_timestamps

Properties

• resource_directory
• resource_info

Methods

__init__

• __init__(*, memory_storage_client, id, name, created_at, accessed_at, modified_at, handled_request_count, pending_request_count): None

• Parameters

  • optionalkeyword-onlymemory_storage_client: MemoryStorageClient

  • optionalkeyword-onlyid: str | None = None

  • optionalkeyword-onlyname: str | None = None

  • optionalkeyword-onlycreated_at: datetime | None = None

  • optionalkeyword-onlyaccessed_at: datetime | None = None

  • optionalkeyword-onlymodified_at: datetime | None = None

  • optionalkeyword-onlyhandled_request_count: int = 0

  • optionalkeyword-onlypending_request_count: int = 0

  Returns None

add_request

• async add_request(*, request, forefront): ProcessedRequest

• Add a request to the queue.

  ---

  Parameters

  • optionalkeyword-onlyrequest: Request

    The request to add to the queue.

  • optionalkeyword-onlyforefront: bool = False

    Whether to add the request to the head or the end of the queue.

  Returns ProcessedRequest

batch_add_requests

• async batch_add_requests(*, requests, forefront): BatchRequestsOperationResponse

• Add a batch of requests to the queue.

  ---

  Parameters

  • optionalkeyword-onlyrequests: Sequence[Request]

    The requests to add to the queue.

  • optionalkeyword-onlyforefront: bool = False

    Whether to add the requests to the head or the end of the queue.

  Returns BatchRequestsOperationResponse

batch_delete_requests

• async batch_delete_requests(*, requests): BatchRequestsOperationResponse

• Delete given requests from the queue.

  ---

  Parameters

  • optionalkeyword-onlyrequests: list[Request]

    The requests to delete from the queue.

  Returns BatchRequestsOperationResponse

delete

• async delete(): None

• Permanently delete the request queue managed by this client.

  ---

  Returns None

delete_request

• async delete_request(*, request_id): None

• Delete a request from the queue.

  ---

  Parameters

  • optionalkeyword-onlyrequest_id: str

    ID of the request to delete.

  Returns None

delete_request_lock

• async delete_request_lock(*, request_id, forefront): None

• Delete the lock on a specific request in the queue.

  ---

  Parameters

  • optionalkeyword-onlyrequest_id: str

    ID of the request to delete the lock.

  • optionalkeyword-onlyforefront: bool = False

    Whether to put the request in the beginning or the end of the queue after the lock is deleted.

  Returns None

get

• async get(): RequestQueueMetadata | None

• Get metadata about the request queue being managed by this client.

  ---

  Returns RequestQueueMetadata | None

get_request

• async get_request(*, request_id): Request | None

• Retrieve a request from the queue.

  ---

  Parameters

  • optionalkeyword-onlyrequest_id: str

    ID of the request to retrieve.

  Returns Request | None

list_and_lock_head

• async list_and_lock_head(*, lock_secs, limit): RequestQueueHeadWithLocks

• Fetch and lock a specified number of requests from the start of the queue.

  Retrieves and locks the first few requests of a queue for the specified duration. This prevents the requests from being fetched by another client until the lock expires.

  ---

  Parameters

  • optionalkeyword-onlylock_secs: int

    Duration for which the requests are locked, in seconds.

  • optionalkeyword-onlylimit: int | None = None

    Maximum number of requests to retrieve and lock.

  Returns RequestQueueHeadWithLocks

list_head

• async list_head(*, limit): RequestQueueHead

• Retrieve a given number of requests from the beginning of the queue.

  ---

  Parameters

  • optionalkeyword-onlylimit: int | None = None

    How many requests to retrieve.

  Returns RequestQueueHead

prolong_request_lock

• async prolong_request_lock(*, request_id, forefront, lock_secs): ProlongRequestLockResponse

• Prolong the lock on a specific request in the queue.

  ---

  Parameters

  • optionalkeyword-onlyrequest_id: str

    The identifier of the request whose lock is to be prolonged.

  • optionalkeyword-onlyforefront: bool = False

    Whether to put the request in the beginning or the end of the queue after lock expires.

  • optionalkeyword-onlylock_secs: int

    The additional amount of time, in seconds, that the request will remain locked.

  Returns ProlongRequestLockResponse

update

• async update(*, name): RequestQueueMetadata

• Update the request queue metadata.

  ---

  Parameters

  • optionalkeyword-onlyname: str | None = None

    New new name for the request queue.

  Returns RequestQueueMetadata

update_request

• async update_request(*, request, forefront): ProcessedRequest

• Update a request in the queue.

  ---

  Parameters

  • optionalkeyword-onlyrequest: Request

    The updated request.

  • optionalkeyword-onlyforefront: bool = False

    Whether to put the updated request in the beginning or the end of the queue.

  Returns ProcessedRequest

update_timestamps

• async update_timestamps(*, has_been_modified): None

• Update the timestamps of the request queue.

  ---

  Parameters

  • optionalkeyword-onlyhas_been_modified: bool

  Returns None

Properties

resource_directory

resource_directory: str

Get the resource directory for the client.

resource_info

resource_info: RequestQueueMetadata

Get the resource info for the request queue client.