4SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKJ r SSKJ r SSKJ r SS K Jr SS K Jr SSK J r SS K Jr SS K Jr SS K Jr SSK Jr SSK Jr SSK Jr SSKJr SSKJr SSKJr SSKJr SSK J!r" SSK#J$r$ SSK#J%r% SSK#J&r& SSK'r'SSK(J)r) SSK(J*r* \"RVRXS\"RVRZS\"RVR\S0r/Sr0S/r1"S S!\Rd5r3g)"zDFunctions for creating a client to talk to the App Engine Admin API.)absolute_import)division)unicode_literalsN)encoding) exceptions) list_pager)build)env)instances_util)operations_util) region_util) service_util)util) version_util)appengine_api_client_base)logs) convert_yaml)appinfo)base)log) properties) resources)filter)mapv1v1alphav1betac>[Un[RU5$N)APPENGINE_VERSIONS_MAPAppengineApiClient GetApiClient) release_track api_versions 6lib/googlecloudsdk/api_lib/app/appengine_api_client.pyGetApiClientForTrackr&:s&}5+  ( ( 55python27c$\rSrSrSrSrSrSrS'SjrS(Sjr S(S jr S r S(S jr S r S rS)SjrSrSrS*SjrSrS+SjrS'SjrSrSrS*SjrS*SjrSrSrSrSrSrSrS'Sjr S(S jr!S!r"S"r#S#r$S$r%S%r&S&r'g),r!Az=Client used by gcloud to communicate with the App Engine API.cURRUR5S9nURRR U5$)zRetrieves the application resource. Returns: An app resource representing the project's app. Raises: apitools_exceptions.HttpNotFoundError if app doesn't exist name)messagesAppengineAppsGetRequest _FormatAppclientappsGet)selfrequests r%GetApplication!AppengineApiClient.GetApplicationDs=mm339J3KG ;;     ((r'cURRUR5US9nURRR U5$)a'Lists the available runtimes for the given App Engine environment. Args: environment: The environment for the application, either Standard or Flexible. Returns: v1beta|v1.ListRuntimesResponse, the list of Runtimes. Raises: apitools_exceptions.HttpNotFoundError if app doesn't exist )parent environment)r. AppengineAppsListRuntimesRequestr0r1r2 ListRuntimes)r4r:r5s r%r<AppengineApiClient.ListRuntimesPsFmm<< k=G ;;   ( ( 11r'cURURRRRURRRR 4;nU$)zChecks application resource to get serving status. Args: app: appengine_v1_messages.Application, the application to check. Returns: bool, whether the application is currently disabled. If serving or not set, returns False. ) servingStatusr. ApplicationServingStatusValueValuesEnum USER_DISABLEDSYSTEM_DISABLED)r4appstoppeds r% IsStoppedAppengineApiClient.IsStoppedbsT !!>>LL !!>>NN$PPG Nr'NcxURRUR5URR5S9nURR R U5n[R"SRURS95 [R"URRX1S9$)zCreates missing app resources. In particular, the Application.code_bucket GCS reference. Args: progress_message: str, the message to use while the operation is polled, if not the default. Returns: A long running operation. )r-repairApplicationRequest!Received operation: [{operation}] operationmessage)r.AppengineAppsRepairRequestr0RepairApplicationRequestr1r2Repairrdebugformatr-r WaitForOperationapps_operations)r4progress_messager5rLs r%RepairApplication$AppengineApiClient.RepairApplicationqsmm66 __ !%!G!G!I7KG   ''0III188..9"#  + + ##Y JJr'cSnU(a%URRURXS9nO$URRURUS9nU(aX4lURR R U5n[R"SRURS95 SRURUS9n[R"URRXVS9$) aHCreates an App Engine app within the current cloud project. Creates a new singleton app within the currently selected Cloud Project. The action is one-time and irreversible. Args: location: str, The location (region) of the app, i.e. "us-central" service_account: str, The app level service account of the app, i.e. "123@test-app.iam.gserviceaccount.com" ssl_policy: enum, the app-level SSL policy to update for this App Engine app. Can be DEFAULT or MODERN. Raises: apitools_exceptions.HttpConflictError if app already exists Returns: A long running operation. N)id locationIdserviceAccount)rZr[rJrKzMCreating App Engine application in project [{project}] and region [{region}].)projectregionrM)r.r@r] sslPolicyr1r2CreaterrRrSr-r rTrU)r4locationservice_account ssl_policycreate_requestrLrNs r% CreateAppAppengineApiClient.CreateApps&N}}00 \\h1Pn}}00 \\h10n!+   ''7III188..9"#$$*F4<<2:%+%<   + +DKK,G,G,5 HHr'c URXUXEUU5nSRUS9n UR[R[R4;aU S- n UR 5n U(aUR 5(aU (d[R"S5 O[R"URRU 5n [R"URRXU S9n[R"X5n U (a[R R#U 5nU(aUR%5(a[&R(R+UR,S[.R0R2R4R60SS9n [8R:"5R=U [R>S 9 [RN"URRU 5n[R"URRUUS 9$![@RBa [DRF"URI5RJ5n[&R(RMS [.R0R2R4R6UUR,S 9n [8R:"5R=U [R>S 9 GN!f=f) aUpdates and deploys new app versions. Args: service_name: str, The service to deploy. version_id: str, The version of the service to deploy. service_config: AppInfoExternal, Service info parsed from a service yaml file. manifest: Dictionary mapping source files to Google Cloud Storage locations. build: BuildArtifact, a wrapper which contains either the build ID for an in-progress parallel build, the name of the container image for a serial build, or the options for creating a build elsewhere. Not present during standard deploys. extra_config_settings: dict, client config settings to pass to the server as beta settings. service_account_email: Identity of this deployed version. If not set, the Admin API will fall back to use the App Engine default appspot service account. Returns: The Admin API Operation, unfinished. Raises: apitools_exceptions.HttpNotFoundError if build ID doesn't exist zUpdating service [{service}]servicez (this may take several minutes)zIUnable to determine build from Operation metadata. Skipping log streaming)rNpoller projectIdzcloudbuild.projects.builds)params collection)outz$cloudbuild.projects.locations.builds)rm projectsId locationsIdbuildsId)rj)(_CreateVersionrSr FLEX MANAGED_VMS_ResolveMetadataTypeIsBuildOptionsrwarningr AppEngineOperationBuildPollerr1rUrTGetBuildFromOperationapp_cloud_build BuildArtifactMakeBuildIdArtifact IsBuildIdrREGISTRYParse identifierrVALUEScorer] GetOrFailcloudbuild_logsCloudBuildClientStreamstatusapitools_exceptionsHttpNotFoundErrorrConvertToCloudRegionr6r[r`AppEngineOperationPoller)r4 service_name version_idservice_configmanifestr extra_config_settingsservice_account_emailrLrNoperation_metadata_typerjbuild_id build_refr^ done_pollers r% DeployService AppengineApiClient.DeployServicesiB##Ln$,5J$9;I-33L3IGchh88 33g"779 %%'' $ - .!>> KK ' ')@B#44 KK ' ' #88 0 !//CCHM% "" M&&,,   !2!2!7!7!?!?!I!IJ3-5  ((*11)1L":: ##%<>K  + + ## ! 2 2M**4+>+>+@+K+KL&&--=!((--55??%% .' ((*11)1LMsBH--C K:9K:c|SURRR5-n[URU5$)zAAttempts to resolve the expected type for the operation metadata.OperationMetadata)r1_VERSIONtitlegetattrr.)r4metadata_type_names r%ru'AppengineApiClient._ResolveMetadataTypes4-t{{/C/C/I/I/KK 4=="4 55r'cURX4X%UU5nURRURUS9US9n URR R U 5$)acBegins the updates and deployment of new app versions. Args: service_name: str, The service to deploy. version_id: str, The version of the service to deploy. service_config: AppInfoExternal, Service info parsed from a service yaml file. manifest: Dictionary mapping source files to Google Cloud Storage locations. build: BuildArtifact, a wrapper which contains either the build ID for an in-progress parallel build, the name of the container image for a serial build, or the options to pass to Appengine for a server-side build. extra_config_settings: dict, client config settings to pass to the server as beta settings. service_account_email: Identity of this deployed version. If not set, the Admin API will fall back to use the App Engine default appspot service account. Returns: The Admin API Operation, unfinished. r)r9version)_CreateVersionResourcer.*AppengineAppsServicesVersionsCreateRequest_GetServiceRelativeNamer1apps_services_versionsr`) r4rrrrr rrversion_resourcerds r%rr!AppengineApiClient._CreateVersion sn:22>3=3H3HJ]]MM+++F N"N ;; - - 4 4^ DDr'cURRURU5S9nURRR U5$)zzDescribe the given service. Args: service: str, the ID of the service Returns: Service resource object from the API r,)r.AppengineAppsServicesGetRequestrr1 apps_servicesr3)r4rir5s r%GetServiceResource%AppengineApiClient.GetServiceResource3sFmm;;  ) )' 2<4G ;; $ $ ( ( 11r'c,US0nURX5$)zSets the default serving version of the given services. Args: service_name: str, The service name version_id: str, The version to set as default. Returns: Long running operation. g?)SetTrafficSplit)r4rr allocationss r%SetDefaultVersion$AppengineApiClient.SetDefaultVersion@ss#K    ::r'c[R"URRUUS.5nURR UR US9URR US9USS9nSRUS9nURRRU5n[R"URRUUS9$) a2Sets the traffic split of the given services. Args: service_name: str, The service name allocations: A dict mapping version ID to traffic split. shard_by: A ShardByValuesEnum value specifying how to shard the traffic. migrate: Whether or not to migrate traffic. Returns: Long running operation. )rshardByr)splitr)r-rimigrateTraffic updateMaskz-Setting traffic split for service [{service}]rhrM)rPyValueToMessager. TrafficSplit!AppengineAppsServicesPatchRequestrServicerSr1rPatchr rTrU) r4rrshard_bymigrate traffic_splitupdate_service_requestrNrLs r%r"AppengineApiClient.SetTrafficSplitNs--dmm.H.H>I:B/DEM"]]LL  ) )| ) D %%M%: M >DDEG ))//0FGI  + +DKK,G,G,54; ==r'clURRUS9nURRURUS9URR US9SS9nSR US9nUR RRU5n[R"UR RXeS9$) zSets the ingress traffic allowed for a service. Args: service_name: str, The service name ingress_traffic_allowed: An IngressTrafficAllowed enum. Returns: The completed Operation. The Operation will contain a Service resource. )ingressTrafficAllowedr)networkSettingsr)r-rirz0Setting ingress settings for service [{service}]rhrM) r.NetworkSettingsrrrrSr1rrr rTrU)r4ringress_traffic_allowednetwork_settingsrrNrLs r%SetIngressTrafficAllowed+AppengineApiClient.SetIngressTrafficAllowedls}}44557!]]LL  ) )| ) D %%6F%G$M& AGGHG ))//0FGI  + + ##Y AAr'cURRURUUS9S9nURRR U5nSR X5n[R"URRXES9$)zDeletes the specified version of the given service. Args: service_name: str, The service name version_id: str, The version to delete. Returns: The completed Operation. rrr,zDeleting [{0}/{1}]rM) r.*AppengineAppsServicesVersionsDeleteRequest_FormatVersionr1rDeleterSr rTrU)r4rrdelete_requestrLrNs r% DeleteVersion AppengineApiClient.DeleteVersions]]MM  l,6!8N9N 2299.II")),CG  + + ##Y AAr'c4URRURUUS9URRUS9SS9nURR R U5nU(a+[R"URRU5$U$)aXSets the serving status of the specified version. Args: service_name: str, The service name version_id: str, The version to delete. serving_status: The serving status to set. block: bool, whether to block on the completion of the operation Returns: The completed Operation if block is True, or the Operation to wait on otherwise. r)r?r?)r-rr) r.)AppengineAppsServicesVersionsPatchRequestrVersionr1rrr rTrU)r4rrserving_statusblock patch_requestrLs r%SetServingStatus#AppengineApiClient.SetServingStatussMMKK  l,6!8 %%N%C" L$M  2288GI  - -dkk.I.I.799r'c /nUHnURRURURUR5S9n[ R "URRUSSSS9H1nUR[RRU55 M3 M U$![Ra Mf=f)zProduces a generator of all instances for the given versions. Args: versions: list of version_util.Version Returns: A list of instances_util.Instance objects for the given versions r9 instancesdpageSizefield batch_sizebatch_size_attribute)r.1AppengineAppsServicesVersionsInstancesListRequestrrirZr YieldFromListr1 apps_services_versions_instancesappendr InstanceFromInstanceResourcerr)r4versionsrrr5instances r% ListInstances AppengineApiClient.ListInstancessI OO$$W__gjjAPCg  "00 KK 8 8 !+ -H   %%::8D F -  ! 2 2   sA!B--CCc UR5n[R"SRU55 [R "XA(aU/OS5nUR U5n[R"SR[[[U5555 [R"XR(aU/OSU5n[[X555nURU5$)a(Generator of all instances, optionally filtering by service or version. Args: service: str, the ID of the service to filter by. version: str, the ID of the version to filter by. version_filter: filter function accepting version_util.Version Returns: generator of instance_util.Instance zAll services: {0}Nz Versions: {0}) ListServicesrrRrSrGetMatchingServices ListVersionslistrstrrGetMatchingVersionsrr)r4rirversion_filterservicesrs r%GetAllInstances"AppengineApiClient.GetAllInstancess  "HII!((23//w7)D2H  *HIIo$$T#c8*<%=>?//w7)D';HF>45H   h ''r'c URRUR5URRUS9S9nURR R U5n[R"URRU5$)aEnable debugging of a Flexible instance. Args: res: A googleclousdk.core.Resource object. ssh_key: str, Public SSH key to add to the instance. Examples: `[USERNAME]:ssh-rsa [KEY_VALUE] [USERNAME]` , `[USERNAME]:ssh-rsa [KEY_VALUE] google-ssh {"userName":"[USERNAME]",` `"expireOn":"[EXPIRE_TIME]"}` For more information, see Adding and Removing SSH Keys (https://cloud.google.com/compute/docs/instances/adding-removing-ssh- keys). Returns: The completed Operation. )sshKey)r-debugInstanceRequest) r.2AppengineAppsServicesVersionsInstancesDebugRequest RelativeNameDebugInstanceRequestr1rDebugr rTrU)r4resssh_keyr5rLs r% DebugInstance AppengineApiClient.DebugInstances~ mmNN    !]]??w?OOQG <<BB7KI  + +DKK,G,G,5 77r'cURRUR5S9nURRR U5n[ R"URRU5$)zvDelete a Flexible instance. Args: res: A googlecloudsdk.core.Resource object. Returns: The completed Operation. r,) r.3AppengineAppsServicesVersionsInstancesDeleteRequestrr1rrr rTrU)r4rr5rLs r%DeleteInstance!AppengineApiClient.DeleteInstancesfmmOO    P!G <<CCGLI  + +DKK,G,G,5 77r'cURRUR5S9nURRR U5$)zDescribe the given instance of the given version of the given service. Args: res: A googlecloudsdk.core.Resource object. Raises: apitools_exceptions.HttpNotFoundError: If instance does not exist. Returns: Version resource object from the API r,)r.0AppengineAppsServicesVersionsInstancesGetRequestrr1rr3)r4rr5s r%GetInstanceResource&AppengineApiClient.GetInstanceResourcesEmmLL    M!G ;; 7 7 ; ;G DDr'czURUUURRRRU5$)aStops the specified version. Args: service_name: str, The service name version_id: str, The version to stop. block: bool, whether to block on the completion of the operation Returns: The completed Operation if block is True, or the Operation to wait on otherwise. )rr.rrASTOPPEDr4rrrs r% StopVersionAppengineApiClient.StopVersions9   ::BB  r'czURUUURRRRU5$)aStarts the specified version. Args: service_name: str, The service name version_id: str, The version to start. block: bool, whether to block on the completion of the operation Returns: The completed Operation if block is True, or the Operation to wait on otherwise. )rr.rrASERVINGr s r% StartVersionAppengineApiClient.StartVersion,s9   ::BB  r'cURRUR5S9n/n[R"UR R USSSS9Hn0nUR(a?URRRHnURXER'M UR[R"URUR U55 M U$)zbLists all services for the given application. Returns: A list of service_util.Service objects. rrrrr)r. AppengineAppsServicesListRequestr0rrr1rrradditionalPropertiesvaluekeyrrrr]rZ)r4r5rrirrs r%rAppengineApiClient.ListServices>s mm<< ="GH++ !!7*Z9m ]]..CCE%*[[- "Doo   t||WZZ GI9 Or'cURRURX5URRRRS9nUR R RU5$)zDescribe the given version of the given service. Args: service: str, the ID of the service for the version to describe. version: str, the ID of the version to describe. Returns: Version resource object from the API. )r-view)r.'AppengineAppsServicesVersionsGetRequestrViewValueValuesEnumFULLr1rr3)r4rirr5s r%GetVersionResource%AppengineApiClient.GetVersionResourceRsammCC   2mm556I6I$$DQG ;; - - 1 1' ::r'c z/nUHnURRURUR5S9n[R "UR RUSSSS9H1nUR[RRXS55 M3 M U$![Ra Mf=f)zLists all versions for the specified services. Args: services: A list of service_util.Service objects. Returns: A list of version_util.Version objects. rrrrr)r.(AppengineAppsServicesVersionsListRequestrrZrrr1rrrrFromVersionResourcerr)r4rrrir5rs r%rAppengineApiClient.ListVersionsbsH FF--gjj9G;g  !// KK . . !+ -G //""66wH J - " O ! 2 2   sA!B""B:9B:c(URRSRUR5S9n[R "UR RUSSSS9nUVs/sH"n[RRU5PM$ sn$s snf)zList all regions for the project, and support for standard and flexible. Returns: List of region_util.Region instances for the project. zapps/{0}r, locationsrrr) r.!AppengineAppsLocationsListRequestrSr]rrr1apps_locationsr RegionFromRegionResource)r4r5regionslocs r% ListRegionsAppengineApiClient.ListRegions~s mm==   t|| ,>.G&& ""G;Z9GCJ J'3K   1 1# 6' JJ Js#)BcURRURUS9S9nURRR U5nSR U5n[R"URRUUS9$)zDeletes the specified service. Args: service_name: str, Name of the service to delete. Returns: The completed Operation. rr,z Deleting [{}]rM) r."AppengineAppsServicesDeleteRequestrr1rrrSr rTrU)r4rrrLrNs r% DeleteService AppengineApiClient.DeleteServices]]EE  ) )| ) DFFN ))00@I$$\2G  + +DKK,G,G,54; ==r'cURRURU5S9nURRR U5$)zGrabs details about a particular gcloud operation. Args: op_id: str, ID of operation. Returns: Operation resource object from API call. r,)r.!AppengineAppsOperationsGetRequest_FormatOperationr1rUr3)r4op_idr5s r% GetOperationAppengineApiClient.GetOperationsHmm==  " "5 )>+G ;; & & * *7 33r'cURRUR5US9n[R"UR R USSSS9nUVs/sHn[R"U5PM sn$s snf)zLists all operations for the given application. Args: op_filter: String to filter which operations to grab. Returns: A list of opeartion_util.Operation objects. )r-r operationsrrr) r."AppengineAppsOperationsListRequestr0rrr1rUr Operation)r4 op_filterr5r9ops r%ListOperations!AppengineApiClient.ListOperationsswmm>> __ ?G)) ##WLZ9J5? ?JbO % %b )J ?? ?s A<c \[R"URR55nSU;aSUS'SU;aSU;a[R "S5e[ R"URR5nURU5n [ R""S R[$R&"U S S S 955 UbXiS '0U S'X)SS'U(a{UR)5(aSUR*0U SS'OQUR-5(aSUR*0U SS'O'UR/5(aUR*U SS'[0R2"UR4R6U 5n U R8(a$U R8R:R=SS9 U(aSU ;a0U S'U SR?U5 SU ;aU RAS5n /n [CU RE55HAupU RGUR4R6RHRKXS95 MC UR4R6RIU S9U l&SU ;a/n[CU S5HdnURO5n[ R""SU5 URG[QUR4R6RRU55 Mf U(a?[ R""SU5 UU l.[ R""SU R\5 U R^R`R:R=[bRd"S 5S9 X;l3U $![aGn [R "SRUR[R"U 5S95eSn A ff=f![Ta$ [VRXR[SUS35ef=f![Ta Nf=f)!aConstructs a Version resource for deployment. Args: service_config: ServiceYamlInfo, Service info parsed from a service yaml file. manifest: Dictionary mapping source files to Google Cloud Storage locations. version_id: str, The version of the service. build: BuildArtifact, The build ID, image path, or build options. extra_config_settings: dict, client config settings to pass to the server as beta settings. service_account_email: identity of this deployed version. If not set, Admin API will fallback to use the App Engine default appspot SA. Returns: A Version resource whose Deployment includes either a container pointing to a completed image, or a build pointing to an in-progress build. entrypointapp_engine_apisapp_engine_bundled_serviceszdCannot specify both `app_engine_apis` and `app_engine_bundled_services` in the same `app.yaml` file.zc[{f}] could not be converted to the App Engine configuration format for the following reason: {msg})fmsgNzConverted YAML to JSON: "{0}"T)indent sort_keysr\ deploymentfilesimage container cloudBuildIdr cloudBuildOptionscUR$rr)xs r%;AppengineApiClient._CreateVersionResource.. sr'rQ betaSettings)rr)rappEngineBundledServiceszenum_value: %szInvalid bundled service: .zBundled services enums: %sz-version_resource.appEngineBundledServices: %sr)4copydeepcopyparsedToDictr ConfigErrorrGetSchemaParserr1r ConvertValue ValueErrorrSfilesix text_typerrRjsondumpsIsImagerr}rvrrr.r envVariablesrsortupdategetsorteditemsrBetaSettingsValueAdditionalPropertyrUupperr0AppEngineBundledServicesValueListEntryValuesEnumAttributeErrorr validationValidationErrorrVrJrKoperator attrgetterrZ)r4rrrr rr config_dict schema_parserjson_version_resourceer json_dict attributesrrbundled_services_enumsr enum_values r%r)AppengineApiClient._CreateVersionResources 2-- 5 5 < < >?K;&"$k, [( )[ 8  " " G  <"224;;3G3GHm+88E II-44 (dCEF(0E,-*,,'3;,'0  U%%< l+K8 ??   E,,8 l+G4    ! !    l+,?@001F1F1FH$$##88==> 4 402n-N+223HI ..'++N;ijy01*# MM ! ! 3 3 F F G & '2'+mm&;&;&M&M)'N'+#"%::!  : ;,"'')  "J/ ' '--''XX   (*@ 5K1 ;  5 5  !!''<<AA!!%(B% } <  " " 3396##q)94:4; <<rrrrrr__static_attributes__rr'r%r!r!AsE )2$ J0'H^+/*.Pd6,0+/%EN 2 ;7<=<A.A&"46(07. 7E"&$(; 8 K=" 4@.4837 KZ7>76G$F@!r'r!)4r __future__rrrrXrcrsapitools.base.pyrrrrgooglecloudsdk.api_lib.appr rzr r r r rrrgooglecloudsdk.api_lib.app.apir!googlecloudsdk.api_lib.cloudbuildrr/googlecloudsdk.appengine.admin.tools.conversionrgooglecloudsdk.appengine.apirgooglecloudsdk.callioper calliope_basegooglecloudsdk.corerrrra six.movesrr ReleaseTrackGAALPHABETAr r&rAppengineApiClientBaser!rr'r%rs K&' %>'?*15623+3DEH09#*) !!4$$i##X6 V2IIVr'