8j@ddlmZddlmZmZddlmZddlmZm Z m Z m Z m Z m Z mZmZmZddlmZmZddlmZddlmZddlmZer,dd lmZdd lmZmZdd lm Z m!Z!m"Z"m#Z#m$Z$m%Z%dd l&m'Z'dd l(m)Z)m*Z*edGddeZ+edGddeZ,y)) annotations) TYPE_CHECKINGAny) docs_group) ActorStandbyRun RunResponseTask TaskInput TaskOptionsTaskPublicConfig TaskResponseUpdateTaskRequest)ResourceClientResourceClientAsync)encode_webhooks_to_base64)response_to_dict) to_seconds) timedelta)ActorJobStatus RunOrigin) RunClientRunClientAsyncRunCollectionClientRunCollectionClientAsyncWebhookCollectionClientWebhookCollectionClientAsync) TaskInputDict)Timeout WebhooksListzResource clientsceZdZdZdd dfdZddddZddddddddddddddddddddd  dd Zdddd Zdddd Zdddd Z dddddddddd ddZ dddddddddd d dZ ddd!dZ ddd"dZ d#dZdddd$dZd%dZxZS)& TaskClientzSub-client for managing a specific task. Provides methods to manage a specific task, e.g. update it, delete it, or start runs. Obtain an instance via an appropriate method on the `ApifyClient` class. actor-tasks resource_pathc *t|d||d|yN) resource_idr%super__init__selfr(r%kwargs __class__s Z/var/www/html/GAP/venv/lib/python3.12/site-packages/apify_client/_resource_clients/task.pyr,zTaskClient.__init__. X[ XQWXshorttimeoutcj|j|}|ytj|jSzRetrieve the task. https://docs.apify.com/api/v2#/reference/actor-tasks/task-object/get-task Args: timeout: Timeout for the API HTTP request. Returns: The retrieved task. r5N_getrmodel_validatedatar.r6results r1getzTaskClient.get7s37+ >**62777r3Nname task_inputbuild max_items memory_mbytes run_timeoutrestart_on_errortitle,actor_standby_desired_requests_per_actor_run(actor_standby_max_requests_per_actor_runactor_standby_idle_timeoutactor_standby_buildactor_standby_memory_mbytes is_publicpublic_config_seo_titlepublic_config_seo_description!public_config_input_schema_fieldspublic_config_dataset_namepublic_config_dataset_viewr6c||%t|tstj|}t||||t |||||t |||t |d|t| | t | d| | }|jd d|i|jdd}tj|jS) Update the task with specified fields. https://docs.apify.com/api/v2#/reference/actor-tasks/task-object/update-task Args: name: Name of the task. build: Actor build to run. It can be either a build tag or build number. By default, the run uses the build specified in the task settings (typically latest). max_items: Maximum number of results that will be returned by this run. If the Actor is charged per result, you will not be charged for more results than the given limit. memory_mbytes: Memory limit for the run, in megabytes. By default, the run uses a memory limit specified in the task settings. run_timeout: Optional timeout for the run. By default, the run uses timeout specified in the task settings. restart_on_error: If true, the Task run process will be restarted whenever it exits with a non-zero status code. task_input: Task input dictionary. title: A human-friendly equivalent of the name. actor_standby_desired_requests_per_actor_run: The desired number of concurrent HTTP requests for a single Actor Standby run. actor_standby_max_requests_per_actor_run: The maximum number of concurrent HTTP requests for a single Actor Standby run. actor_standby_idle_timeout: If the Actor run does not receive any requests for this time, it will be shut down. actor_standby_build: The build tag or number to run when the Actor is in Standby mode. actor_standby_memory_mbytes: The memory in megabytes to use when the Actor is in Standby mode. is_public: Set to `True` to publish the task on its public landing page, or `False` to unpublish it. Passing the value the task already has does nothing. Publishing requires the public display configuration to be filled in, and write access to the task's Actor. public_config_seo_title: SEO title of the public task page. Defaults to the task title when not set. public_config_seo_description: SEO description of the public task page. Defaults to the task description when not set. public_config_input_schema_fields: Names of the task input fields displayed on the public task page. public_config_dataset_name: Name of the dataset from the Actor's dataset schema whose results are displayed on the public task page. public_config_dataset_view: View key from the Actor's dataset schema shown on the public task page. timeout: Timeout for the API HTTP request. Returns: The updated task.  seo_titleseo_descriptioninput_schema_fields dataset_name dataset_viewTas_intrCrDrE timeout_secsrGdesired_requests_per_actor_runmax_requests_per_actor_runidle_timeout_secsrCrErArHinputrN public_configoptions actor_standbyr6by_alias exclude_noner) isinstancer r;rr r rr_update model_dumprr<r.rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSr6 task_fieldsr>s r1updatezTaskClient.updateGsB  !*Z*K"11*=J'*1 =$E77  #+' DA!1 '/[+S",-GPT"U)9 ' 6jgj1G1GQUdh1G1ij**62777r3c(|jd|S)%Publish the task on its public landing page. Convenience wrapper over `update` with `is_public` set to `True`. The task's Actor must be public and the task must have its public display configuration set up. Requires write access to the task and to its Actor. Publishing an already published task does nothing. https://docs.apify.com/api/v2#/reference/actor-tasks/task-object/update-task Args: timeout: Timeout for the API HTTP request. Returns: The published task. TrNr6rrr.r6s r1publishzTaskClient.publishs{{T7{;;r3c(|jd|S);Unpublish the task from its public landing page. Convenience wrapper over `update` with `is_public` set to `False`. The public display configuration is preserved, so the task can be published again without re-entering it. Requires write access to the task and to its Actor. Unpublishing a task that is not published does nothing. https://docs.apify.com/api/v2#/reference/actor-tasks/task-object/update-task Args: timeout: Timeout for the API HTTP request. Returns: The unpublished task. Frurvrws r1 unpublishzTaskClient.unpublishs{{UG{<s r1startzTaskClient.startsV  !*Z*K"11*=J++ {48+).x8, $$))'#%FG,6,B&&(! * "(+))&1666r3 no_timeout rBrCrDrErFrGr wait_durationr6c |j|||||||| } |jj| j|j|j |j |j} | j|S)Start a task and wait for it to finish before returning the Run object. It waits indefinitely, unless the wait_duration argument is provided. https://docs.apify.com/api/v2#/reference/actor-tasks/run-collection/run-task Args: task_input: Task input dictionary. build: Specifies the Actor build to run. It can be either a build tag or build number. By default, the run uses the build specified in the task settings (typically latest). max_items: Maximum number of results that will be returned by this run. If the Actor is charged per result, you will not be charged for more results than the given limit. memory_mbytes: Memory limit for the run, in megabytes. By default, the run uses a memory limit specified in the task settings. run_timeout: Optional timeout for the run. By default, the run uses timeout specified in the task settings. restart_on_error: If true, the Task run process will be restarted whenever it exits with a non-zero status code. webhooks: Specifies optional webhooks associated with the Actor run, which can be used to receive a notification e.g. when the Actor finished or failed. Note: if you already have a webhook set up for the Actor or task, you do not have to add it again here. wait_duration: The maximum time the server waits for the task run to finish. If not provided, waits indefinitely. timeout: Timeout for the API HTTP request. Returns: The run object. rBrCrDrErFrGrr6r(base_urlpublic_base_url http_clientclient_registryrr_client_registry run_clientid _base_url_public_base_urlrr r.rBrCrDrErFrGrrr6 started_runrs r1rzTaskClient.callsRjj!'#-!  **55#^^ 11)) 11 6 )) )FFr3c|jj|jdd|j|}t |S)SRetrieve the default input for this task. https://docs.apify.com/api/v2#/reference/actor-tasks/task-input-object/get-task-input Args: timeout: Timeout for the API HTTP request. Returns: Retrieved task input. Raises: NotFoundError: If the task does not exist. reGETrrrr6rrrrrr.r6rs r1 get_inputzTaskClient.get_inputVsJ$$))(%%' *   ))r3c|%t|tstj|}|jj |j dd|j |j|}t|S)KUpdate the default input for this task. https://docs.apify.com/api/v2#/reference/actor-tasks/task-input-object/update-task-input Args: task_input: The new default input for this task. timeout: Timeout for the API HTTP request. Returns: The updated task input. rePUTrrrrr6 rmr r;rrrrrorr.rBr6rs r1 update_inputzTaskClient.update_inputlsu  !*Z*K"11*=J$$))(%%'&&( *  ))r3cR|jjdddi|jSz,Retrieve a client for the runs of this task.r%rr)rrun_collection_client_base_client_kwargsr.s r1rzTaskClient.runs3:t$$::   &&  r3statusoriginc x|jjddd|j||d|jSaYRetrieve the client for the last run of this task. Last run is retrieved based on the start time of the runs. Args: status: Consider only runs with this status. origin: Consider only runs started with this origin. Returns: The resource client for the last run of this task. lastrr)r(r%rr)rrrrr.rrs r1last_runzTaskClient.last_runM0t$$//  %%VF%C &&   r3cN|jjdi|jSz9Retrieve a client for webhooks associated with this task.r)rwebhook_collection_clientrrs r1rzTaskClient.webhooks$>t$$>>ZAYAYZZr3r(strr%rr/rreturnNoner6rrz Task | None*rA str | NonerB TaskInputDict | TaskInput | NonerCrrD int | NonerErrFtimedelta | NonerG bool | NonerHrrIrrJrrKrrLrrMrrNrrOrrPrrQzlist[str] | NonerRrrSrr6rrr r6rrr r6rrrrBrrCrrDrrErrFrrGrrrrWebhooksList | Noner6rrrrBrrCrrDrrErrFrrGrrrrrr6rrz Run | Noner6rrdictrBzTaskInputDict | TaskInputr6rrr)rr)rActorJobStatus | NonerRunOrigin | Nonerr)rr__name__ __module__ __qualname____doc__r,r?rrrxr{rrrrrrrr __classcell__r0s@r1r"r"&s+ YY Y  Y  Y)08& 7; $$((,(, CG?C7;*.26!%.248>B1515"-`8`85 `8  `8  `8"`8&`8&`8`87A`83=`8%5`8(`8&0`8 !`8"",#`8$(2%`8&,<'`8(%/)`8*%/+`8,-`8. /`8D-4<"/6=",3&8< $$((,(,&*(,#B75B7 B7  B7 " B7&B7&B7$B7&B7B7 B7N8< $$((,(,(,*.';G5;G ;G  ;G " ;G&;G&;G&;G(;G;G ;Gz/6*,Y`*0 ;?[_ &[r3r"ceZdZdZdd dfdZddddZddddddddddddddddddddd  dd Zdddd Zdddd Zdddd Z dddddddddd ddZ dddddddddd d dZ ddd!dZ ddd"dZ d#dZdddd$dZd%dZxZS)&TaskClientAsynczSub-client for managing a specific task. Provides methods to manage a specific task, e.g. update it, delete it, or start runs. Obtain an instance via an appropriate method on the `ApifyClientAsync` class. r#r$c *t|d||d|yr'r*r-s r1r,zTaskClientAsync.__init__r2r3r4r5cK|j|d{}|ytj|jS7&wr8r9r=s r1r?zTaskClientAsync.gets?yyy11 >**627772sA?'ANr@cK|%t|tstj|}t||||t |||||t |||t |d|t| | t | d| | }|jd d|i|jdd d{}tj|jS7#w) rUNrVTr\r^r`rdr6rir)rlrps r1rrzTaskClientAsync.updatesB  !*Z*K"11*=J'*1 =$E77  #+' DA!1 '/[+S",-GPT"U)9 ' 6$t||pGp{7M7MW[jn7M7opp**62777qsB"C $C%$C cDK|jd|d{S7w)rtTruNrvrws r1rxzTaskClientAsync.publish&s![[4[AAAA   cDK|jd|d{S7w)rzFruNrvrws r1r{zTaskClientAsync.unpublish7s![[5'[BBBBrcDK|j|d{y7wr}r~rws r1rzTaskClientAsync.deleteHsll7l+++s   rrc K|%t|tstj|}|j|||t |d||t |} |j j|jddddi||jnd| | d{} t| } tj| jS7.wrrrs r1rzTaskClientAsync.startRsV  !*Z*K"11*=J++ {48+).x8, **//'#%FG,6,B&&(! 0  "(+))&1666 sBCC /Crrc ,K|j|||||||| d{} |jj| j|j|j |j |j} | j|d{S7p7w)rrNrrrrs r1rzTaskClientAsync.callsR!JJ!'#-'   **55#^^ 11)) 11 6  //m/LLL#  "Ms"BBA+B B BBcK|jj|jdd|j|d{}t |S7w)rrerrNrrs r1rzTaskClientAsync.get_inputsX**//(%%' 0    ))  sAAAAcK|%t|tstj|}|jj |j dd|j |j|d{}t|S7w)rNrerrrrs r1rzTaskClientAsync.update_inputs  !*Z*K"11*=J**//(%%'&&( 0   )) sA6B 8B9B cR|jjdddi|jSrrrs r1rzTaskClientAsync.runsrr3rc x|jjddd|j||d|jSrrrs r1rzTaskClientAsync.last_runrr3cN|jjdi|jSrrrs r1rzTaskClientAsync.webhooksrr3rrrrrrrrr)rr)rrrrrr)rrrrs@r1rrs+ YY Y  Y  Y/68& 7; $$((,(, CG?C7;*.26!%.248>B1515"-`8`85 `8  `8  `8"`8&`8&`8`87A`83=`8%5`8(`8&0`8 !`8"",#`8$(2%`8&,<'`8(%/)`8*%/+`8,-`8. /`8D3:B"5<C"29,8< $$((,(,&*(,#B75B7 B7  B7 " B7&B7&B7$B7&B7B7 B7N8< $$((,(,(,*.':M5:M :M  :M " :M&:M&:M&:M(:M:M :Mx5<*,_f*0 ;?[_ &[r3rN)- __future__rtypingrrapify_client._docsrapify_client._modelsrrr r r r r rr/apify_client._resource_clients._resource_clientrrapify_client._utils.encodingrapify_client._utils.httprapify_client._utils.timerdatetimerapify_client._literalsrrapify_client._resource_clientsrrrrrrapify_client._typeddictsrapify_client.typesrr r"rr)r3r1r s"%)   `B5/"@78 y[y[ y[x  x[)x[ x[r3