i?1it[ddlmZddlmZmZmZddlmZmZm Z m Z ddl m Z ddl mZmZmZddlmZmZddlmZmZddlmZmZdd lmZmZerdd lmZmZ d dd Z Gd deZ!GddeZ"y )) annotations) TYPE_CHECKINGAnycast)"filter_out_none_values_recursively ignore_docsmaybe_extract_enum_member_valueparse_date_fields) ApifyApiError)catch_not_found_or_throwencode_webhook_list_to_base64 pluck_data)ResourceClientResourceClientAsync) RunClientRunClientAsync)RunCollectionClientRunCollectionClientAsync)WebhookCollectionClientWebhookCollectionClientAsync)ActorJobStatus MetaOriginNc||||||d||dS)z,Get the dictionary representation of a task.)buildmaxItems memoryMbytes timeoutSecs)actIdnameoptionsinputtitle)actor_idr task_inputr max_items memory_mbytes timeout_secsr"s t/home/www/therecruiter.miabetepe.com/venv/lib/python3.12/site-packages/apify_client/clients/resource_clients/task.pyget_task_representationr*s-!)'    c"eZdZdZedfd ZddZdddddddd ddZddZdddddddd dd Z dddddddd  dd Z dd Z dd Z ddZ dddddZddZxZS) TaskClientz*Sub-client for manipulating a single task.cL|jdd}t||d|i|y)zInitialize the TaskClient. resource_path actor-tasksNpopsuper__init__selfargskwargsr/ __class__s r)r4zTaskClient.__init__3, ?MB  $FmFvFr+c"|jS)Retrieve the task. https://docs.apify.com/api/v2#/reference/actor-tasks/task-object/get-task Returns: dict, optional: The retrieved task _getr6s r)getzTaskClient.get9syy{r+Nrr%rr&r'r(r"c Zt|||||||}|jt|S)Update the task with specified fields. https://docs.apify.com/api/v2#/reference/actor-tasks/task-object/update-task Args: name (str, optional): Name of the task build (str, optional): 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 (int, optional): 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 (int, optional): Memory limit for the run, in megabytes. By default, the run uses a memory limit specified in the task settings. timeout_secs (int, optional): Optional timeout for the run, in seconds. By default, the run uses timeout specified in the task settings. task_input (dict, optional): Task input dictionary title (str, optional): A human-friendly equivalent of the name Returns: dict: The updated task rAr*_updater r6rr%rr&r'r(r"task_representations r)updatezTaskClient.updateCs<<6!'% ||>?RSTTr+c"|jS)oDelete the task. https://docs.apify.com/api/v2#/reference/actor-tasks/task-object/delete-task _deleter?s r)deletezTaskClient.deletems ||~r+r%rr&r'r(wait_for_finishwebhooksc |j|||||| t|nd}|jj|j ddddi||} t t | jSaStart the task and immediately return the Run object. https://docs.apify.com/api/v2#/reference/actor-tasks/run-collection/run-task Args: task_input (dict, optional): Task input dictionary build (str, optional): 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 (int, optional): 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 (int, optional): Memory limit for the run, in megabytes. By default, the run uses a memory limit specified in the task settings. timeout_secs (int, optional): Optional timeout for the run, in seconds. By default, the run uses timeout specified in the task settings. wait_for_finish (int, optional): The maximum number of seconds the server waits for the run to finish. By default, it is 0, the maximum value is 60. webhooks (list of dict, optional): Optional ad-hoc webhooks (https://docs.apify.com/webhooks/ad-hoc-webhooks) associated with the actor run which can be used to receive a notification, e.g. when the actor finished or failed. If you already have a webhook set up for the actor or task, you do not have to add it again here. Each webhook is represented by a dictionary containing these items: * ``event_types``: list of ``WebhookEventType`` values which trigger the webhook * ``request_url``: URL to which to send the webhook HTTP request * ``payload_template`` (optional): Optional template for the request payload Returns: dict: The run object N)rrmemorytimeout waitForFinishrPrunsPOSTz content-typezapplication/json; charset=utf-8)urlmethodheadersjsonparams_paramsr http_clientcall_urlr rr[ r6r%rr&r'r(rOrPrequest_paramsresponses r)startzTaskClient.starttsL  )@H@T28 )  D(--/**r+c8tdi|jdSz,Retrieve a client for the runs of this task.rV)r/r#)r_sub_resource_init_optionsr?s r)rVzTaskClient.runss"[T%D%DSY%D%Z[[r+statusoriginctdi|jdd|jt|t|S)aRetrieve the client for the last run of this task. Last run is retrieved based on the start time of the runs. Args: status (ActorJobStatus, optional): Consider only runs with this status. origin (MetaOrigin, optional): Consider only runs started with this origin. Returns: RunClient: The resource client for the last run of this task. lastrVr resource_idr/r\r#)rrr^r r6rrs r)last_runzTaskClient.last_runsP  --"$||:6B:6B$.  r+c4tdi|jSz9Retrieve a client for webhooks associated with this task.r#)rrr?s r)rPzTaskClient.webhookss&K)H)H)JKKr+)r6r-r7rr8rreturnNone)r6r-r dict | None)r6r-r str | Noner%rrrr& int | Noner'rr(rr"rrrv)r6r-rr)r6r-r%rrrr&rr'rr(rrOrrPlist[dict] | Nonerrv)r6r-r%rrrr&rr'rr(rrPrrgrrr)r6r-r%rvrrv)r6r-rr)r6r-rActorJobStatus | NonerMetaOrigin | Nonerr)r6r-rr__name__ __module__ __qualname____doc__rr4r@rHrMrer`ryrrVrrP __classcell__r9s@r)r-r-0s4GG  "& $$(#' (U(U(U (U  (U  (U"(U!(U(U (UT#' $$(#'&*&*7>7> 7> 7>  7> " 7>!7>$7>$7> 7>x#' $$(#'&* $+\+\ +\ +\  +\ " +\!+\$+\+\ +\Z&+ \GKhl .Lr+r-c"eZdZdZedfd ZddZdddddddd ddZddZdddddddd dd Z dddddddd  dd Z dd Z dd Z ddZ dddddZddZxZS)TaskClientAsyncz0Async sub-client for manipulating a single task.cL|jdd}t||d|i|y)zInitialize the TaskClientAsync.r/r0Nr1r5s r)r4zTaskClientAsync.__init__ r:r+c>K|jd{S7w)r<Nr=r?s r)r@zTaskClientAsync.get&sYY[   NrAc vKt|||||||}|jt|d{S7w)rCrANrDrFs r)rHzTaskClientAsync.update0sF<6!'% \\"DEX"YZZZZs 0979c>K|jd{S7w)rJNrKr?s r)rMzTaskClientAsync.deleteZs \\^###rrNc  K|j|||||| t|nd}|jj|j ddddi||d{} t t | jS7&wrRr]rbs r)rezTaskClientAsync.startasL  )@H@T28A'A%!A'$B%A'' B0 B;BBBcK|jj|jdd|j|d{}t t |j S7"w)r{r!r|r}Nr~rs r)rzTaskClientAsync.update_inputs])).. '"<<> /   D(--/**  sAA'A%#A'c8tdi|jdSr)rrr?s r)rVzTaskClientAsync.runss'`$*I*IX^*I*_``r+rctdi|jdd|jt|t|S)aRetrieve the client for the last run of this task. Last run is retrieved based on the start time of the runs. Args: status (ActorJobStatus, optional): Consider only runs with this status. origin (MetaOrigin, optional): Consider only runs started with this origin. Returns: RunClientAsync: The resource client for the last run of this task. rrVrrr#)rrr^r rs r)rzTaskClientAsync.last_runsP  --"$||:6B:6B$.  r+c4tdi|jSr)rrr?s r)rPzTaskClientAsync.webhookss+Pd.M.M.OPPr+)r6rr7rr8rrr)r6rrr)r6rrrr%rrrr&rr'rr(rr"rrrv)r6rrr)r6rr%rrrr&rr'rr(rrOrrPrrrv)r6rr%rrrr&rr'rr(rrPrrgrrr)r6rr%rvrrv)r6rrr)r6rrrrrrr)r6rrrrrs@r)rrs:GG ! "& $$(#' ([([([ ([  ([  (["([!([([ ([T$#' $$(#'&*&*7>7> 7> 7>  7> " 7>!7>$7>$7> 7>x#' $$(#'&* $+b+b +b +b  +b " +b!+b$+b+b +bZ&+ aLPmq .Qr+r)NNNNNNNN)r$rrrr%rrrr&rr'rr(rr"rrrv)# __future__rtypingrrrapify_shared.utilsrrr r apify_client._errorsr apify_client._utilsr r rapify_client.clients.baserr)apify_client.clients.resource_clients.runrr4apify_client.clients.resource_clients.run_collectionrr8apify_client.clients.resource_clients.webhook_collectionrrapify_shared.constsrrr*r-rr#r+r)rs"++/ccIOnz> " $#         2jLjLZjQ)jQr+