m 4 dZddlZddlZddlmZmZmZddlmZddlm Z ddl m Z ddl m Z ddl mZdd lmZdd lmZddlm Z dd lmZdd lmZdd lmZdd lmZddlm ZddlmZddlm Z dd l!mZ"ddl#m$Z$ddl#m%Z%ddl#m&Z&ddl#m'Z'ddl#m(Z(ddl#m)Z)ddl*m+Z+dd l,mZ-ddl.m/Z/ddl0m1Z1ddl2m3Z3ddl4m Z5ddl4m6Z6ddl4m7Z7ddl8m9Z9ddl8m:Z:ddl;mZ>d Z?ejd!ZAd"ZBejd#ZCd$ZDd%ZEd&ZFgd'ZGd(ZHd)ZId*ZJe:jd+d,-ZLe:jd.d/-ZMe:jd0d1-ZNeLeMeNgZOgd2ZPd3gePzZQd4ZRd5ZSd6ejd7eUd8ejfd9ZWd6ejd7eUd8ejfd:ZX dcd;ejdeeUd8ejf d?Z\d;ejdjd]d^_d`Z|d;ejdaejd8ejfdbZ~y)dzHThis 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. messagessourcereturnctj|}|stjt|j |j |jd|jdS)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+  ctj|}|tjt|j |j d|j d|j d}|j d}|j d}|j d}|r||_n|r||_n |xsd|_ |j| S) 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# "K K$/xK K 00rHargsr function_refkms_keyc|j}tj5}tj|||j }|j ratj|||j }|j|j|j|jcdddS|j|} |jj|j| |j!j#} tj,|| j.|j| j0cdddS#t$j&$r} t)j*| || d} ~ wwxYw#1swYyxYw)aConstructs 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}sl& # #($$&'44))M 33 t'8'8k__ .. '' 0@0@/ '&%-$E$E%F%! 22DD  U U)D#**,99; V  &&}dnnE __4+=+=_ >?'&2! * *""1g.3'&s7BF0FAE ;FF#E;;FFF existing_functionc |j.|,|jjjr dtfS|jxsd}|j}|j drt ||tdgfS|j drt||tdgfS|jxs|jj}tj||t||||t||tdgfS)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 6 *I7L6M,N NN $ 6 *I7L6M,N NNllC/;;CCG88I   '89   '()  **rHc i}|r|jrt|jjr^|jjjr>|jjjD]}|j||j<t j d|}t j|fi|}i}i}|rJ|jr>tj|jj|jj}tj|rQ tj||tj t#j$tj }n|}tj0|\} } tj0|\} } t3|||\}}}t5||\}}t7|dd}t7|dd}t9}|j:r|j=d|j>|j=d||j=d||j=d|j@ |jBr|j=d |jD |jFr|j=d |jH |jJ|j=d |jL|j=d ||k7r|j=d | | k7r|j=d| | k7r|j=dd}|jOdr|j=dn.|jOdr|jP}|j=dtRjU|||}|jWtY|j>|jBrdn |j@|jFrdn |jD|jHxs |jJ|jL||||j:xsd|jVj[t]|j_Dcgc],\}}|jVjZja||.c}}tjb| |tjd| |d|tg|||fS#t&$r3} t)j*t-j.| Yd} ~ d} ~ wwxYwcc}}w)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 availableCpubinaryAuthorizationPolicy)4 serviceConfigrrrr&rGetMapFlagsFromArgs ApplyMapFlags secrets_utilGetSecretsAsDictrrrIsArgsSpecified ApplyFlagsapi_util GetProject projects_utilGetProjectNumberrcore_exceptionsreraiserrASplitSecretsDict_GetVpcAndVpcEgressSettings_GetIngressSettingsgetattrset!serve_all_traffic_latest_revisionaddmemory max_instancesclear_max_instances min_instancesclear_min_instancesrun_service_accountservice_accounttimeoutIsKnownAndSpecifiedrrunion ServiceConfig_ParseMemoryStrToK8sMemoryEnvironmentVariablesValuesorteditemsAdditionalPropertySecretEnvVarsToMessagesSecretVolumesToMessages_ValidateK8sCpuStr)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_fieldsingress_settingsingress_updated_fieldsrrupdated_fieldsbinary_authorization_policyservice_updated_fieldsr&rs 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.Ax-P**mT2+eT"#5. ++FG [[89HI_56 #t'?'?:; #t'?'?:; )T-A-A-M=> \\78 =>++DE))67 $ :;CD  67"&";";CD$??0. 4T[[A  % % !!  % % !!"66N$:N:N*$%844<'55OO %+8>>+;$< $%=jc5((BBUUUV%= $ P &2%I%Ix& %<<h )4)#.$?A!DG$ $q @j77>??@T$sAR291S1 2 S.;(S))S.rc||sytjt|tj}|s%t j ddj ||jd}|jd}|d}ttDcgc]}|j|fc}}|j|j}|s%t j ddj |||z}|Scc}w)a`Parses 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 ++- 9s C6rc|ytjt|tj}|s%t j ddj ||jdxsd}|jd}|r|dk(r%t j ddj ||r-|tvr%t j dd j |||z}|S) axValidates 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@ 6/- rHc|jrdt|rdgng}}n|js |jrt ||tdg}}nn|j s|j s |jrt||tdg}}n1|r|jt}}ntjgdd|jdr(t|||\}}||_|j|}|r3t!j"|j$rt'j(|r>t!j*|j$rt'j,|j.||fS)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_GetEventTriggerr 3sb$ (,i.B/%M T22(D h)/"#&M T00D4N4N(@ h)/"#&M   ( ( +(m ? ?  F   g(1$-(P%L% ,M+112EF}11-2I2IJ779}33M4K4KL33M4N4NO * **rHc|j}|j}|jxs |j}|tj vrKt j|}|jtjt|||jS|tjvs|tjvrztjj!|j"}tjj%||}|j||j'd|g||jSt)j*ddj-|)a8Constructs 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)rrrrrzOEvent 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 rFrrrsI$$-**66N$:N:Nh;;;==>NOL  66),71++ ! x666 (DD D..667GHOOK!CCGG}  $  8; G 2++ !   - - $$*F=$9 rHc g}d}d}|jxs |j}|j}|jr'tj }t |j}n|jrC|jddjd}tj}|jd|g}n|jr|jjd}|jjD cgc]\}} |dk7r|j|| }}} |jrPd} |j|jjD cgc]\}} |j|| | c} }d} |j r2|j"j j%j'} |j)||||| | Scc} }wcc} }w) a9Constructs 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)rrrrchannelr)rrrrrrrrrstripEA_STORAGE_FINALIZErrrr"trigger_event_filters_path_patternextendtrigger_channelCONCEPTSParserqr) r]r4 event_filters event_typer rrr;attrvalr'r-s rFrrs-*,66N$:N:N** 55J();); t37;  ..%hBBHHJJidC   S8  LJ / mm3399;HHJO    /$  !s 3"G G rc|tjt|jr'|jj dt dgfS|jj dt dgfS)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 cJdjtj|S)Nzprojects/{}/topics/{})rrr)r s rFrrs ' '(;(;(=| LLrHc\t||||\}}i}|r|jrt|jjr^|jjjr>|jjjD]}|j||j <t jd|}t j|fi|} t} | |k7r| jd|j| jd|j| jd|jrdn |j} |j |jr| jd|j} | |j r| jd|j"} d}d}|j%drO| j'd |j(d k(r| j+}|j(d k(r| j-}t.j1|| }| j3|j|j|| | j2j5t7| j9Dcgc],\}}| j2j4j;|| .c}} | |||fScc}}w)aaConstructs 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_accountrdrupdater;AutomaticUpdatePolicyOnDeployUpdatePolicyrr 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_GetBuildConfigrTs",6   ,(/(  ' '  ' ' < <  ' ' < < Q Q %%::OO 5H4M4M,001 P!445EtL))/.5.));< !12 \\-.44$:P:P+ '4+G+G12../ D$D$D56  # #(   -. !![0 ( > > @ !![0 ( = = ?")>O%%,,  '33MM %+>+?+?+A$B $%Cjc5&&@@SSUT%C $ N ) 76"% $s$1J(c|jdr |jS|jdry|sdS|jS)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 rFrrcsA i << ( &H,=,H,HHrHc|jratjd|jjt j j|j}|tdgfSdtfS)aConstructs 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 rFrrwsq %66#++JJ66t,,-  !)-N,O"P PP  rHc|jrddtddgfSt}d}|jrD|jjj j }|jdn:|r8|jr,|jjr|jj}d}|jr||stjddtjd|jj t"j$j'|j}|jd||t|fS)a Constructs 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_settingsrX)clear_vpc_connectorrrrr.r/rqrrrrbrRequiredArgumentExceptionrr\r)VpcConnectorEgressSettingsValueValuesEnumrEGRESS_SETTINGS_MAPPINGr_)r]r4r~update_fields_setrrbs rFrrs5,    * :   e- MM//557DDFM89  ) )  ) ) 6 6%33@@M/    0 0  O   00"++UU55t++,  HI 3D)E EErHcztD]2\}}|j|stjt|zy)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_ValidateV1OnlyFlagsrms6"0mY  .  % %&9I&E FF#1rHc.|ri}n tti}tjj ||}|j |j j|r |jnd}|jr|jtdgfSdtfS)aConstructs 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 LabelsValuerp needs_updater)r]r4r~ro labels_diff labels_updates rF _GetLabelsr{s"O-/EFO  // O0+####"3-   H:!6 66  rHfunctionct}|r |jnd|_|jds|jdr$|jdrdn |j|_||j|jk7r=|j t j |j||j d|S)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_rV kms_key_name)rrarr_r ValidateKMSKeyForFunctionr)r]r|r~r^rs rF_SetCmekFieldsrs&5.&7""T  i D$4$4_$E  1t||     1 < < < ||))(*=*=|L~& rHc&t}|r|jjnd|j_|jds|jdr|jdrdn |j}t j ||j_|-|jj|jjk7r|jd|jr,|jjstjdd|S)arSets 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 NormalizeDockerRepositoryFormatrrarrd)r]r|r~rupdated_docker_repositorys rF_SetDockerRepositoryConfigrs "5. ##44  '  )*d.>.>/   5 6  # # 112KL ) !    0 0  ( ( 9 9 :9: !5!5!F!F  7 7 !  rHrkcNtjdj|dS)zMPrompts the user to allow unauthenticated invocations for the given function.z7Allow unauthenticated invocations of new function [{}]?F) prompt_stringdefault)rPromptContinuer)rks rF(_PromptToAllowUnauthenticatedInvocationsrPs&  " " C J J4 P  rH gcf_clientc$|j}|j}|j|jj |j |}|j j|}d}tj||||ty)aCreate 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 functionIdr|zDeploying functionN) r r45CloudfunctionsProjectsLocationsFunctionsCreateRequestrprqNamermCreaterWaitForOperation _EXTRA_STAGES)rr^r|r r4create_request operationoperation_descriptions rF_CreateAndWaitrZs"   &  (DD$$&335!&&(E1188H).  h #8-rHr c`|j}|j}|ru|j|jdj t ||}|j j|}d}tj||||tytjjdy)aOUpdate 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 updateMaskr|z$Updating function (may take a while)zNothing to update.N)r r44CloudfunctionsProjectsLocationsFunctionsPatchRequestrqjoinrrmPatchrrrrstatusPrint) rr^r|r r r4update_requestrrs rF_UpdateAndWaitr|s&   &  (EE**,xx'9 :; F 3399.IIB )%:MJJ)*rHi) max_retrialssleep_msc |j|jS#tj$r}t j d|d}~wwxYw)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 4 tj|}|j}|jjj }t ||j|j}|j|jjDcic]3}t|jdk(r|jd|ji5}}|du}|r|jst!j"st%j&ddt)|j+} t!j,| d} | | |_t.j0j3d j5|jt7j8r0|r.t|jd k(rt;j<d d |jxs|j>j} | r| |vrt;j<d | d| |vr*|| dr"|| dD]} t/j@| |r?|jBr3|jBjD} | | st/j@tFtI|||\}}tK||jL||\}}tO|||\}}tQ|||\}}|jS|j||||}tU||||}tW|||}tYjZdtYjZdtYjZdd}|j]dr |j^}n|r|sta|jb}tejftijj|j|jl|rto|||n(tpjs||||||}tu||||tw||}|r|s|r7|j]dr&tyjz||t|j~t.j0j3ddj5|j|jtijjz|Scc}w)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)rkrrrrpzrun.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_v2FunctionsClientr4r.rkr/rmrrq ListRuntimes locationsIdruntimesstr environmentrrr CanPromptrrdrkeys PromptChoicerrrrr ShouldUseGen2rrrwarningrr(_LATEST_REVISION_TRAFFIC_WARNING_MESSAGEr rTr rr{rvrrrPromptToEnableApiIfDisabledrrrNAMEr2ValidateDefaultBuildServiceAccountAndPromptWarningrrr?rrrrrrAddOrRemoveInvokerBindingr"ALLOW_UNAUTH_POLICY_BINDING_MEMBERr)r]rr r4r^r~r gen2_runtimesis_new_functionridxrw"has_all_traffic_on_latest_revisionrtrigger_updated_fields build_configrSservice_configr labels_valuelabels_updated_fieldsr|cmek_updated_fields docker_repository_updated_fieldsrrs rFRunrsv  $ $= A& __(##))+,t(()B)B)DE""<#;#;<EEE! Q]] w &ffz1::&&E &-/T\\    !  9 9 F m((*+H  ! !6 CC=DLJJN      ++ , 7  - -K  LL A-99AA'  -  - -i) )  -"8"D 7 #J / kk!n0,::''BB' +62 kk:;*: H'+'-'(7  mm ($,$,= H',(.()3 H')%,%     $ $ & "  (' H'&@ H'&",,-AB,,-HI,,-NO -. 66}DTYYOII!! 6<2__( N6<>B "6< 8(      2 3 &&)$GG **>O v  " "L$5$5$79L9L9N /as8R)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?rBrUrVr7rrirjrqrrStage_ARTIFACT_REGISTRY_STAGE_SERVICE_ROLLBACK_STAGE_TRIGGER_ROLLBACK_STAGErrrrr ModuleTyperrCrGr\ Namespace BaseApiClientResourcer}rvrrrrrrr rr RetryPolicyrrrrJrTrIngressSettingsrVpcConnectorEgressSettingsrrmrwr{rrboolrrrRetryOnExceptionr ReleaseTrackrrHrFrsO --%>;6DCC:B@79E5AF6<9?E<?E@:9=#)288*" BJJ23 BJJ   QK" .) D+%2+1111*00+1*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 .*bP  % %PP 2 23P 9 " "IcN 23 Pf/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~G0::GtG  % % 2 23 8I)) *IcN :; D"  % %"  " 2 23"$$ " s^ "J0  % %0  0 2 230s^ 0f34))$$   D%+))%+$$%+  %+"# %+  %+PQ6Q7Q]  % %]6C6P6P]]rH