#?NdZddlmZddlmZddlmZddlZddlmZddlm Z ddl m Z dd l m Z dd l m Zdd l mZdd l mZdd lmZddlZGd dej(ZdZdZdZ ddedj2fdZdZdZdZdZdZdZ dZ!dZ"Gdde#Z$y) z8Utility file that contains helpers for Queued Resources.)absolute_import)division)unicode_literalsN)metadata_utils)apis)base) exceptions) properties) resources)timesceZdZdZy)BootDiskConfigurationErrorz0Error if the boot disk configuration is invalid.N)__name__ __module__ __qualname____doc__Dlib/googlecloudsdk/command_lib/compute/tpus/queued_resources/util.pyrr!s8rrc.tjd|S)Ntpu)rGetMessagesModule)versions rrr%s  w //rc^tj|j|j}t |}|j j }tj|D]E\}}|jj|j j j||G|S)zCreates the metadata for the Node. Based on googlecloudsdk.command_lib.compute.tpus.tpu_vm.util.MergeMetadata. Args: args: The gcloud args api_version: The api version (e.g. v2 or v2alpha1) Returns: The constructed MetadataValue. keyvalue) rConstructMetadataDictmetadatametadata_from_filerNode MetadataValuesix iteritemsadditionalPropertiesappendAdditionalProperty)args api_version metadata_dict tpu_messagesrrrs r MergeMetadatar,,s!66 mmT,,-#;/,    , , .(MM-0jc5 !!((''::s%:P1 /rcfd}|S)z2Creates the repeated structure nodeSpec from args.cV t }|j|j|_|jj|j |j_|jjj r$|jjj d}n@g|jj_|j }|j|_|jj|_ |jr|j|j_ |j|j_|j rng|j_|j D]N}|j%|j&|j(}|jj"j+|P|j,r|j,|j_|j.r|jj1|j_g|jj._|j.j5D]Y\}}|jj.j2j+|jj0j7||[|j8r|j8|j_|j<r!|j?d|j_ dk(r|jBrd|j_"|jG|j_$|jK|j_&|jNr%|jN|jjH_'|jPr%|jP|jjH_(|jRr%|jR|jjL_*|jVr%|jV|jjL_,|jZr|jZ|j_-|j\ |jjH_/|j`r%tc|j` |j_2tg| |j_4|jjr!|jlstojpd|jrr|jr|_:n|jlr dk(r|jw|_<|jl|jx_=|jjr|jj|jx_>|j~dk(r|jvjj|jx_BnW|j|_D|jl|j_=|jjr|jj|j_>|g|jj_|S) Nr) sourceDiskmoderT)enableSecureBootv2alpha1zACan only specify --node-prefix if --node-count is also specified.AVAILABILITY_OPTIMIZED)ErqueuedResourceQueuedResourcerTpunodeSpecNodeSpecr!nodeParent RelativeNameparentaccelerator_typeacceleratorTyperuntime_versionruntimeVersion data_disk dataDisks AttachedDiskr/r0r& descriptionlabels LabelsValuer%itemsr'range cidrBlockshielded_secure_bootShieldedInstanceConfigshieldedInstanceConfigautocheckpoint_enabledautocheckpointEnabled NetworkConfig networkConfigServiceAccountserviceAccountnetwork subnetworkservice_accountemailscopesscopetags internal_ipsenableExternalIps boot_diskParseBootDiskConfigbootDiskConfigr,r node_prefix node_countr ConflictingArgumentsExceptionnode_idnodeIdMultiNodeParamsmultiNodeParams nodeCount nodeIdPrefix workload_typeWorkloadTypeValueValuesEnumr3 workloadTypeMultisliceParamsmultisliceParams) refr(requestr+ node_specrA attached_diskrrr)s rProcesszCreateNodeSpec..ProcessGs$[1L%+::INN   4 4 M  ||i   "$0$@$@$B !.2oo !!+   373C3C) # # 0   !9 9**FF]]  # # 0&2%B%B%D "/3 "",   484D4D) $ $ 1+4+G' Nrrr)rqs` rCreateNodeSpecrsDsZx .rr2returnct|}d}d}|jD]#}|||fvs tdj|||j |dj dk(}|j |d}|r8|dk7rt jdd |td j||i}|r|j| } | |d <|dk(r|r||d <|r|jdi|Sy)z$Parses configurations for boot disk.zkms-keyzconfidential-computez.--boot-disk only supports arguments: {} and {}FalsetrueNr2z --boot-diskzBconfidential-compute is only available in the alpha release track.zQargument --boot-disk: with confidential-compute={} requires kms-key; received: {}) kmsKeyNamecustomerEncryptionKeyenableConfidentialComputer) rkeysrformatgetlowerr InvalidArgumentExceptionCustomerEncryptionKeyBootDiskConfig) boot_disk_argsr)r+kms_key_arg_nameconfidential_compute_arg_namearg_nameenable_confidential_computekms_keyboot_disk_config_kwargscustomer_encryption_keys rr]r]sR#;/,"8 %%'h(*GHH & : A A+-=  (6@FFH    / 6' j  / /  N PP & ++16)7,4   *@@A7N34J#>#78 &< & & A)@ AA rcj~|jr%|jdkrtjdd|S)Nz --node-countz!Node count must be greater than 1)r`r rrmr(rns rVerifyNodeCountrs7  __A-  - -;  .rc~|jratd}|j|j|_|jj|j |j_|S)zECreates an empty BestEffort structure if best-effort arg flag is set.r2) best_effortrr4r5 bestEffort BestEffort)rmr(rnr+s r SetBestEffortrsc  $Z0L%+::.Processs $[1L%+::(>(C(C(K&2&7&7&9# Nrrrrs` rSetSpotrs  .rcfd}|S)z9Creates an empty Guaranteed structure if arg flag is set.c~|jrat}|j|j|_|jj|j |j_|SN) guaranteedrr4r5 Guaranteed)rmr(rnr+r)s rrqzSetGuaranteed..Processsb  &{3l    '!-!    * * 2,8,C,C,E) Nrrrrs` r SetGuaranteedrs  .rcfd}|S)z'Sets the provisioning model enum value.cj~t}|j|j|_|jsl|jr/|jj j |j_|jj j|j_|S |jjddj}|jj |}||j_|S#t$r)}tjd|jd|d}~wwxYw)Nrrz--provisioning-modelzb is not a valid provisioning model, must be one of [standard, spot, reservation-bound, flex-start])rr4r5rrrrprovisioningModelSTANDARDrr TypeErrorr r)rmr(rnr+normalized_candidatecandidate_enumer)s rrqz%SetProvisioningModel..Processs+ $[1L%+::G, N   / /  $ $ %&G G  s(AD D2 $D--D2rrrs` rSetProvisioningModelrs B .rcfd}|S)z:Combine multiple timing constraints into a valid_interval.c ~|jr |js|jr!|jrt j dt }tj}d}|jr |j}n'|jr|jj|}d}|jr |j}n'|jr|jj|}|r|r|j}tj||_ tj||_ |j|j|_|j!|j_||jj"_|S)NzEOnly one timing constraint for each of (start, end) time is permitted)valid_after_durationvalid_after_timevalid_until_durationvalid_until_timer rarr NowGetRelativeDateTimeIntervalFormatDateTime startTimeendTimer4r5QueueingPolicyqueueingPolicy validInterval) rmr(rnr+ current_time start_timeend_timevalid_intervalr)s rrqz!SetValidInterval..Process:sM  !!d&;&; !!d&;&;  4 4  %[1L99;LJ ((j " ",,@@NjH &&h " "**>>|Lhh#,,.n!&!5!5j!An$33H=n    '!-!.:.I.I.Kg+.Processks & &4+G+G  ( (T-O-O  . .43P3P  4 4 2 2G%6"$N! $$  d33TYY  % %  T11499  + +  4==tyy  z!:t}}!!&&..88:g  GTYYG } %$*:*:rxx&(8(8@!!&&..88:g6== 499d../?g, Nrrrrs` rCreateReservationNameras(T .rcF~t|dr|jrd|_|S)z&Sets force arg to true if flag is set.forceT)rrrs rSetForcers!  T7 GM .rc"eZdZdZdZdZdZy)TPUQueuedResourcez#Helper to get TPU Queued Resources.c|tjjk(rd|_nd|_t j d|j|_t jd|j|_y)Nr2rr) r ReleaseTrackALPHA _api_versionrGetClientInstanceclientrmessages)self release_tracks r__init__zTPUQueuedResource.__init__sZ))///$dd((0A0ABDK**5$2C2CDDMrc|jSr)r)rs r GetMessageszTPUQueuedResource.GetMessagess ==rchtjjjj d}t j j|||dd|j}|jj|j}|jjj |S)zrs?&' 9,(.A*)* 9!4!:!:900_F!+-z"11-` ("#L'T4nGGr