8j|ddlmZddlZddlZddlZddlZddlmZddlm Z m Z ddl m Z ddl mZddlmZmZddlmZmZdd lmZmZdd lmZmZdd lmZdd lmZmZdd l m!Z!e r*ddl"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ddl0m1Z1e dGddeZ2e dGddeZ3y)) annotationsN) timedelta) TYPE_CHECKINGAny) docs_group)create_redirect_logger)Run RunResponse)ResourceClientResourceClientAsync)StatusMessageWatcherStatusMessageWatcherAsync) StreamedLogStreamedLogAsync)#encode_key_value_store_record_value)response_to_dict to_safe_id) to_seconds)Decimal) GeneralAccess) DatasetClientDatasetClientAsyncKeyValueStoreClientKeyValueStoreClientAsync LogClientLogClientAsyncRequestQueueClientRequestQueueClientAsync)TimeoutzResource clientsceZdZdZdd d%fdZddd&dZddddd  d'd Zddd(d Zdd d d)dZddd d*dZ dddd d d+dZ ddddddd d d,dZ d dd-dZ d.dZ d/dZd0dZd1dZ d2ddd d3dZdddd  d4d!Zded"dd# d5d$ZxZS)6 RunClientzSub-client for managing a specific Actor run. Provides methods to manage a specific Actor run, e.g. get it, update it, abort it, or wait for it to finish. Obtain an instance via an appropriate method on the `ApifyClient` class. actor-runs resource_pathc *t|d||d|yN) resource_idr$super__init__selfr'r$kwargs __class__s Y/var/www/html/GAP/venv/lib/python3.12/site-packages/apify_client/_resource_clients/run.pyr+zRunClient.__init__.'  #'  shorttimeoutcj|j|}|ytj|jSaReturn information about the Actor run. https://docs.apify.com/api/v2#/reference/actor-runs/run-object/get-run Args: timeout: Timeout for the API HTTP request. Returns: The retrieved Actor run data. r4N_getr model_validatedatar-r5results r0getz RunClient.get;s37+ >))&1666r2Nstatus_messageis_status_message_terminalgeneral_accessr5cj|j||||}tj|jS)Update the run with the specified fields. https://docs.apify.com/api/v2#/reference/actor-runs/run-object/update-run Args: status_message: The new status message for the run. is_status_message_terminal: Set this flag to True if this is the final status message of the Actor run. general_access: Determines how others can access the run and its storages. timeout: Timeout for the API HTTP request. Returns: The updated run. r5 statusMessageisStatusMessageTerminal generalAccess_updater r:r;r-r@rArBr5r=s r0updatezRunClient.updateKs<*($>(   ))&1666r2c(|j|yzDelete the run. https://docs.apify.com/api/v2#/reference/actor-runs/delete-run/delete-run Args: timeout: Timeout for the API HTTP request. r4N_deleter-r5s r0deletezRunClient.deletehs W %r2medium gracefullyr5c|jj|jdd|j||}t |}t j |jS)DAbort 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: 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. timeout: Timeout for the API HTTP request. Returns: The data of the aborted Actor run. abortPOSTrUurlmethodparamsr5 _http_clientcall _build_url _build_paramsrr r:r;r-rUr5responser=s r0rXzRunClient.abortrse$$))(%%%< *  "(+))&1666r2 no_timeout wait_durationr5c|j|j|j||}|ytj|S)aWait synchronously until the run finishes or the server times out. Args: wait_duration: How long does the client wait for run to finish. None for indefinite. timeout: Timeout for the API HTTP request. Returns: The Actor run data. If the status on the object is not one of the terminal statuses (SUCCEEDED, FAILED, TIMED-OUT, ABORTED), then the run has not yet finished. r\r^rhr5N_wait_for_finishrbrcr r:r-rhr5res r0wait_for_finishzRunClient.wait_for_finishsQ ((!%%'' )   !!(++r2target_actor_build run_input content_typer5ct||\}}t|}|j||}|jj |j ddd|i|||}t |} tj| 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: ID of the target Actor that the run should be transformed into. target_actor_build: 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: The input to pass to the new run. content_type: The content type of the input. timeout: Timeout for the API HTTP request. Returns: The Actor run data. rr targetActorIdbuild metamorphrY content-typer\r]headersr;r^r5 rrrcr`rarbrr r:r; r-target_actor_idrprqrrr5safe_target_actor_idrequest_paramsrer=s r0ryzRunClient.metamorphs2#Fi^j"k <)/:++:NVh+i$$)) ,#\2! * "(+))&1666r2rx memory_mbytes run_timeout max_itemsmax_total_charge_usdrestart_on_errorr5c|j||t|d|||}|jj|j dd||} t | } t j| jS)#Resurrect a finished Actor run. Only finished runs, i.e. runs with status SUCCEEDED, 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: 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: New memory limit for the resurrected run, in megabytes. By default, the resurrected run uses the same memory limit as before. run_timeout: New timeout for the resurrected run. By default, the resurrected run uses the same timeout as before. max_items: Maximum number of items that the resurrected pay-per-result run will return. By default, the resurrected run uses the same limit as before. Limit can be only increased. max_total_charge_usd: Maximum cost for the resurrected pay-per-event run in USD. By default, the resurrected run uses the same limit as before. Limit can be only increased. restart_on_error: Determines whether the resurrected run will be restarted if it fails. By default, the resurrected run uses the same setting as before. timeout: Timeout for the API HTTP request. Returns: The Actor run data. Tas_intrxmemoryr5maxItemsmaxTotalChargeUsdrestartOnError resurrectrYr[ rcrr`rarbrr r:r; r-rxrrrrrr5rrer=s r0rzRunClient.resurrectsH++ {482+ , $$)) ,! * "(+))&1666r2c|jj|jdd|}t|}t j |j S)3Reboot 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 Args: timeout: Timeout for the API HTTP request. Returns: The Actor run data. rebootrYr\r]r5r`rarbrr r:r;r-r5rer=s r0rzRunClient.rebootsT$$)))*  "(+))&1666r2ch|jjdd|jd|jSzGet 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: A client allowing access to the default dataset of this Actor run. datasetr$r^r(_client_registrydataset_client_default_params_base_client_kwargsr-s r0rzRunClient.dataset@4t$$33 #'' &&  r2ch|jjdd|jd|jSa 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: A client allowing access to the default key-value store of this Actor run. zkey-value-storerr(rkey_value_store_clientrrrs r0key_value_storezRunClient.key_value_store(@z-RunClient.get_streamed_log..xJTTDJapify.r to_loggerr) r>idact_idr actor_client _base_url_public_base_urlr`namejoinrrr r-rrr5run_datarun_idactor_id actor_datar actor_namers r0get_streamed_logzRunClient.get_streamed_logRs*88G8,+3 6(++'&.8??B 00==$ $ 5 5 -- $ 5 5 >L&))'):J(2Z__ 88Jj&-AJJD.v?IdhhjIR\]]r2countidempotency_keyr5c |s td||djtjtj tj zd}ttjdz}|jd|d|d|}|jj|jdd |d d tj||d | yaCharge for an event of a Pay-Per-Event Actor run. https://docs.apify.com/api/v2#/reference/actor-runs/charge-events-in-run Args: event_name: The name of the event to charge for. count: The number of events to charge. idempotency_key: A unique key to ensure idempotent charging. If not provided, one will be auto-generated. timeout: Timeout for the API HTTP request. Raises: ValueError: If event_name is empty or not provided. z,event_name is required for charging an eventNr)ki-chargerYzapplication/json)zidempotency-keyrz) eventNamer)r\r]r|r;r5 ValueErrorrrandomchoicesstring ascii_lettersdigitsinttime _resource_idr`rarbjsondumpsr- event_namerrr5 random_suffix timestamp_mss r0rzRunClient.charge}s,KL L  "GGFNN63G3G&--3W[\$]^Mtyy{T12L!%!2!2 31ZL,qQ^P_`O )#2 2!+"   r2secondsr check_periodr5c|j|}|r|jrd|jnd}|r |jnd}d}|rZ|jj ||j |j |j|j}|j|}|r |jnd} |s(djd| |fD} td| }t||| S) 0Get `StatusMessageWatcher` instance that can be used to redirect status and status messages to logs. `StatusMessageWatcher` can be explicitly started and stopped or used as a context manager. Args: to_logger: `Logger` used for logging the status and status messages. If not provided, a new logger is created. check_period: The period with which the status message will be polled. timeout: Timeout for the API HTTP request. Returns: `StatusMessageWatcher` instance. r4rrNrrc3&K|] }|s| ywrr(rs r0rz7RunClient.get_status_message_watcher..rrr run_clientrr) r>rrrrrrr`rrrr r-rrr5rrrrrrrs r0get_status_message_watcherz$RunClient.get_status_message_watchers(88G8,+3 6(++'&.8??B 00==$ $ 5 5 -- $ 5 5 >L&))'):J(2Z__ 88Jj&-AJJD.v?I#tyWcddr2r'strr$rr.rreturnNoner5rr Run | None r@ str | NonerA bool | NonerBzGeneralAccess | Noner5rrr r5rrrrUr r5rrr rhtimedelta | Noner5rrr rrrpr rqrrrr r5rrr rxr r int | NonerrrrrzDecimal | Nonerr r5rrr r5rrr )rr)rr)rr)rrr)rlogging.Logger | Nonerboolr5rrr rrrrrr r5rrr)rrrrr5rrr )__name__ __module__ __qualname____doc__r+r>rLrRrXrnryrrrrrrrrrr __classcell__r/s@r0r!r!&sm*          )07&&*26/3" 7#7%0 7 - 7  7 7:,3&26(74+/' ,(, ,  ,@*.#'#)7)7' )7  )7 ! )7)7 )7\!$((, $/3(,#5757" 57 & 57  57-57&5757 57n,47&        ,0)^ ! )^()^ )^  )^  )^^&*" , ,  , $ ,  ,  , b,0"+A"6! (e)(e (e  (e  (er2r!ceZdZdZdd d%fdZddd&dZddddd  d'd Zdd d d(d Zddd d)dZddd*dZ dddd d d+dZ ddddddd d d,dZ d dd-dZ d.dZ d/dZd0dZd1dZ d2ddd d3dZdddd  d4d!Zded"dd# d5d$ZxZS)6RunClientAsynczSub-client for managing a specific Actor run. Provides methods to manage a specific Actor run, e.g. get it, update it, abort it, or wait for it to finish. Obtain an instance via an appropriate method on the `ApifyClientAsync` class. r"r#c *t|d||d|yr&r)r,s r0r+zRunClientAsync.__init__r1r2r3r4cK|j|d{}|ytj|jS7&wr7r8r<s r0r>zRunClientAsync.gets?yyy11 >))&16662sA?'ANr?cK|j||||d{}tj|jS7#w)rDrENrIrKs r0rLzRunClientAsync.updatesJ*||($>( $   ))&1666  sA?$ArSrTcK|jj|jdd|j||d{}t |}t j |jS7.w)rWrXrYrZr[Nr_rds r0rXzRunClientAsync.abortss**//(%%%< 0   "(+))&1666 sAA5A3/A5rfrgcK|j|j|j||d{}|tj|SdS7w)aWait asynchronously until the run finishes or the server times out. Args: wait_duration: How long does the client wait for run to finish. None for indefinite. timeout: Timeout for the API HTTP request. Returns: The Actor run data. If the status on the object is not one of the terminal statuses (SUCCEEDED, FAILED, TIMED-OUT, ABORTED), then the run has not yet finished. rjNrkrms r0rnzRunClientAsync.wait_for_finish/s` ..!%%'' /   08/Cs!!(+MM  s5AAAcDK|j|d{y7wrNrOrQs r0rRzRunClientAsync.deleteGsll7l+++s   roc2Kt||\}}t|}|j||}|jj |j ddd|i|||d{}t |} tj| jS7.w)rtrurvryrYrzr{Nr}r~s r0ryzRunClientAsync.metamorphQs2#Fi^j"k <)/:++.$,  **// ,#\2! 0  "(+))&1666 sA$B&B'/BrcK|j||t|d|||}|jj|j dd||d{} t | } t j| jS7.w)rTrrrrYr[Nrrs r0rzRunClientAsync.resurrectsH++ {482+ , **// ,! 0  "(+))&1666 sABB/BcK|jj|jdd|d{}t|}t j |j S7.w)rrrYrNrrs r0rzRunClientAsync.rebootsb**//)0   "(+))&1666  s1A$A"/A$ch|jjdd|jd|jSrrrs r0rzRunClientAsync.datasetrr2ch|jjdd|jd|jSrrrs r0rzRunClientAsync.key_value_storerr2ch|jjdd|jd|jSrrrs r0rzRunClientAsync.request_queuerr2ch|jjdd|jd|jSrrrs r0rzRunClientAsync.logrr2TrrcK|j|d{}|r|jrd|jnd}|r |jnd}d}|rb|jj ||j |j |j|j}|j|d{}|r |jnd} |s(djd| |fD} td| }t|j|| S77\w) rr4Nrrrrc3&K|] }|s| ywrr(rs r0rz2RunClientAsync.get_streamed_log..'rrrr) r>rrrrrrr`rrrrrrs r0rzRunClientAsync.get_streamed_logs*'22+3 6(++'&.8??B 00==$ $ 5 5 -- $ 5 5 >L ,///@@J(2Z__ 88Jj&-AJJD.v?I488:Wabb)3As#D DBD -D .AD  D rrc K|s td||djtjtj tj zd}ttjdz}|jd|d|d|}|jj|jdd |d d tj||d | d{y7wrrrs r0rzRunClientAsync.charge,s,KL L  "GGFNN63G3G&--3W[\$]^Mtyy{T12L!%!2!2 31ZL,qQ^P_`O$$)#2 2!+" %   sCC!CC!rrcK|j|d{}|r|jrd|jnd}|r |jnd}d}|rb|jj ||j |j |j|j}|j|d{}|r |jnd} |s(djd| |fD} td| }t||| S77Nw) rr4Nrrrrc3&K|] }|s| ywrr(rs r0rz.rrrr) r>rrrrrrr`rrrrrs r0rz)RunClientAsync.get_status_message_watcherZs('22+3 6(++'&.8??B 00==$ $ 5 5 -- $ 5 5 >L ,///@@J(2Z__ 88Jj&-AJJD.v?I(DI\hii+3As#C>C:BC>-C<.A C><C>rrr r rr rrr)rr)rr)rr)rrr)rrrrr5rrrr)rrrrr5rrr)rrrrr+r>rLrXrnrRryrrrrrrrrrrrrs@r0rrsq*          /67&&*26/3" 7#7%0 7 - 7  7 7:8rBs" %)81_`DLA/4   + lele le^  lj(lj ljr2