[3dZddlZddlmZddlmZddlmZddlm Z ddl m Z ejZ dZ d Zd Zd Zd Zd ZdZdZdZdZdZdZdZ ddZ dde dej6defdZddZdZdZ dZ!y)z(Notebook-executor executions api helper.N)runtime_templates) exceptions)parser_extensions) resources) console_iocd|vr" tjj|dStjj|dS#tj$rY6wxYw)zParse operation relative resource name to the operation reference object. Args: operation_name: The execution operation resource name Returns: The operation reference object z/notebookExecutionJobs/z>aiplatform.projects.locations.notebookExecutionJobs.operations) collectionz(aiplatform.projects.locations.operations)rREGISTRYParseRelativeName WrongResourceCollectionException)operation_names :lib/googlecloudsdk/api_lib/notebook_executor/executions.pyParseExecutionOperationrsu.0    1 1 N2    - -!K .   5 5   s AAAcf|jjjjS)zGet the parent Location resource name for the execution or schedule resource. Args: args: Argparse object from Command.Run Returns: The resource name in the form projects/{project}/locations/{location}. )CONCEPTSregionParse RelativeNameargss rGetParentForExecutionOrScheduler5s&    # # % 2 2 44cf|jjjjS)zGet the resource name for the execution. Args: args: Argparse object from Command.Run Returns: The resource name in the form projects/{project}/locations/{location}/notebookExecutionJobs/{execution_job_id}. )r executionrrrs rGetExecutionResourceNamerAs&  & & ( 5 5 77rc~|jt||}t|stjdd|S)aChecks that the execution is a Workbench execution and returns it if so. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the aiplatform API. service: The service to use for the API call. Returns: The execution if it is a Workbench execution. Raises: InvalidArgumentException: If the execution is not a Workbench execution. EXECUTIONzeExecution is not of Workbench type. To manage Colab Enterprise executions use `gcloud colab` instead.GetCreateExecutionGetRequestIsWorkbenchExecutionrInvalidArgumentExceptionrmessagesservicers r ValidateAndGetWorkbenchExecutionr&NsIkkh/) i (  - - 2  rc~|jt||}t|rtjdd|S)aChecks that the execution is of Colab Enterprise type and returns it if so. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the aiplatform API. service: The service to use for the API call. Returns: The execution if it is a Colab Enterprise execution. Raises: InvalidArgumentException: If the execution is a Workbench execution. rznExecution is not of Colab Enterprise type. To manage Workbench executions use `gcloud beta workbench` instead.rr#s rValidateAndGetColabExecutionr(isIkkh/))$  - - ;  rc|jduS)zFilter for Workbench executions. Args: execution: The execution item to check. Returns: True if the execution is a Workbench execution. N) kernelName)rs rr!r!s   T ))rcrd}|jdr#|j|||jSy)zGet the dataform repository source from the args. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the aiplatform API. Returns: DataformRepositorySource message for the execution. cf|jjjjS)N)rdataform_repository_namerrrs r!GetDataformRepositoryResourceNamezNGetDataformRepositorySourceFromArgs..GetDataformRepositoryResourceNames$ == 1 1 7 7 9 F F HHrr-)dataformRepositoryResourceName commitShaN) IsSpecifiedHGoogleCloudAiplatformV1beta1NotebookExecutionJobDataformRepositorySource commit_sha)rr$r.s r#GetDataformRepositorySourceFromArgsr4sFI 01  \ \'H'N// ]  rcz|j}|jdr||j|jSy)zGet the GCS notebook source from the args. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the aiplatform API. Returns: GcsNotebookSource message for the execution. gcs_notebook_uri)uri generationN)AGoogleCloudAiplatformV1beta1NotebookExecutionJobGcsNotebookSourcer1r6r8)rr$gcs_notebook_sources rGetGcsNotebookSourceFromArgsr;sEPP ()   ! !??  rc|j}|jdr(|tj|jdSy)zCreate direct notebook source message from the args. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the aiplatform API. Returns: DirectNotebookSource message for the execution. direct_contentT)binary)contentN)DGoogleCloudAiplatformV1beta1NotebookExecutionJobDirectNotebookSourcer1rReadFromFileOrStdinr=)rr$notebook_sources rGetDirectNotebookSourceFromArgsrCsKaa/ &' ..t/B/B6:<  rc2t|jdzS)zGet the execution timeout from the args. Args: args: Argparse object from Command.Run Returns: Serialized Duration message for the execution timeout. s)strexecution_timeoutrs rGetExecutionTimeoutFromArgsrHs T # # $s **rcf|jjjjS)zGet the runtime template resource name from the args. Args: args: Argparse object from Command.Run Returns: The notebook runtime template resource name. )rnotebook_runtime_templaterrrs rGetRuntimeTemplateResourceNamerKs&  0 0 6 6 8 E E GGrc|j}|tj||tj||tj||S)a Get the custom environment spec from the args for a Workbench execution. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the aiplatform API. Returns: CustomEnvironmentSpec message for the execution. ) machineSpec networkSpecpersistentDiskSpec)EGoogleCloudAiplatformV1beta1NotebookExecutionJobCustomEnvironmentSpecruntime_templates_utilGetMachineSpecFromArgsGetNetworkSpecFromArgsGetPersistentDiskSpecFromArgs)rr$custom_environment_specs rGetCustomEnvironmentSpecrVsTTT !(??hO(??hO/MM  rcxtjj|jd}|j S)z&Get the URL for an execution resource.z3aiplatform.projects.locations.notebookExecutionJobs) relative_namer )rr r nameSelfLink)resourcers rGetExecutionUrir\s8  22MMF3)    rc|rEd}t||}|j}d}d}tj||} |j} n+t ||}d}d}|j }t|}d} d} |j||rdn t|||r |jn |jt||t|||j|||j| ||  S)aCreates the NotebookExecutionJob message for the create request. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the AIPlatform API. workbench_execution: Whether this execution is for a Workbench notebook. for_schedule: Whether this execution is used to create a schedule. Returns: Instance of the NotebookExecutionJob message. N) dataformRepositorySourcedirectNotebookSource displayNameexecutionTimeout executionUsergcsNotebookSource gcsOutputUri#notebookRuntimeTemplateResourceNamecustomEnvironmentSpecserviceAccountencryptionSpecworkbenchRuntimer*)rV@GoogleCloudAiplatformV1beta1NotebookExecutionJobWorkbenchRuntimerQCreateEncryptionSpecConfig kernel_namer4 user_emailrK0GoogleCloudAiplatformV1beta1NotebookExecutionJobrCexecution_display_name display_namerHr;gcs_output_uriservice_account) rr$workbench_execution for_scheduledataform_repository_sourcerUworkbench_runtimeexecution_userruntime_template_nameencryption_specrls rCreateNotebookExecutionJobrzs!%6tXFQQSN ,GG hO""K!D h"#__N:4@OK  B B9  *4 : --   248"4T8D&&*?3))$(# C rrr$ for_workbenchc\t|}t|||d}|j||S)acBuilds a NotebookExecutionJobsCreateRequest message for a CreateSchedule request. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. for_workbench: Indicates whether this is a Workbench execution. Returns: Instance of the NotebookExecutionJobsCreateRequest message. T)rsrt)notebookExecutionJobparent)rrz=GoogleCloudAiplatformV1beta1CreateNotebookExecutionJobRequestrr$r{r~notebook_execution_jobs r'CreateExecutionCreateRequestForScheduler@sC +4 0&5 H-d  O O1  P rcpt|}t|||}|j||j|S)aFBuilds a NotebookExecutionJobsCreateRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. for_workbench: Indicates whether this is a Workbench execution. Returns: Instance of the NotebookExecutionJobsCreateRequest message. )rs)0googleCloudAiplatformV1beta1NotebookExecutionJobnotebookExecutionJobIdr~)rrz=AiplatformProjectsLocationsNotebookExecutionJobsCreateRequestexecution_job_idrs rCreateExecutionCreateRequestrYsJ +4 0&5 H-  O O7M!22  P rc8|jt|S)aBuilds a NotebookExecutionJobsDeleteRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. Returns: Instance of the NotebookExecutionJobsDeleteRequest message. rY)=AiplatformProjectsLocationsNotebookExecutionJobsDeleteRequestrrr$s rCreateExecutionDeleteRequestros%LL'-Mrc8|jt|S)zBuilds a NotebookExecutionsJobGetRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. Returns: Instance of the NotebookExecutionsJobGetRequest message. r):AiplatformProjectsLocationsNotebookExecutionJobsGetRequestrrs rr r s%II'-Jrc8|jt|S)zBuilds a NotebookExecutionJobsListRequest message. Args: args: Argparse object from Command.Run messages: Module containing messages definition for the specified API. Returns: Instance of the NotebookExecutionJobsListRequest message. )r~);AiplatformProjectsLocationsNotebookExecutionJobsListRequestrrs rCreateExecutionListRequestrs%  M M ,T 2 N r)F)"__doc__types'googlecloudsdk.api_lib.colab_enterpriserrQgooglecloudsdk.callioperrgooglecloudsdk.corergooglecloudsdk.core.consoler Namespacerrrr&r(r!r4r;rCrHrKrVr\rz ModuleTypeboolrrrr rrrrs/ _.5)2  ' ' 0 5 864 **** + H,7<6x  2,$$ r