i?1iwEddlmZddlmZddlmZmZmZddlm Z m Z m Z ddl m Z mZddlmZmZddlmZmZddlmZmZdd lmZmZGd d e ZGd d eZy)) annotations)Any)"filter_out_none_values_recursively ignore_docsparse_date_fields)#encode_key_value_store_record_value pluck_data to_safe_id)ActorJobBaseClientActorJobBaseClientAsync) DatasetClientDatasetClientAsync)KeyValueStoreClientKeyValueStoreClientAsync) LogClientLogClientAsync)RequestQueueClientRequestQueueClientAsyncceZdZdZedfd ZddZdddddZddZdddd Z dd dd Z dddd  dd Z dddd ddZ ddZ ddZddZd dZd!dZxZS)" RunClientz/Sub-client for manipulating a single actor run.cL|jdd}t||d|i|y)zInitialize the RunClient. resource_path actor-runsNpopsuper__init__selfargskwargsr __class__s s/home/www/therecruiter.miabetepe.com/venv/lib/python3.12/site-packages/apify_client/clients/resource_clients/run.pyrzRunClient.__init__, ?LA  $FmFvFc"|jS)Return information about the actor run. https://docs.apify.com/api/v2#/reference/actor-runs/run-object/get-run Returns: dict: The retrieved actor run data _getrs r#getz RunClient.getsyy{r%Nstatus_messageis_status_message_terminalc@||d}|jt|S)Update the run with the specified fields. https://docs.apify.com/api/v2#/reference/actor-runs/run-object/update-run Args: status_message (str, optional): The new status message for the run is_status_message_terminal (bool, optional): Set this flag to True if this is the final status message of the Actor run. Returns: dict: The updated run  statusMessageisStatusMessageTerminal_updaterrr-r.updated_fieldss r#updatezRunClient.update"s(,'A  ||>~NOOr%c"|jS)kDelete the run. https://docs.apify.com/api/v2#/reference/actor-runs/delete-run/delete-run _deleter*s r#deletezRunClient.delete5s ||~r% gracefullyc&|j|S)'Abort the actor run which is starting or currently running and return its details. https://docs.apify.com/api/v2#/reference/actor-runs/abort-run/abort-run Args: gracefully (bool, optional): If True, the actor run will abort gracefully. It will send ``aborting`` and ``persistStates`` events into the run and force-stop the run after 30 seconds. It is helpful in cases where you plan to resurrect the run later. Returns: dict: The data of the aborted actor run r>_abortrr?s r#abortzRunClient.abort<s{{j{11r% wait_secsc&|j|S)Wait synchronously until the run finishes or the server times out. Args: wait_secs (int, optional): how long does the client wait for run to finish. None for indefinite. Returns: dict, optional: The actor run data. If the status on the object is not one of the terminal statuses (SUCEEDED, FAILED, TIMED_OUT, ABORTED), then the run has not yet finished. rF_wait_for_finishrrGs r#wait_for_finishzRunClient.wait_for_finishKs$$y$99r%target_actor_build run_input content_typect||\}}t|}|j||}|jj |j ddd|i||}t t|jS)Transform an actor run into a run of another actor with a new input. https://docs.apify.com/api/v2#/reference/actor-runs/metamorph-run/metamorph-run Args: target_actor_id (str): ID of the target actor that the run should be transformed into target_actor_build (str, optional): The build of the target actor. It can be either a build tag or build number. By default, the run uses the build specified in the default run configuration for the target actor (typically the latest build). run_input (Any, optional): The input to pass to the new run. content_type (str, optional): The content type of the input. Returns: dict: The actor run data.  targetActorIdbuild metamorphPOST content-typeurlmethodheadersdataparams rr _params http_clientcall_urlrr jsonrtarget_actor_idrOrPrQsafe_target_actor_idrequest_paramsresponses r#rWzRunClient.metamorphWs,#FiQ]"^ <)/:.$&  ##(( +&#\2! ) !HMMO!<==r%rV memory_mbytes timeout_secsc|j|||}|jj|jdd|}t t |j S))Resurrect a finished actor run. Only finished runs, i.e. runs with status FINISHED, FAILED, ABORTED and TIMED-OUT can be resurrected. Run status will be updated to RUNNING and its container will be restarted with the same default storages. https://docs.apify.com/api/v2#/reference/actor-runs/resurrect-run/resurrect-run Args: build (str, optional): Which actor build the resurrected run should use. It can be either a build tag or build number. By default, the resurrected run uses the same build as before. memory_mbytes (int, optional): New memory limit for the resurrected run, in megabytes. By default, the resurrected run uses the same memory limit as before. timeout_secs (int, optional): New timeout for the resurrected run, in seconds. By default, the resurrected run uses the same timeout as before. Returns: dict: The actor run data. rVmemorytimeout resurrectrXr[r\r_rarbrcrdrr rerrVrlrmrirjs r#rszRunClient.resurrectsg2  &  ##(( +&!)  !HMMO!<==r%c|jj|jdd}tt |j S)Reboot an Actor run. Only runs that are running, i.e. runs with status RUNNING can be rebooted. https://docs.apify.com/api/v2#/reference/actor-runs/reboot-run/reboot-run Returns: dict: The Actor run data. rebootrXr[r\rbrcrdrr rerrjs r#ryzRunClient.rebootsF##(( (#) !HMMO!<==r%c8tdi|jdS)a Get the client for the default dataset of the actor run. https://docs.apify.com/api/v2#/reference/actors/last-run-object-and-its-storages Returns: DatasetClient: A client allowing access to the default dataset of this actor run. datasetr)r _sub_resource_init_optionsr*s r#r~zRunClient.datasets' --I-F  r%c8tdi|jdS)a!Get the client for the default key-value store of the actor run. https://docs.apify.com/api/v2#/reference/actors/last-run-object-and-its-storages Returns: KeyValueStoreClient: A client allowing access to the default key-value store of this actor run. key-value-storerr)rrr*s r#key_value_storezRunClient.key_value_stores(# --'>'>' '>  '> ! '> '>X!$(#' %>%>%>" %> ! %>  %>N >        r%rceZdZdZedfd ZddZdddddZddddZdd dd Z dd Z dddd  dd Z dddd ddZ ddZ ddZddZd dZd!dZxZS)"RunClientAsyncz5Async sub-client for manipulating a single actor run.cL|jdd}t||d|i|y)zInitialize the RunClientAsync.rrNrrs r#rzRunClientAsync.__init__r$r%c>K|jd{S7w)r'Nr(r*s r#r+zRunClientAsync.getsYY[   Nr,c\K||d}|jt|d{S7w)r0r1Nr4r6s r#r8zRunClientAsync.updates2,'A  \\"D^"TUUUUs #,*,r>cBK|j|d{S7w)rAr>NrBrDs r#rEzRunClientAsync.abort s[[J[7777 rFcBK|j|d{S7w)rIrFNrJrLs r#rMzRunClientAsync.wait_for_finishs"**Y*????rc>K|jd{S7w)r:Nr;r*s r#r=zRunClientAsync.delete's \\^###rrNcKt||\}}t|}|j||}|jj |j ddd|i||d{}t t|jS7&w)rSrTrWrXrYrZNr`rfs r#rWzRunClientAsync.metamorph.s,#FiQ]"^ <)/:.$&  )).. +&#\2! /  !HMMO!<== sA"B $B %'B rkcK|j|||}|jj|jdd|d{}t t |j S7&w)rorprsrXrtNrurvs r#rszRunClientAsync.resurrectWsu2  &  )).. +&!/   !HMMO!<==  sAA0A.'A0cK|jj|jddd{}tt |j S7&w)rxryrXrzNr{r|s r#ryzRunClientAsync.reboot~sT)).. (#/  !HMMO!<==  s0AA'Ac8tdi|jdS)aGet the client for the default dataset of the actor run. https://docs.apify.com/api/v2#/reference/actors/last-run-object-and-its-storages Returns: DatasetClientAsync: A client allowing access to the default dataset of this actor run. r~rr)rrr*s r#r~zRunClientAsync.datasets'" --I-F  r%c8tdi|jdS)a&Get the client for the default key-value store of the actor run. https://docs.apify.com/api/v2#/reference/actors/last-run-object-and-its-storages Returns: KeyValueStoreClientAsync: A client allowing access to the default key-value store of this actor run. rrr)rrr*s r#rzRunClientAsync.key_value_stores(( --'>'>' '>  '> ! '> '>X!$(#' %>%>%>" %> ! %>  %>N >        r%rN) __future__rtypingrapify_shared.utilsrrrapify_client._utilsrr r apify_client.clients.baser r -apify_client.clients.resource_clients.datasetr r5apify_client.clients.resource_clients.key_value_storerr)apify_client.clients.resource_clients.logrr3apify_client.clients.resource_clients.request_queuerrrrrr%r#rsE"aa[[Q[oOkT "T nT ,T r%