SrSSKrSSKrSSKJrJrJr SSKJr SSKJ r SSK J r SSK J r SSK Jr SS KJr SS KJr SSKJ r SS KJr SS KJr SS KJr SS KJr SSKJ r SSKJr SSKJ r SS K!Jr" SSK#J$r$ SSK#J%r% SSK#J&r& SSK#J'r' SSK#J(r( SSK#J)r) SSK*J+r+ SS K,Jr- SSK.J/r/ SSK0J1r1 SSK2J3r3 SSK4J r5 SSK4J6r6 SSK4J7r7 SSK8J9r9 SSK8J:r: SSK;Jr> S r?\R"S!5rAS"rB\R"S#5rCS$rDS%rES&rF/S'QrGS(rHS)rIS*rJ\:R"S+S,S-9rL\:R"S.S/S-9rM\:R"S0S1S-9rN\L\M\N/rO/S2QrPS3/\P-rQS4rRS5rSS6\RS7\US8\R4S9jrWS6\RS7\US8\R4S:jrXSdS;\RS<\RS=\7RS7\US>\\US8\R4 S?jjr\S;\RS<\RS=\7RS@\\RS8\\\R\\U44 SAjr^S;\RS6\RS@\\RS8\\R\\U44SBjr`SC\US8\\U4SDjraSE\US8\\U4SFjrbS;\RS6\RS@\\RS8\\\R\\U44SGjrdS;\RS6\RS8\R4SHjreS;\RS6\RS8\R4SIjrfS;\RS6\RSJ\\RS8\\R\\U44SKjrhSL\US8\U4SMjriS;\RS<\RS=\7RS@\\RS8\\R\\U44 SNjrlS;\RS@\\RS8\\U4SOjrmS;\RS6\RS8\\\R\\U44SPjroS;\RS6\RS8\\\U\\R\\U44SQjrqS;\RS6\RS8\\\r\R\\R\\U44SRjruS;\RS8S4SSjrvS;\RS6\RS@\\RS8\\\R\\U44STjrxS;\RSU\RS@\\RS=\7RS8\\U4 SVjryS;\RSU\RS@\\RS8\\U4SWjrzSX\US8\{4SYjr|SZ\RS=\7RSU\RS8S4S[jr}SZ\RS=\7RSU\RS\\\US8S4 S]jr~\>R"S^S_S`9Sa5rS;\RSb\GRS8\R4Scjrg)ezHThis file provides the implementation of the `functions deploy` command.N) FrozenSetOptionalTuple)base_api) exceptions)api_enablement) cmek_util)secrets)util)client)types) storage_util)base)parser_extensions)ArgumentTypeError)flags) labels_util)run_util)secrets_config)service_account_util) source_util) deploy_util)serverless_operations) arg_utils)map_util)log) resources) console_io)progress_tracker)files)retryz^There was a problem uploading the source code to a signed Cloud Storage URL. Please try again.zgs://([^/]+)/(.*)zNInvalid Cloud Storage URL. Must match the following format: gs://bucket/objectzhttps://source\.developers\.google\.com/projects/(?P[^/]+)/repos/(?P[^/]+)(((/revisions/(?P[^/]+))|(/moveable-aliases/(?P[^/]+))|(/fixed-aliases/(?P[^/]+)))(/paths/(?P[^/]+))?)?/?$aBInvalid Cloud Source Repository URL provided. Must match the following format: https://source.developers.google.com/projects//repos/. Specify the desired branch by appending /moveable-aliases/, the desired tag with /fixed-aliases/, or the desired commit with /revisions/. zD`--retry` is only supported with an event trigger not http triggers.zThe latest revision of this function is not serving 100% of traffic. Please see the associated Cloud Run service to confirm your expected traffic settings.))docker_registryz--docker-registry)security_levelz--security-level)buildpack_stackz--buildpack-stackz=`%s` is only supported in Cloud Functions (First generation).zdeployment-toolz cli-gcloudz[ArtifactRegistry]ARTIFACT_REGISTRY)keyz [Healthcheck]SERVICE_ROLLBACKz[Triggercheck]TRIGGER_ROLLBACK) kKiMMiGGiTTiPPima ^ # Beginning of input marker. (?P\d+) # Amount. ((?P[-/ac-zAC-Z]+)([bB])?)? # Optional scale and optional 'b'. $ # End of input marker. z ^ # Beginning of input marker. (?P\d*.?\d*) # Amount. (?P[-/ac-zAC-Z]+)? # Optional scale. $ # End of input marker. messagessourcereturnc[RU5nU(d[R"[5eUR UR URS5URS5S9S9$)zConstructs a `Source` message from a Cloud Storage object. Args: messages: messages module, the GCFv2 message stubs. source: the Cloud Storage URL. Returns: The resulting cloudfunctions_v2_messages.Source. bucketobject storageSource)_GCS_SOURCE_REGEXmatchrFunctionsError_GCS_SOURCE_ERROR_MESSAGESource StorageSourcegroup)r4r5r@s =lib/googlecloudsdk/command_lib/functions/v2/deploy/command.py _GetSourceGCSrGsg  ! !& )%   # #$= >> **Q A+  c[RU5nUc[R"[5eUR UR S5UR S5UR S5S9nUR S5nUR S5nUR S5nU(aXClOU(aXclOU=(d SUl URUS 9$) zConstructs a `Source` message from a Cloud Source Repository reference. Args: messages: messages module, the GCFv2 message stubs. source: the Cloud Source Repository reference. Returns: The resulting cloudfunctions_v2_messages.Source. project_id repo_namepath) projectIdrepoNamedircommitbranchtagmaster) repoSource) _CSR_SOURCE_REGEXr@rrA_CSR_SOURCE_ERROR_MESSAGE RepoSourcerE commitShatagName branchNamerC)r4r5r@ repo_sourcerPrQrRs rF _GetSourceCSRr\s  ! !& )% ]  # #$= >>## L){{;' ++f $+ ;;x & ;;x & E# " $/xK K 00rHargsr function_refkms_keycURn[R"5n[R"XcUR 5nUR (a[[R"XrUR 5nURURURURS9S9sSSS5 $URUS9n URRURU UR!5R#5S95n [R,"XzR.5 URU R0S9sSSS5 $![$R&an [(R*"X5 U eSn A ff=f!,(df  g=f)asConstructs a `Source` message from a local file system path. Args: args: The arguments that this command was invoked with. client: The GCFv2 Base API client. function_ref: The GCFv2 functions resource reference. source: The source path. kms_key: resource name of the customer managed KMS key | None Returns: The resulting cloudfunctions_v2_messages.Source. r:r=N) kmsKeyName)generateUploadUrlRequestparent)MESSAGES_MODULE file_utilsTemporaryDirectoryrCreateSourcesZipFile ignore_file stage_bucketUploadToStageBucketrCrDr;nameGenerateUploadUrlRequestprojects_locations_functionsGenerateUploadUrl@CloudfunctionsProjectsLocationsFunctionsGenerateUploadUrlRequestParent RelativeNameapitools_exceptions HttpErrorr ProcessExceptionUploadToGeneratedUrl uploadUrlr>) r]r r^r5r_r4tmp_dir zip_file_path dest_objectgenerate_upload_url_requestdestes rF_GetSourceLocalr}sd& # #($$&'44))M 33 t'8'8k__ .. '' 0@0@/ '&%-$E$E%F%! 22DD  U U)D#**,99; V  &&}nnE __4+=+=_ >?'&2! * *""1.3'&s7BE;0E;AE8E;E8E33E88E;; F existing_functionc <URc4Ub1URRR(a S[54$UR=(d SnURnUR S5(a[ XT5[S/54$UR S5(a[XT5[S/54$UR=(d URRn[R"XF5 [UUUU[X5S9[S/54$)aParses the source bucket and object from the --source flag. Args: args: arguments that this command was invoked with. client: The GCFv2 API client function_ref: The GCFv2 functions resource reference. existing_function: `cloudfunctions_v2_messages.Function | None`, pre-existing function. Returns: A tuple `(function_source, update_field_set)` where - `function_source` is the resulting `cloudfunctions_v2_messages.Source`, - `update_field_set` is a set of update mask fields. N.zgs://zbuild_config.sourcezhttps://)r_) r5 buildConfigrT frozensetrd startswithrGr\runtimer(ValidateDirectoryHasRequiredRuntimeFilesr}_GetActiveKmsKey)r]r r^r~r5r4rs rF _GetSourcers* kk  '  ' ' . . 9 9   ;; #&  # #( w  *I7L6M,N NN $$  *I7L6M,N NNllC/;;CCG88I   9   '()  **rHc 0nU(aUR(aURR(adURRR(a?URRRHnURX4R'M [ R "SU5n[ R"U40UD6n0n0nU(aPUR(a?[R"URRURR5n[R"U5(aU[R"UU[R "5["R$"[R "555nOUn[R0"U5up[R0"U5up[3XU5upn[5XU5unnn[7X5unn[9USS5n[9USS5n[;5nUR<(aUR?S5 UR@bUR?S5 UbUR?S5 UbUR?S5 URBcURD(aUR?S 5 URFcURH(aUR?S 5 URJc URLbUR?S 5 URNbUR?S 5 Xc:waUR?S 5 X:waUR?S5 X:waUR?S5 SnURQS5(aUR?S5 O3URQS5(aURRnUR?S5 [TRWUUUU5nURY[[UR@5URD(aSO URBURH(aSO URFURJ=(d URLURNUUUUR<=(d SURXR][_URa55VVs/sH*unnURXR\RcUUS9PM, snnS9[Rd"X5[Rf"XSS9U[iU5UUS9nU(aUUl5UU4$![&a5n [(R*"[,R."U 55 Sn A GNSn A ff=fs snnf)aConstructs a ServiceConfig message from the command-line arguments. Args: args: arguments that this command was invoked with. messages: messages module, the GCFv2 message stubs. existing_function: the existing function. Returns: A tuple `(service_config, updated_fields_set)` where - `service_config` is the resulting `cloudfunctions_v2_messages.ServiceConfig`. - `updated_fields_set` is a set of update mask fields. zenv-varsN concurrencycpuz-service_config.all_traffic_on_latest_revisionzservice_config.available_memoryz/service_config.max_instance_request_concurrencyzservice_config.available_cpuz!service_config.max_instance_countz!service_config.min_instance_countz$service_config.service_account_emailzservice_config.timeout_secondsz$service_config.environment_variablesz+service_config.secret_environment_variableszservice_config.secret_volumesclear_binary_authorizationz*service_config.binary_authorization_policybinary_authorizationr&valueadditionalPropertiesT)normalize_for_v2)availableMemorymaxInstanceCountminInstanceCountserviceAccountEmailtimeoutSecondsingressSettings vpcConnectorvpcConnectorEgressSettingsallTrafficOnLatestRevisionenvironmentVariablessecretEnvironmentVariables secretVolumesmaxInstanceRequestConcurrency availableCpubinaryAuthorizationPolicydirectVpcEgress)6 serviceConfigrrrr&rGetMapFlagsFromArgs ApplyMapFlags secrets_utilGetSecretsAsDictrrrIsArgsSpecified ApplyFlagsapi_util GetProject projects_utilGetProjectNumberrcore_exceptionsreraiserrASplitSecretsDict_GetVpcAndVpcEgressSettings_GetDirectVpcNetworkSettings_GetIngressSettingsgetattrset!serve_all_traffic_latest_revisionaddmemory max_instancesclear_max_instances min_instancesclear_min_instancesrun_service_accountservice_accounttimeoutIsKnownAndSpecifiedrrunion ServiceConfig_ParseMemoryStrToK8sMemoryEnvironmentVariablesValuesorteditemsAdditionalPropertySecretEnvVarsToMessagesSecretVolumesToMessages_ValidateK8sCpuStrdirectVpcNetworkInterface)r]r4r~ old_env_varsadditional_property env_var_flagsenv_vars old_secrets new_secretserrorold_secret_env_varsold_secret_volumessecret_env_varssecret_volumes vpc_connectorvpc_egress_settingsvpc_updated_fieldsnetwork_interfacesdirect_vpc_egressdirect_vpc_updated_fieldsingress_settingsingress_updated_fieldsrrupdated_fieldsbinary_authorization_policyservice_updated_fieldsr&rservice_configs rF_GetServiceConfigrEs&,  ) )  ) ) > >  ) ) > > S S ''<<QQ /B.G.Gl**+ R..z4@-  # #L BM B(++,:://''BB''55K ##D))@"--        ( ()<)<)> ? kK,:,K,K-)%3$C$CK$P!/"$2CD9-&8#43DEC')B.A-P**mT2+eT"#5. ++FG [[89HI_56 #t'?'?:; #t'?'?:; )T-A-A-M=> \\78 =>+DE)67 $ :;;CD  677"&";";CD$?? ))0=#77tT=O=O#77tT=O=O22Jd6J6J\\& !4  0 0 8D#11KK !'x~~'7 8  !9*#u$$>>QQR!9  L".!E!E "!88 T%0%c* ;';*.>/AN, 0 11 @j77>??@V s?AT)(1U+ ) U(3*U##U(rc UbU(dg[R"[U[R5nU(d&[R "SSR U55eURS5nURS5nUcSn[[Vs/sHoDR5U4PM sn5nURUR55nU(d&[R "SSR U55eX6-nU$s snf)aHParses user provided memory to kubernetes expected format. Ensure --gen2 continues to parse Gen1 --memory passed in arguments. Defaults as M if no unit was specified. k8s format: https://github.com/kubernetes/kubernetes/blob/master/staging/src/k8s.io/apimachinery/pkg/api/resource/generated.proto Args: memory: input from `args.memory` Returns: k8s_memory: str|None, in kubernetes memory format. GCF 2nd Gen control plane is case-sensitive and only accepts: value + m, k, M, G, T, Ki, Mi, Gi, Ti. Raises: InvalidArgumentException: User provided invalid input for flag. Nz--memoryz'Invalid memory value for: {} specified.suffixamountr+!Invalid suffix for: {} specified.) rer@_MEMORY_VALUE_PATTERNVERBOSErInvalidArgumentExceptionformatrEdict_GCF_GEN2_UNITSupperget)rr@rrunituppercased_gen2_unitscorrected_suffix parsed_memorys rFrrs& ^6  (((&"** =%   - -=DDVL  ;;x & ;;x & ^ F(78 d8+..v||~>   - -7>>vF +- 9sD rcUcg[R"[U[R5nU(d&[R "SSR U55eURS5=(d SnURS5nU(aUS:Xa&[R "SSR U55eU(a0U[;a&[R "SS R U55eX2-nU$) afValidates user provided cpu to kubernetes expected format. k8s format: https://github.com/kubernetes/kubernetes/blob/master/staging/src/k8s.io/apimachinery/pkg/api/resource/generated.proto Args: cpu: input from `args.cpu` Returns: k8s_cpu: str|None, in kubernetes cpu format. Raises: InvalidArgumentException: User provided invalid input for flag. Nz--cpuz$Invalid cpu value for: {} specified.rrrz!Invalid amount for: {} specified.r) rr@_CPU_VALUE_PATTERNrrrrrE_GCF_GEN2_CPU_UNITS)rr@rrrs rFrr s [  ((%sBJJ 7%   - -7>>sC  ;;x &B& ;;x & 6S=  - -4;;C@  11  - -4;;C@ /- rHcZUR(aS[U(aS/O/5pCOUR(dUR(a[ X5[S/5pCOUR (d"UR (dUR(a[X5[S/5pCO6U(aUR[5pCO[R"/SQS5eURS5(a%[XU5upVXSlURU5nU(a:[ R""UR$5(a[&R("5 U(aE[ R*"UR$5(a [&R,"UR.5 X44$)aConstructs an EventTrigger message from the command-line arguments. Args: args: The arguments that this command was invoked with. messages: messages module, the GCFv2 message stubs. existing_function: The pre-existing function. Returns: A tuple `(event_trigger, update_fields_set)` where: - `event_trigger` is a `cloudfunctions_v2_messages.EventTrigger` used to request events sent from another service, - `updated_fields_set` is a set of update mask fields. N event_trigger)z--trigger-topicz--trigger-bucketz--trigger-http--trigger-eventz--trigger-event-filtersz9You must specify a trigger when deploying a new function.r!) trigger_httpr trigger_eventtrigger_resource_GetEventTriggerForEventType trigger_topictrigger_buckettrigger_event_filters_GetEventTriggerForOther eventTriggercalliope_exceptionsOneOfArgumentsRequiredException IsSpecified _GetRetry retryPolicyr trigger_types IsPubsubType eventTyper'ensure_pubsub_sa_has_token_creator_roleIsAuditLogType#ensure_data_access_logs_are_enabled eventFilters)r]r4r~rupdated_fields_set retry_policyretry_updated_fields rF_GetEventTriggerr6sU$ (,i.B/% T22(D )/"#& T00D4N4N(@ )/"#&   ( ( +( ? ?  F   g(1$-(P%L ,+112EF}11-2I2IJJ779}33M4K4KLL33M4N4NO  **rHcURnURnUR=(d URnU[R ;aI[ R"U5nUR[R[U5UURS9$U[R;dU[R;as[RR!U5R"n[RR%X"5nURUUR'SUS9/UURS9$[(R*"SSR-U55e)a*Constructs an EventTrigger message from the command-line arguments. Args: args: The arguments that this command was invoked with. messages: messages module, the GCFv2 message stubs. Returns: A `cloudfunctions_v2_messages.EventTrigger`, used to request events sent from another service. )r  pubsubTopicr triggerRegionr; attributer)r rrrrzOEvent type {} is not supported by this flag, try using --trigger-event-filters.)rrtrigger_service_accountrrPUBSUB_MESSAGE_PUBLISH_TYPES api_util_v1ValidatePubsubTopicNameOrRaise EventTriggerEA_PUBSUB_MESSAGE_PUBLISHED_BuildFullPubsubTopictrigger_locationEVENTARC_STORAGE_TYPES!EVENTFLOW_TO_EVENTARC_STORAGE_MAPrBucketReferenceFromUrlr;r EventFilterrrr)r]r4rrservice_account_email pubsub_topic bucket_namestorage_event_types rFrrusG$$-**66N$:N:Nh;;;==>NOL  66),71++ ! x666 (DD D..667GHOOK!CCGG  $  8; G 2++ !   - - $$*F=$9 rHc /nSnSnUR=(d URnURnUR(a'[R n[ UR5nGOUR(a@URSSRS5n[RnURSUS9/nOUR(aURRS5nURR5VV s/sHupUS:wdM URXS9PM nnn UR(aNSn URURR5VV s/sHupURXU S9PM sn n5 Sn UR (a2UR"R R%5R'5n UR)UUUUU US 9$s sn nfs sn nf) a+Constructs an EventTrigger when using `--trigger-[bucket|topic|filters]`. Args: args: arguments that this command was invoked with. messages: messages module, the GCFv2 message stubs. Returns: A `cloudfunctions_v2_messages.EventTrigger` used to request events sent from another service. N/r;rtypezmatch-path-pattern)rroperator)rr rrchannelr)rrr rrrrrrstripEA_STORAGE_FINALIZEr%rrr"trigger_event_filters_path_patternextendtrigger_channelCONCEPTSParserqr) r]r4 event_filters event_typer'r&r r;attrvalr.r4s rFrrs-*,66N$:N:N** 55J();); 8t7;  ..%hBBHHJJid   8  LJ / mm3399;HHJO    /$  !s G"G"%G( rcUc[R"[5eUR(a'URR S5[ S/54$URR S5[ S/54$)aConstructs an RetryPolicy enum from --(no-)retry flag. Args: args: arguments that this command was invoked with. messages: messages module, the GCFv2 message stubs. event_trigger: trigger used to request events sent from another service. Returns: A tuple `(retry_policy, update_fields_set)` where: - `retry_policy` is the retry policy enum value, - `update_fields_set` is the set of update mask fields. RETRY_POLICY_RETRYzeventTrigger.retryPolicyRETRY_POLICY_DO_NOT_RETRY)rrA!_INVALID_RETRY_FLAG_ERROR_MESSAGEr!rRetryPolicyValueValuesEnumr)r]r4rs rFrrs$  # #$E FF ZZ  ; ; ,-. //  ; ;# ,-. //rHr'cLSR[R"5U5$)Nzprojects/{}/topics/{})rrr)r's rFrrs ' '(;(;(=| LLrHc[UUUU5upE0nU(aUR(aURR(adURRR(a?URRRHnURXgR 'M [ R"SU5n[ R"U40UD6n [5n X:waU RS5 URbU RS5 URbU RS5 UR(aSO URn URcUR(aU RS5 URn U cUR (aU RS5 UR"n SnSnUR%S5(aQU R'S 5 UR(S :XaU R+5nUR(S :XaU R-5n[.R1XZ5nU R3URURUU U R2R5[7U R955VVs/sH*unnU R2R4R;UUS 9PM, snnS 9U UUS9U4$s snnf)aQConstructs a BuildConfig message from the command-line arguments. Args: args: arguments that this command was invoked with. client: The GCFv2 API client. function_ref: The GCFv2 functions resource reference. existing_function: The pre-existing function. Returns: The resulting build config and the set of update mask fields. zbuild-env-varsz"build_config.environment_variablesNzbuild_config.entry_pointzbuild_config.runtimezbuild_config.worker_poolzbuild_config.service_accountruntime_update_policy)z$build_config.automatic_update_policyz$build_config.on_deploy_update_policy automaticz on-deployrr) entryPointrr5 workerPoolrserviceAccountautomaticUpdatePolicyonDeployUpdatePolicy)rrrrrr&rrrrr entry_pointrclear_build_worker_poolbuild_worker_poolbuild_service_accountclear_build_service_accountrdrupdaterBAutomaticUpdatePolicyOnDeployUpdatePolicyrr BuildConfigrrrr)r]r r^r~function_sourcesource_updated_fieldsold_build_env_varsrbuild_env_var_flagsbuild_env_varsr worker_poolrr4automatic_update_policyon_deploy_update_policybuild_updated_fieldsr&rs rF_GetBuildConfigr[s",6   ,(/  ' '  ' ' < <  ' ' < < Q Q %%::OO 5H4M4M001 P!445EtL))/.5.);< !12 \\-.44$:P:P+ '4+G+G12../ D$D$D56  # #(   -.. !![0 ( > > @ !![0 ( = = ?")>O%%,,  '33MM %+>+?+?+A$B $%Cjc5&&@@SSUT%C $ N ) 76"% $s1KcURS5(a UR$URS5(agU(dS$UR$)zRetrives KMS key applicable to the deployment request. Args: args: arguments that this command was invoked with. existing_function: the pre-existing function. Returns: Either newly passed or pre-existing KMS key. r_ clear_kms_keyN)rr_ra)r]r~s rFrrfsG i  << (( &H,=,H,HHrHcUR(a_[R"SURR[ R S9RUR5nU[S/54$S[54$)asConstructs ingress setting enum from command-line arguments. Args: args: arguments that this command was invoked with. messages: messages module, the GCFv2 message stubs. Returns: A tuple `(ingress_settings_enum, updated_fields_set)` where: - `ingress_settings_enum` is the ingress setting enum value, - `updated_fields_set` is the set of update mask fields. rarg_name message_enumcustom_mappingszservice_config.ingress_settingsN) rrChoiceEnumMapperrIngressSettingsValueValuesEnumrINGRESS_SETTINGS_MAPPINGGetEnumForChoicer)r]r4ingress_settings_enums rFrrzsq %66#++JJ66t,,-  !)-N,O"P PP  rHcUR(aSS[SS/54$[5nSnUR(aDURRR 5R 5nURS5 OIU(aBUR(a1URR(aURRnSnUR(aU(d[R"SS5e[R"SURR ["R$S9R'UR5nURS5 XE[U54$)aConstructs vpc connector and egress settings from command-line arguments. Args: args: The arguments that this command was invoked with. messages: messages module, the GCFv2 message stubs. existing_function: The pre-existing function. Returns: A tuple `(vpc_connector, egress_settings, updated_fields_set)` where: - `vpc_connector` is the name of the vpc connector, - `egress_settings` is the egress settings for the vpc connector, - `updated_fields_set` is the set of update mask fields. Nzservice_config.vpc_connectorz,service_config.vpc_connector_egress_settingsz vpc-connectorzCFlag `--vpc-connector` is required for setting `--egress-settings`.egress_settingsr_)clear_vpc_connectorrrrr5r6rqrrrrirRequiredArgumentExceptionrrcr)VpcConnectorEgressSettingsValueValuesEnumrEGRESS_SETTINGS_MAPPINGrf)r]r4r~update_fields_setrris rFrrs3,    * :   e- MM//557DDFM89  ) )  ) ) 6 6%33@@M/    0 0  O   00"++UU55t++,  HI 3D)E EErHcZ[USS5(aSS[SS/54$[5nSnSnU(aEUR(a4URR(aURRSn[USS5n[USS5n[USS5n[US S5n U=(d U=(d U=(d U n U (aUR 5n/UlU(a<URUlURUlUR =(d /UlU(aXdlU(aXtlU(aXlOU (a/UlURS5 O U(aUnSn [US S5(aU(d[R"S S 5e[R"S URR[ R"S 9R%UR&5n URS5 U(aU/OSn X[U54$)aConstructs direct VPC network settings from command-line arguments. Args: args: The arguments that this command was invoked with. messages: messages module, the GCFv2 message stubs. existing_function: The pre-existing function. Returns: A tuple `(network_interfaces, direct_vpc_egress, updated_fields_set)` where: - `network_interfaces` is the list containing configuration of the Direct VPC, - `direct_vpc_egress` is the egress settings for the Direct VPC network, - `updated_fields_set` is the set of update mask fields. clear_networkNz+service_config.direct_vpc_network_interfacez service_config.direct_vpc_egressrnetworksubnet network_tagsclear_network_tagsrzdirect-vpc-egressz9Direct VPC is required for setting `--direct-vpc-egress`.r_)rrrrrDirectVpcNetworkInterfacetagsrq subnetworkrrrkrrcrDirectVpcEgressValueValuesEnumr"DIRECT_VPC_EGRESS_SETTINGS_MAPPINGrfr) r]r4r~rnnetwork_interfaceexisting_network_interfacerqrrrsrthas_direct_vpc_flagsrrs rFrrs0 T?D))   9 .   e#  ) )  ) ) C C ''AA!D D)T *' 44 (&~t4,t%94@ PFPlP>P ::<!"<"D"D%?%J%J"9>>D"") %+"+ !GH!2 T&--   0 0  E  "22$++JJ@@t--.  <=.?)*T  :K0L LLrHc[H8upURU5(dM[R"[U-5e g)zDEnsures that only the arguments supported in V2 are passing through.N)_V1_ONLY_FLAGSrrrA_V1_ONLY_FLAG_ERROR)r] flag_variable flag_names rF_ValidateV1OnlyFlagsr/s7"0m  ..  % %&9I&E FF#1rHcDU(a0nO [[0n[RR XS9nUR UR RU(a UROS5nUR(aUR[S/54$S[54$)auConstructs labels from command-line arguments. Args: args: The arguments that this command was invoked with messages: messages module, the GCFv2 message stubs. existing_function: The pre-existing function. Returns: A tuple `(labels, updated_fields_set)` where: - `labels` is functions labels metadata, - `updated_fields_set` is the set of update mask fields. )required_labelsNlabels) _DEPLOYMENT_TOOL_LABEL_DEPLOYMENT_TOOL_VALUErDiffFromUpdateArgsApplyFunction LabelsValuer needs_updater)r]r4r~r labels_diff labels_updates rF _GetLabelsr6s"O-/EFO  // 0+####"3-   H:!6 66  rHfunctionc[5nU(a UROSUlURS5(dURS5(a)URS5(aSO URUlUbURUR:wa?URb![R "URU5 UR S5 U$)aSets CMEK-related fields on the function. Args: args: arguments that this command was invoked with. function: `cloudfunctions_v2alpha_messages.Function`, the recently created or updated GCF function. existing_function: `cloudfunctions_v2_messages.Function | None`, the pre-existing function. function_ref: resource reference. Returns: A set of update mask fields. Nr_r] kms_key_name)rrarr_r ValidateKMSKeyForFunctionr)r]rr~r^rs rF_SetCmekFieldsrXs&5.&7""T  i  D$4$4_$E$E  11t||     1 < < < ||))(*=*=|L~& rHcj[5nU(aURROSURlURS5(dURS5(aURS5(aSO URn[ R "U5URlUb.URRURR:waURS5 UR(a2URR(d[R"SS5eU$)a`Sets user-provided docker repository field on the function. Args: args: arguments that this command was invoked with function: `cloudfunctions_v2_messages.Function`, recently created or updated GCF function. existing_function: `cloudfunctions_v2_messages.Function | None`, pre-existing function. Returns: A set of update mask fields. Ndocker_repositoryclear_docker_repositoryzbuild_config.docker_repositoryz--docker-repositoryzTA Docker repository must be specified when a KMS key is configured for the function.) rrdockerRepositoryrrr NormalizeDockerRepositoryFormatrrarrk)r]rr~rupdated_docker_repositorys rF_SetDockerRepositoryConfigr}s"5. ##44  '  )**d.>.>//   5 6 6  # # 112KL ) !    0 0  ( ( 9 9 :9: !5!5!F!F  7 7 !  rHrkcJ[R"SRU5SS9$)zMPrompts the user to allow unauthenticated invocations for the given function.z7Allow unauthenticated invocations of new function [{}]?F) prompt_stringdefault)rPromptContinuer)rks rF(_PromptToAllowUnauthenticatedInvocationsrs&  " " C J J4 P  rH gcf_clientcURnURnURUR5R 5UR 5US9nUR RU5nSn[R"X4Xg[5 g)a Create a function. This does not include setting the invoker permissions. Args: gcf_client: The GCFv2 API client. function_ref: The GCFv2 functions resource reference. function: `cloudfunctions_v2_messages.Function`, The function to create. Returns: None )rc functionIdrzDeploying functionN) r r45CloudfunctionsProjectsLocationsFunctionsCreateRequestrprqNamermCreaterWaitForOperation _EXTRA_STAGES)rr^rr r4create_request operationoperation_descriptions rF_CreateAndWaitrs"   &  (DD$$&335!&&(E1188H).  -rHrcbURnURnU(aqURUR5SR [ U55US9nUR RU5nSn[R"XEXx[5 g[RRS5 g)a=Update a function. This does not include setting the invoker permissions. Args: gcf_client: The GCFv2 API client. function_ref: The GCFv2 functions resource reference. function: `cloudfunctions_v2_messages.Function`, The function to update. updated_fields_set: A set of update mask fields. Returns: None ,)rk updateMaskrz$Updating function (may take a while)zNothing to update.N)r r44CloudfunctionsProjectsLocationsFunctionsPatchRequestrqjoinrrmPatchrrrrstatusPrint) rr^rrr r4update_requestrrs rF_UpdateAndWaitrs&   &  (EE**,xx'9 :; F 3399.IIB )MJJ)*rHi) max_retrialssleep_mscURUR55$![Ran[R "SU5eSnAff=f)z Retrieves a function with retry.z"Function not found after retries, N) GetFunctionrqrrrsrrA)r r^rs rF_GetFunctionWithRetryrsNQ   l779 ::  & &Q  # #$H% PPQs!AA  A release_trackc  [R"US9nURnURRR 5n[ U5 URUR55nURUR5RVs0sH7n[UR5S:XdMURSUR0_M9 nnUSLnU(aUR(d[ R""5(d[$R&"SS5e[)UR+55n [ R,"U SS9n XUl[.R0R3S R5UR55 [6R8"5(a7U(a0[UR5S :Xa[:R<"S S 5eUR=(d UR>Rn U (aX;a[:R<"S U S35eX;a0X{S(a$X{SHn [.R@"U 5 M U(aKURB(a:URBRDn U b!U (d[.R@"[F5 [IXU5up[KUURLUU5unn[OXU5unn[QXU5unnURSUR5UUUUS9n[UUUXT5n[WUUU5n[XRZ"S5 [XRZ"S5 [XRZ"S5 SnUR]S5(a UR^nO#U(aU(d[aURb5n[dRf"[hRj"5URURl5 U(a [oX$U5 O'[pRsUUUUUU5n[uX$UU5 [wX$5nU(aU(dU(a:UR]S5(a$[xRz"UU[|R~S9 [.R0R3SSR5URUR5[hRj"55-5 U$s snf)z/Runs a function deployment with the given args.)rGEN_2warningsNrz/Flag `--runtime` is required for new functions.zPlease select a runtime: )messagezCTo skip this prompt, add `--runtime={}` to your command next time. GEN_1z--gen2zAFunction already exists in 1st gen, can't change the environment.z --runtimezt is not a supported runtime on GCF 2nd gen. Use `gcloud functions runtimes list` to get a list of available runtimes)rkrrrrzrun.googleapis.comzcloudbuild.googleapis.comzartifactregistry.googleapis.comallow_unauthenticated) add_bindingmemberz6You can view your function in the Cloud Console here: zDhttps://console.cloud.google.com/functions/details/{}/{}?project={} )A client_v2FunctionsClientr4r5rkr6rrrq ListRuntimes locationsIdruntimesstr environmentrrr CanPromptrrkrkeys PromptChoicerrrrr ShouldUseGen2rrrwarningrr(_LATEST_REVISION_TRAFFIC_WARNING_MESSAGErr[r rrrrrrPromptToEnableApiIfDisabledrrrNAMEr2ValidateDefaultBuildServiceAccountAndPromptWarningrrrFrrrrrrAddOrRemoveInvokerBindingr"ALLOW_UNAUTH_POLICY_BINDING_MEMBERr)r]rr r4r^r~r gen2_runtimesis_new_functionridxrw"has_all_traffic_on_latest_revisionrtrigger_updated_fields build_configrZrr labels_valuelabels_updated_fieldsrcmek_updated_fields docker_repository_updated_fieldsrrs rFRunr si  $ $= A& __(##))+,t(()B)B)DE""<#;#;<EEE! Q]] w &'affz1::&&E &-/T\\    ! !  9 9 F m((*+H  ! !6 C=DLJJN      ++ , 7  - -K  LL A-99AA' -  - -i) )  -"8"D  #J / kk!n0,::''BB' +62 kk:;*: '+'-(7  mm ($,$,= ',(.()3 ')%,%     $ $ & "  (' H'&@ H'&",,-AB,,-HI,,-NO -.. 66}DTYYOII!! 62__( N6>B "6 8(      2 3 3 &&)$GG **>O v  " "L$5$5$79L9L9N /as S97S9)N)__doc__rr typingrrrapitools.base.pyrrrr googlecloudsdk.api_lib.functionsrr r r#googlecloudsdk.api_lib.functions.v1r r#googlecloudsdk.api_lib.functions.v2r r api_typesrgooglecloudsdk.api_lib.storagergooglecloudsdk.callioper calliope_baserr#googlecloudsdk.calliope.arg_parsersr#googlecloudsdk.command_lib.eventarcr $googlecloudsdk.command_lib.functionsrrrrrr'googlecloudsdk.command_lib.functions.v2r#googlecloudsdk.command_lib.projectsrgooglecloudsdk.command_lib.runr$googlecloudsdk.command_lib.util.apisr$googlecloudsdk.command_lib.util.argsrgooglecloudsdk.corerrrgooglecloudsdk.core.consolerrgooglecloudsdk.core.utilr rer!!_SIGNED_URL_UPLOAD_ERROR_MESSSAGEcompiler?rBrUrVr>rr~rrrStage_ARTIFACT_REGISTRY_STAGE_SERVICE_ROLLBACK_STAGE_TRIGGER_ROLLBACK_STAGErrrrr ModuleTyperrCrGr\ Namespace BaseApiClientResourcer}rrrrrrrrrr RetryPolicyrrrrQr[rIngressSettingsrVpcConnectorEgressSettingsrlistruDirectVpcEgressrrrrrrboolrrrRetryOnExceptionr ReleaseTrackrrHrFrsO --%>;6DCC:B@79E5AF6<9?E<?E@:9=#)288*" JJ23 JJ   QK" .) D+%,111+00++00,   eo-E,,ci>N>N*"1E,,"1c"1i>N>N"1T" 3?  % %3?  " "3?$$3?  3? c] 3?  3?l.*  % %.*  " ".*$$.* 2 23 .*  8I$$ %y~ 56 .*bS2  % %S2S2 2 23S2 9 " "IcN 23 S2l/s/x}/d&C&HSM&R<+  % %<+<+ 2 23<+ 8I** +Ys^ ;< <+~1  % %1161A1A11h3  % %3161A1A33l/  % %//I223/ 9 )C. 01 /@MMM`  % %`  % %`$$` 2 23 `  9 )C. 01 `FI  % %I 2 23Ic]I(  % %161A1A 8I-- . # >?2<F  % %<F<F  SM Y 1 12 cN <F~ZM  % %ZMZM  T)55 67 Y & &' cN ZMzG0::GtG  % % 2 23 8I)) *IcN :; D"  % %"  " 2 23"$$ " s^ "J0  % %0  0 2 230s^ 0f34))$$   D%+))%+$$%+  %+"# %+  %+PQ6Q7Q]  % %]6C6P6P]]rH