=dZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l mZe jfd ZGd d eZy )z4Utilities for querying hptuning-jobs in AI platform.)absolute_import)division)unicode_literals) list_pager)apis)messages) constants)yamlctjtjtj|}|tj k(r|j jS|jjSN) rGetMessagesModuler AI_PLATFORM_API_NAMEAI_PLATFORM_API_VERSION GA_VERSION GoogleCloudAiplatformV1StudySpecAlgorithmValueValuesEnum%GoogleCloudAiplatformV1beta1StudySpec)versionrs 6lib/googlecloudsdk/api_lib/ai/hp_tuning_jobs/client.pyGetAlgorithmEnumrs[  # #I$B$B$-$E$Eg$NP( $$$  4 4 M MM  9 9 R RRcbeZdZdZdZdZdZdZ d dZd dZ d d Z dd Z d Z y)HpTuningJobsClientzBClient used for interacting with HyperparameterTuningJob endpoint.ctjtjtj|}|j |_|j|_||_ tj||_ yr ) rGetClientInstancer rrMESSAGES_MODULE _messages+projects_locations_hyperparameterTuningJobs_servicerAI_PLATFORM_MESSAGE_PREFIX_message_prefix)selfrclients r__init__zHpTuningJobsClient.__init__(s]  # #I$B$B$-$E$Eg$NPF++DNFFDMDL$??HDrcft|jdj|j|dS)z(Returns the API messsages class by name.z{prefix}{name})prefixnameN)getattrrformatr!)r" message_names r _GetMessagezHpTuningJobsClient._GetMessage0s9  t';';%1  348 ::rc$|jdS)z5Returns the HyperparameterTuningJob resource message.HyperparameterTuningJob)r+r"s rHyperparameterTuningJobMessagez1HpTuningJobsClient.HyperparameterTuningJobMessage8s   5 66rc8|jdjS)z,Returns enum message representing Algorithm. StudySpec)r+rr.s r AlgorithmEnumz HpTuningJobsClient.AlgorithmEnum=s   K ( A AArNc 6|j} |r;tj|}|r$tj||j} | j s |sd| _n |r|| _| j s |sd| _n |r|| _|r|| j_| r| | j_ | r| | j_ | r| | j_ |r|| _ |r| jr|| j_||jd|| _| r| | _|j$t&j(k(r|j*j-|| }n|j*j-|| }|j.j1|S)a1Creates a hyperparameter tuning job with given parameters. Args: config_path: str, the file path of the hyperparameter tuning job configuration. display_name: str, the display name of the created hyperparameter tuning job. parent: str, parent of the created hyperparameter tuning job. e.g. /projects/xxx/locations/xxx/ max_trial_count: int, the desired total number of Trials. The default value is 1. parallel_trial_count: int, the desired number of Trials to run in parallel. The default value is 1. algorithm: AlgorithmValueValuesEnum, the search algorithm specified for the Study. kms_key_name: str, A customer-managed encryption key to use for the hyperparameter tuning job. network: str, user network to which the job should be peered with (overrides yaml file) service_account: str, A service account (email address string) to use for the job. enable_web_access: bool, Whether to enable the interactive shell for the job. enable_dashboard_access: bool, Whether to enable the dashboard defined for the job. labels: LabelsValues, map-like user-defined metadata to organize the hp-tuning jobs. Returns: Created hyperparameter tuning job. EncryptionSpec) kmsKeyName)parent.googleCloudAiplatformV1HyperparameterTuningJob)r73googleCloudAiplatformV1beta1HyperparameterTuningJob)r/r load_path messages_utilDictToMessageWithErrorCheck maxTrialCountparallelTrialCount trialJobSpecnetworkserviceAccountenableWebAccessenableDashboardAccess displayName studySpec algorithmr+encryptionSpeclabelsrr rr@AiplatformProjectsLocationsHyperparameterTuningJobsCreateRequestrCreate)r" config_path display_namer7max_trial_countparallel_trial_countrF kms_key_namer@service_accountenable_web_accessenable_dashboard_accessrHjob_specdatarequests rrJzHpTuningJobsClient.CreateBsZ224H ^^K (d  << $5579  ! !/ h .h  & &/C$%h! $8h!&-h#-F`Hg ==   ((rcp|jj|}|jj|SNr'r=AiplatformProjectsLocationsHyperparameterTuningJobsGetRequestrGetr"r'rUs rr[zHpTuningJobsClient.Gets4nnZZ [G ==  W %%rcp|jj|}|jj|SrW)r@AiplatformProjectsLocationsHyperparameterTuningJobsCancelRequestrCancelr\s rr_zHpTuningJobsClient.Cancels4nn]] ^G ==   ((rc~tj|j|jj |dd|S)N)r7hyperparameterTuningJobspageSize)fieldbatch_size_attributelimit)r YieldFromListrr>AiplatformProjectsLocationsHyperparameterTuningJobsListRequest)r"reregions rListzHpTuningJobsClient.Lists@  # #   G G H (' rc|jj|}|jj|fd}|S)zReturns a function to decide if log fetcher should continue polling. Args: name: String id of job. Returns: A one-argument function decides if log fetcher should continue. rXc,|dkryjduS)Nr4T)endTime)periods_without_logsresponses rShouldContinuez;HpTuningJobsClient.CheckJobComplete..ShouldContinues  "    %%rrY)r"r'rUrorns @rCheckJobCompletez#HpTuningJobsClient.CheckJobCompletesCnnZZ [G}}  )H& r) NNNNNNNFFNr )NN) __name__ __module__ __qualname____doc__r$r+r/r2rJr[r_rirprrrr%sVJI:7 B# _)B& ) rrN)rt __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.utilrrr;googlecloudsdk.command_lib.air googlecloudsdk.corer BETA_VERSIONrobjectrrurrr}sA;&'',A3$'33Sddr