+ }i ^RIHt^RIHtHt^RIHt^RIHt^RI H t ^RI H t ^RI Ht]'d ^RIHt^R IHt] !R 4!R R ] ]44tR #)) annotations)ABCabstractmethod) timedelta) TYPE_CHECKING) docs_group) RequestLoader)ProcessedRequest)Sequence)RequestzRequest loadersc ]tRt^tRt]RRl4t]RR/RRll4tRRRR R ]!^R 7R RR R/RRllt ]RR/RRll4t Rt R#)RequestManagerzlBase class that extends `RequestLoader` with the capability to enqueue new requests and reclaim failed ones.cV^8dQhRR/#)returnNone)formats"z/Users/ahmad/.openclaw/workspace/my-crawler/.venv/lib/python3.14/site-packages/crawlee/request_loaders/_request_manager.py __annotate__RequestManager.__annotate__sffDfc "R#5i)zWRemove persistent state either from the Apify Cloud storage or from the local database.Nr)selfs&rdropRequestManager.drop forefrontFc$V^8dQhRRRRRR/#)rrequestz str | Requestrboolrr r)rs"rrrs(       rc "R#5i)a~Add a single request to the manager and store it in underlying resource client. Args: request: The request object (or its string representation) to be added to the manager. forefront: Determines whether the request should be added to the beginning (if True) or the end (if False) of the manager. Returns: Information about the request addition to the manager. Nrrr!rs&&$r add_requestRequestManager.add_requestrr batch_sizeiwait_time_between_batches)seconds!wait_for_all_requests_to_be_added)wait_for_all_requests_to_be_added_timeoutNc4V^8dQhRRRRRRRRR RR R R R /#)rrequestszSequence[str | Request]rr"r'intr(rr*r+ztimedelta | Nonerrr)rs"rrr+sQ99)9 9  9 $- 9,094D9 9rc "\\,!4pVF.pVPWR7GRjxL p VPV 4K0 R#L5i)aAdd requests to the manager in batches. Args: requests: Requests to enqueue. forefront: If True, add requests to the beginning of the queue. batch_size: The number of requests to add in one batch. wait_time_between_batches: Time to wait between adding batches. wait_for_all_requests_to_be_added: If True, wait for all requests to be added before returning. wait_for_all_requests_to_be_added_timeout: Timeout for waiting for all requests to be added. )rN)listr r%append) rr-rr'r(r*r+processed_requestsr!processed_requests &&$$$$$ r add_requestsRequestManager.add_requests+sI*""235G&*&6&6w&6&T T   % %&7 8 Ts1AAAc$V^8dQhRRRRRR/#)rr!r rr"rzProcessedRequest | Noner)rs"rrrFs"  W D Ul rc "R#5i)zReclaims a failed request back to the source, so that it can be returned for processing later again. It is possible to modify the request data by supplying an updated request as a parameter. Nrr$s&&$rreclaim_requestRequestManager.reclaim_requestErrr) __name__ __module__ __qualname____firstlineno____doc__rrr%rr4r8__static_attributes__rrrrrsvff    "9 9  9 09/C 9389GK94 5  rrN) __future__rabcrrdatetimertypingrcrawlee._utils.docsr'crawlee.request_loaders._request_loaderr crawlee.storage_clients.modelsr collections.abcr crawlee._requestr rrrrrIsF"# *A;(( 8 ]C8 8 r