i?1iSddlmZddlmZddlmZmZmZddlm Z ddl m Z m Z ddl mZmZGddeZGd d eZy ) ) annotations)Any)"filter_out_none_values_recursively ignore_docsparse_date_fields) ApifyApiError)catch_not_found_or_throw pluck_data)ResourceClientResourceClientAsyncceZdZdZedd dfdZddZddddZddZdd dd Z dd dd Z dd dd Z ddZ dd ddZ ddZdd  d dZdd d!dZdd  d"dZd#dZddd d$dZxZS)%RequestQueueClientz3Sub-client for manipulating a single request queue.N client_keycZ|jdd}t||d|i|||_y)zInitialize the RequestQueueClient. Args: client_key (str, optional): A unique identifier of the client accessing the request queue resource_pathrequest-queuesNpopsuper__init__rselfrargskwargsr __class__s }/home/www/therecruiter.miabetepe.com/venv/lib/python3.12/site-packages/apify_client/clients/resource_clients/request_queue.pyrzRequestQueueClient.__init__4 ?4DE  $FmFvF$c"|jS)Retrieve the request queue. https://docs.apify.com/api/v2#/reference/request-queues/queue/get-request-queue Returns: dict, optional: The retrieved request queue, or None, if it does not exist _getrs rgetzRequestQueueClient.getsyy{rnamec>d|i}|jt|S)&Update the request queue with specified fields. https://docs.apify.com/api/v2#/reference/request-queues/queue/update-request-queue Args: name (str, optional): The new name for the request queue Returns: dict: The updated request queue r'_updaterrr'updated_fieldss rupdatezRequestQueueClient.update)s' D ||>~NOOrc"|jS)~Delete the request queue. https://docs.apify.com/api/v2#/reference/request-queues/queue/delete-request-queue _deleter$s rdeletezRequestQueueClient.delete:s ||~rlimitc|j||j}|jj|j dd|}t t |jS)VRetrieve a given number of requests from the beginning of the queue. https://docs.apify.com/api/v2#/reference/request-queues/queue-head/get-head Args: limit (int, optional): How many requests to retrieve Returns: dict: The desired number of requests from the beginning of the queue. r5 clientKeyheadGETurlmethodparams_paramsr http_clientcall_urlrr jsonrr5request_paramsresponses r list_headzRequestQueueClient.list_headAs_ET__M##(( &!!)  !HMMO!<==rc|j|||j}|jj|j dd|}t t |jS)Retrieve a given number of unlocked requests from the beginning of the queue and lock them for a given time. https://docs.apify.com/api/v2#/reference/request-queues/queue-head-with-locks/get-head-and-lock Args: lock_secs (int): How long the requests will be locked for, in seconds limit (int, optional): How many requests to retrieve Returns: dict: The desired number of locked requests from the beginning of the queue. lockSecsr5r9 head/lockPOSTr<r@r lock_secsr5rGrHs rlist_and_lock_headz%RequestQueueClient.list_and_lock_headVsdyQUQ`Q`a##(( +&!)  !HMMO!<==r forefrontc|j||j}|jj|j dd||}t t |jS)mAdd a request to the queue. https://docs.apify.com/api/v2#/reference/request-queues/request-collection/add-request Args: request (dict): The request to add to the queue forefront (bool, optional): Whether to add the request to the head or the end of the queue Returns: dict: The added request. rTr9requestsrOr=r>rEr?r@rrequestrTrGrHs r add_requestzRequestQueueClient.add_requestmsb T__U##(( *%! ) !HMMO!<==rc |jj|jd|d|j}t t |j S#t$r}t|Yd}~yd}~wwxYwa.Retrieve a request from the queue. https://docs.apify.com/api/v2#/reference/request-queues/request/get-request Args: request_id (str): ID of the request to retrieve Returns: dict, optional: The retrieved request, or None, if it did not exist. requests/r;r<N rBrCrDrArr rErr r request_idrHexcs r get_requestzRequestQueueClient.get_requestsw *'',,II *67||~-H %Z %@A A * $S ) ) *sAA"" B+ A;;Bc|d}|j||j}|jj|j d|d||}t t |jS)jUpdate a request in the queue. https://docs.apify.com/api/v2#/reference/request-queues/request/update-request Args: request (dict): The updated request forefront (bool, optional): Whether to put the updated request in the beginning or the end of the queue Returns: dict: The updated request idrWr_PUTrYr@rr[rTrbrGrHs rupdate_requestz!RequestQueueClient.update_requestsrT]  T__U##(( Ij\23! ) !HMMO!<==rc|j|j}|jj|j d|d|yzDelete a request from the queue. https://docs.apify.com/api/v2#/reference/request-queues/request/delete-request Args: request_id (str): ID of the request to delete. r9r_DELETEr<NrArrBrCrDrrbrGs rdelete_requestz!RequestQueueClient.delete_requestsRoo&   Ij\23!  rc|j|j||}|jj|j d|dd|}t t |jS)Prolong the lock on a request. https://docs.apify.com/api/v2#/reference/request-queues/request-lock/prolong-request-lock Args: request_id (str): ID of the request to prolong the lock forefront (bool, optional): Whether to put the request in the beginning or the end of the queue after lock expires lock_secs (int): By how much to prolong the lock, in seconds r9rTrMr_/lockrhr<r@rrbrTrQrGrHs rprolong_request_lockz'RequestQueueClient.prolong_request_locksk 9_hi##(( Ij\78!)  !HMMO!<==rc|j|j|}|jj|j d|dd|ya`Delete the lock on a request. https://docs.apify.com/api/v2#/reference/request-queues/request-lock/delete-request-lock Args: request_id (str): ID of the request to delete the lock forefront (bool, optional): Whether to put the request in the beginning or the end of the queue after the lock is deleted r9rTr_rurnr<NrorrbrTrGs rdelete_request_lockz&RequestQueueClient.delete_request_locksN9U  Ij\78!  rc|j|j|}|jj|j dd||}t t |jS)@Add requests to the queue. https://docs.apify.com/api/v2#/reference/request-queues/batch-request-operations/add-requests Args: requests (list[dict]): list of the requests to add forefront (bool, optional): Whether to add the requests to the head or the end of the queue rzrequests/batchrOr=r>r?rEr@rrXrTrGrHs rbatch_add_requestsz%RequestQueueClient.batch_add_requestssc9U##(( *+! )  !HMMO!<==rc|j|j}|jj|j dd||}t t |jS)Delete given requests from the queue. https://docs.apify.com/api/v2#/reference/request-queues/batch-request-operations/delete-requests Args: requests (list[dict]): list of the requests to delete rmrrnrr@rrXrGrHs rbatch_delete_requestsz(RequestQueueClient.batch_delete_requests sa@##(( *+! ) !HMMO!<==rr5exclusive_start_idc|j|||j}|jj|j dd|}t t |jS)JList requests in the queue. https://docs.apify.com/api/v2#/reference/request-queues/request-collection/list-requests Args: limit (int, optional): How many requests to retrieve exclusive_start_id (str, optional): All requests up to this one (including) are skipped from the result r5rr9rXr;r<r@rr5rrGrHs r list_requestsz RequestQueueClient.list_requestsseEFXdhdsdst##(( *%!)  !HMMO!<==r) rrrrr str | NonerrreturnNone)rrr dict | None)rrr'rrdict)rrrr)rrr5 int | Nonerr)rrrQintr5rrr)rrr[rrT bool | Nonerr)rrrbstrrr)rrrbrrr) rrrbrrTrrQrrr)rrrbrrTrrr)rrrX list[dict]rTrrr)rrrXrrr)rrr5rrrrr__name__ __module__ __qualname____doc__rrr%r.r3rIrRr\rdrjrqrwr|rrr __classcell__rs@rrr sF="& %  % % % %  % %@DP"DH>*]a>.Z^>.0]a>2 ,"& > >> >  >  >4dh *"& > >> >  >0>,!)- > >>' >  >rrc*eZdZdZedd dfdZddZddddZddZdd dd Z dd dd Z dd dd Z ddZ dd ddZ ddZdd  d dZdd  d!dZdd  d"dZd#dZddd d$dZxZS)%RequestQueueClientAsyncz9Async sub-client for manipulating a single request queue.NrcZ|jdd}t||d|i|||_y)zInitialize the RequestQueueClientAsync. Args: client_key (str, optional): A unique identifier of the client accessing the request queue rrNrrs rrz RequestQueueClientAsync.__init__9rrc>K|jd{S7w)r!Nr"r$s rr%zRequestQueueClientAsync.getIsYY[   r&cZKd|i}|jt|d{S7w)r)r'Nr*r,s rr.zRequestQueueClientAsync.updateSs1 D \\"D^"TUUUUs "+)+c>K|jd{S7w)r0Nr1r$s rr3zRequestQueueClientAsync.deleteds \\^###rr4cK|j||j}|jj|j dd|d{}t t |jS7&w)r7r8r:r;r<Nr@rFs rrIz!RequestQueueClientAsync.list_headksmET__M)).. &!!/   !HMMO!<==  AA9A7'A9cK|j|||j}|jj|j dd|d{}t t |jS7&w)rKrLrNrOr<Nr@rPs rrRz*RequestQueueClientAsync.list_and_lock_headsryQUQ`Q`a)).. +&!/   !HMMO!<==  AA:A8'A:rScK|j||j}|jj|j dd||d{}t t |jS7&w)rVrWrXrOrYNr@rZs rr\z#RequestQueueClientAsync.add_requestsp T__U)).. *%! /  !HMMO!<== rc"K |jj|jd|d|jd{}t t |j S7&#t$r}t|Yd}~yd}~wwxYwwr^r`ras rrdz#RequestQueueClientAsync.get_requests *!--22II *67||~3H %Z %@A A  * $S ) ) *sABAA.A,%A.+B,A.. B 7 BBB  BcK|d}|j||j}|jj|j d|d||d{}t t |jS7&w)rfrgrWr_rhrYNr@ris rrjz&RequestQueueClientAsync.update_requestsT]  T__U)).. Ij\23! /  !HMMO!<== sABB'BcK|j|j}|jj|j d|d|d{y7wrlrorps rrqz&RequestQueueClientAsync.delete_requestsX@## Ij\23!$   sAAAAcK|j|j||}|jj|j d|dd|d{}t t |jS7&w)rsrtr_rurhr<Nr@rvs rrwz,RequestQueueClientAsync.prolong_request_locksy 9_hi)).. Ij\78!/   !HMMO!<==  sAA>A<'A>cK|j|j|}|jj|j d|dd|d{y7wryror{s rr|z+RequestQueueClientAsync.delete_request_lock s\9U## Ij\78!$   sAAAAcK|j|j|}|jj|j dd||d{}t t |jS7&w)r~rzrrOrNr@rs rrz*RequestQueueClientAsync.batch_add_requestssq9U)).. *+! /   !HMMO!<==  rcK|j|j}|jj|j dd||d{}t t |jS7&w)rrmrrnrNr@rs rrz-RequestQueueClientAsync.batch_delete_requests7so@)).. *+! /   !HMMO!<==  rrcK|j|||j}|jj|j dd|d{}t t |jS7&w)rrrXr;r<Nr@rs rrz%RequestQueueClientAsync.list_requestsIssEFXdhdsdst)).. *%!/   !HMMO!<==  r) rrrrrrrrrr)rrrr)rrr'rrr)rrrr)rrr5rrr)rrrQrr5rrr)rrr[rrTrrr)rrrbrrr)rrrbrrr) rrrbrrTrrQrrr)rrrbrrTrrr)rrrXrrTrrr)rrrXrrr)rrr5rrrrrrrs@rrr6shC"& %% % % % %  % %!KOV"$OS>*hl>.ei>.0hl>2 ("& >%>> >  >  ><"&  %      4"& >%>> >  >0>*!)- >%>>' >  >rrN) __future__rtypingrapify_shared.utilsrrrapify_client._errorsrapify_client._utilsr r apify_client.clients.baser r rrrrrs8"aa.DIg>g>T i>1i>r