jSrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSKJ r SSKJ r SSK J r SSK Jr SS KJr SS KJr SS KJr SSKrS rS rSrSrSrSrSrSrSrSrSr Sr!Sr"\""S\5"SS\RF55r$\""S\5"SS\RF55r%\ RL"SS 5r'\ RL"S!S"5r(\ RR"S#S$S%S&9r*\ RR"S#S$S'S%S(9r+\ RR"S#S$S'S)S(9r,\ RR"S#S$S)S&9r-\ RR"S*\ R\"SSS+9S,\R^"\R`RbRd5S-9r3S.r4S/r5S0r6S1r7S2r8S3r9S4r:S5S6S7S8S9S:.r;S5S6S7S8S9S:.rS?9r>\ RR"S@SA\ R~"\@\@SB9\ RSCSD9rB\ RR"SESF\ R"5\ RSGSD9rDSHrE\ RR"SISJ\ R~"\@\@SB9\ RSKSD9rF\ RR"SLS$\ R"5\ RSMSD9rG\ RR"SNS=SOS?9rHSPrI\ RR"SQ\'SRSSST9rJ\ RR"SU\(SVSWST9rK\ RR"SXSYSZ9rLS[rMS\rNS]rOS^rPS_R\5rRS`R\5rSSaR\5rTSbR\5rUScR\5rVSdrWSerX\ RR"SfS=SgS?9rY\ RR"ShSiSj/SkSl9rZ\ RR"SmSn\ R"5\ RSoSD9r[\ RR"SpSS=SqSr9r\\ RR"SsSS=StSr9r]\ RR"SuSS=SvSr9r^\ RR"SwSSx\ R"5SySz9r_\ RR"S{SS|S}9r`\ RR"S~SSS9ra\ RR"SSSZ9rb\ RR"SSR\5SZ9rc\ RR"SSSS}9rd\ RR"S\eSS9rf\ RR"SSj\ R~"\@\@S.S9SS9rg\ RR"SS=SS?9rh\ RR"SS=SS?9ri\ RR"S\ R~"\@\@S.S9SjSS9rj\ RR"SS=SSR\5S9rk\ RR"SSSSSR\5S9rl\ RR"SSSSSR\5S9rm\ RR"S\@\$SS9rn\ RR"S\@\$SS9ro\ RR"S\pS\%SS9rq\ RR"S\pS\%SR\5S9rr\ RR"S\pS\%SR\\5S9rs\ RR"S\pS\%SS9rt\ RR"S\pS\%SS9ru\ RR"S\ R"SSSS/SS9S\%SS9rw\ RR"S\ R"SSSS/SS9S\%SR\5S9rx\ RR"S\ R"SSSS/SS9S\%SR\\5S9ry\ RR"S\ R"SSSS/SS9\%SSS9rz\ RR"S\ R"SSSS/SS9\%SSS9r{\ RR"S\ R"SSSS/SS9\%SSS9r|\ RR"S\ R"SSSS/SS9\%SSR\5S9r}\ RR"S\ R"SSSS/SS9\%SSS9r~\ RR"S\ R"SSSS/SS9\%SSS9r\ RR"S\eS\%SS9r\ RR"S\%\eSSS9r\ RR"S\eSSS9r\ RR"S\e\%SSR\5S9r\ RR"SS\e\%SR\\5S9r\ RR"SSSSSS9r\ RR"SSSSSS9r\ RR"SSSSSS9r\ RR"SSSSSS9r\ RR"SS\%SSr9r\ RR"SSSSSR\5S9r\ RR"SSS=SR\5Sr9r\ RR"SSS=SR\5Sr9r\ RR"SSS\GR"SSSS9SR\\5S9r\ RR"SSS\GR"SSSS9SR\\5S9r\GR "SSS9/\GR""\ GR$GR&S9GR(GR*\;S9r\GR "SSS9/\GR""\ GR$GR.S9GR(GR*\;S9r\GR "SS\GR""\ GR$GR2S9GR(GR*\Sr9r\ RR"GS?SS=GS@Sr9r\ RR"GSASS=GSBSr9rGSCrGSDrGSErGSFrGSGrGSHrGSIr\ GR@"\\45r\ RR"GSJSJ\ R~"\\@SB9\ RGSKSD9rGSLrGSMrGS`GSNjrGSOrGSPrGSQrGSRrGSSrGSTrGSUrGSVrGSWrGSXrGSYrGSZrGS[rGS\rGS]rGS^rGS_rg(az3Helpers and common arguments for Composer commands.N)util)actions) arg_parsers)base) exceptions)parsers) arg_utils) labels_util) propertiesz2.2.5z2.0.313z2.0.32z2.4.0z1Cannot specify --{opt} without --{prerequisite}. z5Cannot specify --{opt} without enabling a triggerer. znCannot specify {opt}. Composer version {composer_version} and Airflow version {airflow_version} are required. z3Cannot specify {opt} with Composer 2.X or greater. z(Cannot specify {opt} with Composer 1.X. zRCannot specify {opt}. Composer version {composer_version} or greater is required. zJCannot specify {opt} with Composer version {composer_version} or greater. c^^UU4SjnU$)z9Creates Composer version specific ActionClass decorators.cB>^URmSUUU4SjjnXlU$)zGDecorates ActionClass to cross-validate argument with Composer version.c>SnUR(a9U"UR5T:wa#[R"TRUS95eT"XX#U5 g![a Nf=f)NcTURS5=(d URS5$)Nz composer-1.z composer-1-) startswith) image_versions 0lib/googlecloudsdk/command_lib/composer/flags.pyIsImageVersionStringComposerV1ڥValidateComposerVersionExclusiveOptionFactory..ValidateComposerVersionExclusiveOptionDecorator..DecoratedCall..IsImageVersionStringComposerV1Ps(((78((7 9)opt)r command_utilInvalidUserInputErrorformatAttributeError) selfparser namespacevalue option_stringrcomposer_v1_option error_message original_calls r DecoratedCall}ValidateComposerVersionExclusiveOptionFactory..ValidateComposerVersionExclusiveOptionDecorator..DecoratedCallNsw9  " "'E  # #(%(:(;22""}"57 7 D)MB    sA A A('A(N)__call__) action_classr$r#r!r"s @r/ValidateComposerVersionExclusiveOptionDecoratorfValidateComposerVersionExclusiveOptionFactory..ValidateComposerVersionExclusiveOptionDecoratorJs( ))MCC"* r)r!r"r)s`` r-ValidateComposerVersionExclusiveOptionFactoryr,Fs0 98rTc\rSrSrSrSrg)V1ExclusiveStoreActionezDStoreActionClass first validating if option is Composer 1 exclusive.r+N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r+rrr.r.esMrr.Fc\rSrSrSrSrg)V2ExclusiveStoreActionkzFStoreActionClass first validating if option is Composer >=2 exclusive.r+Nr0r+rrr8r8ksOrr8z*^(\d+(?:\.\d+(?:\.\d+(?:-build\.\d+)?)?)?)zmust be in the form X[.Y[.Z]].zh^composer-(\d+(?:\.\d+\.\d+(?:-[a-z]+\.\d+)?)?|latest)-airflow-(\d+(?:\.\d+(?:\.\d+(?:-build\.\d+)?)?)?)zmust be in the form 'composer-A[.B.C[-D.E]]-airflow-X[.Y[.Z]]' or 'latest' can be provided in place of the Cloud Composer version string. For example: 'composer-latest-airflow-1.10.0'.nameNAMEzThe name of an environment.)metavarhelp+)r<nargsr=z!The name or UUID of an operation.z --location)default_universenon_default_universez0The Cloud Composer location (e.g., us-central1).)requiredr=actionz}Only upper and lowercase letters, digits, and underscores are allowed. Environment variable names may not start with a digit.z"Invalid format of IPV4 CIDR block.z;Not a valid IPV4 CIDR block value for the kubernetes masterzr8r2Frz--master-ipv4-cidrz IPv4 CIDR range to use for the cluster master network. This should have a size of the netmask between 23 and 28. Cannot be specified unless `--enable-private-environment` is also specified. c[USS5$Nrrs rrrrrz--web-server-ipv4-cidrz IPv4 CIDR range to use for the Airflow web server network. This should have a size of the netmask between 24 and 29. Cannot be specified unless `--enable-private-environment` is also specified. c[USS5$)Nrrrrs rrrs8q"Erz--cloud-sql-ipv4-cidrz IPv4 CIDR range to use for the Cloud SQL network. This should have a size of the netmask not greater than 24. Cannot be specified unless `--enable-private-environment` is also specified. c[USS5$rrrs rrrrrz--composer-network-ipv4-cidrz IPv4 CIDR range to use for the Composer network. This must have a size of the netmask between 24 and 29. Can be specified for Composer 2.X or greater. Cannot be specified unless `--enable-private-environment` is also specified. c[USS5$)Nrrs rrrrrz#--composer-internal-ipv4-cidr-blockz The IP range in CIDR notation to use internally by Cloud Composer. This should have a netmask length of 20. Can be specified for Composer {} or greater. z$--enable-scheduled-snapshot-creationz When specified, snapshots of the environment will be created according to a schedule. Can be specified for Composer {} or greater. )rVr^rCrBr=z%--disable-scheduled-snapshot-creationzd Disables automated snapshots creation. Can be specified for Composer {} or greater. z--snapshot-creation-schedulez Cron expression specifying when snapshots of the environment should be created. Can be specified for Composer {} or greater. )rPrBrCr=z--snapshot-locationz The Cloud Storage location for storing automatically created snapshots. Can be specified for Composer {} or greater. )rPrCrBr=z--snapshot-schedule-timezonez Timezone that sets the context to interpret snapshot_creation_schedule. Can be specified for Composer {} or greater. z--maintenance-window-starta Start time of the mantenance window in the form of the full date. Only the time of the day is used as a reference for a starting time of the window with a provided recurrence. See $ gcloud topic datetimes for information on time formats. )rPrBr=z--maintenance-window-enda End time of the mantenance window in the form of the full date. Only the time of the day is used as a reference for an ending time of the window with a provided recurrence. Specified date must take place after the one specified as a start date, the difference between will be used as a length of a single maintenance window. See $ gcloud topic datetimes for information on time formats. z--clear-maintenance-windowza Clears the maintenance window settings. Can be specified for Composer {} or greater. z--maintenance-window-recurrencez An RFC 5545 RRULE, specifying how the maintenance window will recur. The minimum requirement for the length of the maintenance window is 12 hours a week. Only FREQ=DAILY and FREQ=WEEKLY rules are supported. z>Krcl[R"SSSRU5S9RU5 g)a"Adds a --source flag for a storage import command to a parser. Args: parser: argparse.ArgumentParser, the parser to which to add the flag folder: str, the top-level folder in the bucket into which the import command will write. Should not contain any slashes. For example, 'dags'. --sourceTz Path to a local directory/file or Cloud Storage bucket/object to be imported into the {}/ subdirectory in the environment's Cloud Storage bucket. Cloud Storage paths must begin with 'gs://'. rYNrArgumentr AddToParserrfolders rAddImportSourceFlagrs2--  &.&+f-rcn[R"SSSSRU5S9RU5 g)a'Adds a --destination flag for a storage import command to a parser. Args: parser: argparse.ArgumentParser, the parser to which to add the flag folder: str, the top-level folder in the bucket into which the import command will write. Should not contain any slashes. For example, 'dags'. --destination DESTINATIONFaV An optional subdirectory under the {}/ directory in the environment's Cloud Storage bucket into which to import files. May contain forward slashes to delimit multiple levels of subdirectory nesting, but should not contain leading or trailing slashes. If the DESTINATION does not exist, it will be created. r<rBr=Nrrs rAddImportDestinationFlagrs5-- &. &+f-rcj[R"SSRU5S9RU5 g)a!Adds a --source flag for a storage export command to a parser. Args: parser: argparse.ArgumentParser, the parser to which to add the flag folder: str, the top-level folder in the bucket from which the export command will read. Should not contain any slashes. For example, 'dags'. rz An optional relative path to a file or directory to be exported from the {}/ subdirectory in the environment's Cloud Storage bucket. rTNrrs rAddExportSourceFlagrs/--  &.  &+f-rcP[R"SSSSS9RU5 g)zAdds a --destination flag for a storage export command to a parser. Args: parser: argparse.ArgumentParser, the parser to which to add the flag rrTzz The path to an existing local directory or a Cloud Storage bucket/directory into which to export files. rN)rrr)rs rAddExportDestinationFlagrs* --   ;v rch[R"SSSRUS9S9RU5 g)Ntarget?z A relative path to a file or subdirectory to delete within the {folder} Cloud Storage subdirectory. If not specified, the entire contents of the {folder} subdirectory will be deleted. )r)r?r=rrs rAddDeleteTargetPositionalr s3--   && !"-V!4rc4[R"SU5SL$)zValidates that a user-provided arg is a valid environment variable name. Intended to be used as an argparse validator. Args: name: str, the environment variable name to validate Returns: bool, True if and only if the name is valid z^[a-zA-Z_][a-zA-Z0-9_]*$N)rematch)r:s r_IsValidEnvVarNamers ,d 34 ??rz--env-variablesanA comma-delimited list of environment variable `NAME=VALUE` pairs to provide to the Airflow scheduler, worker, and webserver processes. NAME may contain upper and lowercase letters, digits, and underscores, but they may not begin with a digit. To include commas as part of a `VALUE`, see `{top_command} topic escaping` for information about overriding the delimiter.c`[U5nSU::aUS::aU$[R"S5e)aDValidates that a user-provided arg is a valid user port. Intended to be used as an argparse validator. Args: val: str, a string specifying a TCP port number to be validated Returns: int, the provided port number Raises: ArgumentTypeError: if the provided port is not an integer outside the system port range iiz$PORT must be in range [1024, 65535].)intargparseArgumentTypeError)valports rIsValidUserPortr6s1 S$ T\dem K""#IJJrcXSnU(a!X-(a[R"US5egg)a`Validates that a disk size is a multiple of some number of GB. Args: parameter_name: parameter_name, the name of the parameter, formatted as it would be in help text (e.g., `--disk-size` or 'DISK_SIZE') disk_size: int, the disk size in bytes, or None for default value Raises: exceptions.InvalidArgumentException: the disk size was invalid i?z"Must be an integer quantity of GB.N)rr)parameter_name disk_sizegb_masks rValidateDiskSizerKs1 '9&  - -< >>'YrcURUS9nUR[S9nURU5 URU5 URU5 g)aAdds flags related to a partial update of arg represented by a dictionary. Args: update_type_group: argument group, the group to which flags should be added. clear_flag: flag, the flag to clear dictionary. remove_flag: flag, the flag to remove values from dictionary. update_flag: flag, the flag to add or update values in dictionary. group_help_text: (optional) str, the help info to apply to the created argument group. If not provided, then no help text will be applied to group. rTN)add_argument_groupadd_mutually_exclusive_group&GENERAL_REMOVAL_FLAG_GROUP_DESCRIPTIONr)update_type_group clear_flag remove_flag update_flaggroup_help_textgroup remove_groups r!_AddPartialDictUpdateFlagsToGroupr\sY  . .O . D%33 143, & ,' % rcLURSS[R"SS9SS9 g)z~Adds flag related to setting node count. Args: update_type_group: argument group, the group to which flag should be added. z --node-count NODE_COUNT)rdz>The new number of nodes running the environment. Must be >= 3.)r<rPr=N) add_argumentr BoundedIntrs rAddNodeCountUpdateFlagToGrouprts/     ! !a 0 K !MrcXURSS9n[RU5 [RU5 [RU5 [ RU5 [ RU5 [RU5 U(a[RU5 gg)a_Adds flags related to IP aliasing to parser. IP alias flags are related to similar flags found within GKE SDK: /third_party/py/googlecloudsdk/command_lib/container/flags.py Args: update_type_group: argument group, the group to which flag should be added. support_max_pods_per_node: bool, if specifying maximum number of pods is supported. zIP Alias (VPC-native)rTN) add_groupENABLE_IP_ALIAS_FLAGrCLUSTER_IPV4_CIDR_FLAGSERVICES_IPV4_CIDR_FLAG!CLUSTER_SECONDARY_RANGE_NAME_FLAG"SERVICES_SECONDARY_RANGE_NAME_FLAGENABLE_IP_MASQ_AGENT_FLAGMAX_PODS_PER_NODE)rsupport_max_pods_per_noders rAddIpAliasEnvironmentFlagsrs  % %+B % C%""5)$$U+%%e,#//6$007''.!!%(rcURSS9n[RU5 [RU5 [RU5 [ RU5 [ RU5 [RU5 [RU5 [RU5 U[RR:Xa [RRU5 O{U[RR:Xa [ RRU5 O=U[RR":Xa[$RRU5 [&RU5 g)aNAdds flags related to private clusters to parser. Private cluster flags are related to similar flags found within GKE SDK: /third_party/py/googlecloudsdk/command_lib/container/flags.py Args: update_type_group: argument group, the group to which flag should be added. release_track: which release track messages should we use. zPrivate ClustersrTN)rENABLE_PRIVATE_ENVIRONMENT_FLAGr DISABLE_PRIVATE_ENVIRONMENT_FLAGENABLE_PRIVATE_ENDPOINT_FLAGMASTER_IPV4_CIDR_FLAGWEB_SERVER_IPV4_CIDR_FLAGCLOUD_SQL_IPV4_CIDR_FLAGCOMPOSER_NETWORK_IPV4_CIDR_FLAGCONNECTION_SUBNETWORK_FLAGr ReleaseTrackGACONNECTION_TYPE_FLAG_GA choice_argBETACONNECTION_TYPE_FLAG_BETAALPHACONNECTION_TYPE_FLAG_ALPHA%ENABLE_PRIVATELY_USED_PUBLIC_IPS_FLAG)rrors rAddPrivateIpEnvironmentFlagsrs  % %+= % >%!--e4"..u5**51##E*''.&&u-!--e4((/d''***&&2259))...((44U;))///))55e<'33E:rcUR[5n[RU5 [ U[ [ [5 g)zAdds flag related to setting Pypi updates. Args: update_type_group: argument group, the group to which flag should be added. N)r$PYPI_PACKAGES_FLAG_GROUP_DESCRIPTIONUPDATE_PYPI_FROM_FILE_FLAGrrCLEAR_PYPI_PACKAGES_FLAGREMOVE_PYPI_PACKAGES_FLAGUPDATE_PYPI_PACKAGE_FLAG)rrs rAddPypiUpdateFlagsToGrouprs8  8 8* ,%((/#E+C$=$<>rcB[U[[[[5 g)zAdds flags related to updating environent variables. Args: update_type_group: argument group, the group to which flags should be added. N)rCLEAR_ENV_VARIABLES_FLAGREMOVE_ENV_VARIABLES_FLAGUPDATE_ENV_VARIABLES_FLAG$ENV_VARIABLES_FLAG_GROUP_DESCRIPTIONrs r AddEnvVariableUpdateFlagsToGrouprs $$57O$=$=$HJrcB[U[[[[5 g)zAdds flags related to updating Airflow configurations. Args: update_type_group: argument group, the group to which flags should be added. N)rCLEAR_AIRFLOW_CONFIGS_FLAGREMOVE_AIRFLOW_CONFIGS_FLAGUPDATE_AIRFLOW_CONFIGS_FLAG&AIRFLOW_CONFIGS_FLAG_GROUP_DESCRIPTIONrs r"AddAirflowConfigUpdateFlagsToGroupr s $$5$>$?$?$J LrcUR[SS9nU[RR:wa[ R U5 [R U5 g)zAdds flag group to perform in-place env upgrades. Args: update_type_group: argument group, the group to which flags should be added. release_track: gcloud version to add flags to. TmutexN)rENV_UPGRADE_GROUP_DESCRIPTIONrrrUPDATE_AIRFLOW_VERSION_FLAGrUPDATE_IMAGE_VERSION_FLAG)rro upgrade_groups rAddEnvUpgradeFlagsToGrouprsN$66#471-d''***++M:'' 6rcZUR[5n[R"U5 g)zAdds flags related to updating environment labels. Args: update_type_group: argument group, the group to which flags should be added. N)rLABELS_FLAG_GROUP_DESCRIPTIONr AddUpdateLabelsFlags)rlabels_update_groups rAddLabelsUpdateFlagsToGrouprs' *<<#% ""#67rc(UR[SS9n[RU5 UR[5n[ RU5 [ RU5 [RU5 [RU5 g)zAdds flags related to scheduled snapshot. Args: update_type_group: argument group, the group to which flags should be added. TrN) r,SCHEDULED_SNAPSHOTS_UPDATE_GROUP_DESCRIPTION#DISABLE_SCHEDULED_SNAPSHOT_CREATIONr%SCHEDULED_SNAPSHOTS_GROUP_DESCRIPTION"ENABLE_SCHEDULED_SNAPSHOT_CREATIONSNAPSHOT_LOCATIONSNAPSHOT_CREATION_SCHEDULESNAPSHOT_SCHEDULE_TIMEZONE)r update_group scheduled_snapshots_params_groups r AddScheduledSnapshotFlagsToGroupr%s#552$6@,%11,?%1%D%D+&-"$00&( @A(()IJ(()IJrcU[RR:Xa [RR U5 O{U[RR :Xa [RR U5 O=U[RR:Xa[RR U5 UR[5n[R U5 [R U5 [R U5 [R U5 [ R U5 ["R U5 [$R U5 [&R U5 [(R U5 [*R U5 [,R U5 UR[.SS9nUR[05n[2R U5 [4R U5 [6R U5 [8R U5 [:R U5 UR[<5n[>R U5 [@R U5 [BR U5 [DR U5 [FR U5 g)zAdds flags related to updating autoscaling. Args: update_type_group: argument group, the group to which flags should be added. release_track: gcloud version to add flags to. TrN)$rrrENVIRONMENT_SIZE_GArrrENVIRONMENT_SIZE_BETArENVIRONMENT_SIZE_ALPHAr"AUTOSCALING_FLAG_GROUP_DESCRIPTION SCHEDULER_CPU WORKER_CPUWEB_SERVER_CPUSCHEDULER_MEMORY WORKER_MEMORYWEB_SERVER_MEMORYSCHEDULER_STORAGEWORKER_STORAGEWEB_SERVER_STORAGE MIN_WORKERS MAX_WORKERS+TRIGGERER_PARAMETERS_FLAG_GROUP_DESCRIPTION#TRIGGERER_ENABLED_GROUP_DESCRIPTION TRIGGERER_CPUTRIGGERER_COUNTTRIGGERER_MEMORYENABLE_TRIGGERERDISABLE_TRIGGERER/DAG_PROCESSOR_PARAMETERS_FLAG_GROUP_DESCRIPTIONDAG_PROCESSOR_CPUDAG_PROCESSOR_COUNTDAG_PROCESSOR_MEMORYDAG_PROCESSOR_STORAGENUM_SCHEDULERS)rror#triggerer_params_grouptriggerer_enabled_groupdag_processor_params_groups r AddAutoscalingUpdateFlagsToGrouprFsd''***""../@A))...$$001BC))///%%112CD"55(*,L) &\*|,L) - -\*  . ,' ,''::1;?2EE)+34566767 67+>>5  :;!!"<=""#=>##$>?\*rcUR[5n[RU5 [RU5 [ RU5 g)zAdds flag group for master authorized networks. Args: update_type_group: argument group, the group to which flags should be added. N)r,MASTER_AUTHORIZED_NETWORKS_GROUP_DESCRIPTIONMASTER_AUTHORIZED_NETWORKS_FLAGr&ENABLE_MASTER_AUTHORIZED_NETWORKS_FLAG'DISABLE_MASTER_AUTHORIZED_NETWORKS_FLAG)rr#s r-AddMasterAuthorizedNetworksUpdateFlagsToGrouprL9sA #5524,!--l;(44\B)55lCrcUR[5n[RU5 [RU5 [ RU5 g)z~Adds flag group for maintenance window. Args: create_type_group: argument group, the group to which flags should be added. N)r)MAINTENANCE_WINDOW_FLAG_GROUP_DESCRIPTIONMAINTENANCE_WINDOW_START_FLAGrMAINTENANCE_WINDOW_END_FLAG"MAINTENANCE_WINDOW_RECURRENCE_FLAG)create_type_grouprs rAddMaintenanceWindowFlagsGrouprSFs?  % %&O P%++E2))%0$007rcUR[SS9n[RU5 UR [ 5n[ RU5 [RU5 [RU5 g)zAdds flag group for maintenance window used for an update operation. Args: update_type_group: argument group, the group to which flags should be added. TrN) r0MAINTENANCE_WINDOW_FLAG_UPDATE_GROUP_DESCRIPTIONCLEAR_MAINTENANCE_WINDOW_FLAGrrrNrOrPrQ)rr#rs r$AddMaintenanceWindowFlagsUpdateGrouprWRsj#556d6D, ++L9  !J K%++E2))%0$007rcUR[5nURSS9n[RU5 [RU5 g)zAdds flag group for Cloud Data Lineage integration. Args: update_type_group: argument group, the group to which flags should be added. TrN)r0CLOUD_DATA_LINEAGE_INTEGRATION_GROUP_DESCRIPTION*ENABLE_CLOUD_DATA_LINEAGE_INTEGRATION_FLAGr+DISABLE_CLOUD_DATA_LINEAGE_INTEGRATION_FLAG)rr#update_enable_disable_groups r0AddCloudDataLineageIntegrationUpdateFlagsToGroupr]csO #5568,!- ? ?d ? K,88!#-99!#rc[RU5 URSS9n[RU5 [RU5 URSS9n[ RU5 [ RU5 URSS9n[RU5 [RU5 [RU5 [RU5 g)zAdds Composer 3 flags to an update group. Args: update_type_group: argument group, the group to which flags should be added. Trz Virtual Private Cloud networkingrTN) SUPPORT_WEB_SERVER_PLUGINSrrENABLE_PRIVATE_BUILDS_ONLYDISABLE_PRIVATE_BUILDS_ONLYNETWORK_ATTACHMENTDISABLE_VPC_CONNECTIVITYr NETWORK_FLAGSUBNETWORK_FLAG&ENABLE_PRIVATE_ENVIRONMENT_UPDATE_FLAG'DISABLE_PRIVATE_ENVIRONMENT_UPDATE_FLAG)rprivate_builds_only_groupvpc_connectivity_groupnetwork_subnetwork_groups rAddComposer3FlagsToGrouprkss (():;/BB C(()BC))*CD,?? @  !78&&'=>3== ->3467(445FG)556GHrcU(aU$[R"SS9nU(a[R"U5/$[R"X5e)aProvides a list containing composer/location if `location_refs` is empty. This intended to be used as a fallthrough for a plural Location resource arg. The built-in fallthrough for plural resource args doesn't play well with properties, as it will iterate over each character in the string and parse it as the resource type. This function will parse the entire property and return a singleton list if `location_refs` is empty. Args: location_refs: [core.resources.Resource], a possibly empty list of location resource references flag_name: str, if `location_refs` is empty, and the composer/location property is also missing, an error message will be reported that will advise the user to set this flag name failure_msg: str, an error message to accompany the advisory described in the docs for `flag_name`. Returns: [core.resources.Resource]: a non-empty list of location resourc references. If `location_refs` was non-empty, it will be the same list, otherwise it will be a singleton list containing the value of the [composer/location] property. Raises: exceptions.RequiredArgumentException: both the user-provided locations and property fallback were empty F)rB)r GetLocation ParseLocationrRequiredArgumentException) location_refs flag_name failure_msgfallthrough_locations rFallthroughToLocationPropertyrtsG8  ,,e<  ! !"6 7 88  . .y FFrcUH?n[R(aUR5n[R"U5 MA g! [ R "SRU55e=f)zValidates list of IP ranges. Raises exception when any of the given strings is not a valid IPv4 or IPv6 network IP range. Args: ip_ranges: [string], list of IP ranges to validate zInvalid IP range: [{}].N)sixPY2decoderv ip_networkrrr) ip_rangesrZs rValidateIpRangesr{s\h ww"h68$  6  . . # * *8 4 66s A'A.r&)r5rrvrgooglecloudsdk.api_lib.composerrapi_utilgooglecloudsdk.callioperrrr#googlecloudsdk.command_lib.composerrr$googlecloudsdk.command_lib.util.apisr $googlecloudsdk.command_lib.util.argsr googlecloudsdk.corer rvMIN_TRIGGERER_AIRFLOW_VERSIONMIN_TRIGGERER_COMPOSER_VERSIONMIN_COMPOSER3_VERSION(MIN_SCHEDULED_SNAPSHOTS_COMPOSER_VERSION$MIN_COMPOSER_RUN_AIRFLOW_CLI_VERSIONPREREQUISITE_OPTION_ERROR_MSG!ENABLED_TRIGGERER_IS_REQUIRED_MSG.INVALID_OPTION_FOR_MIN_IMAGE_VERSION_ERROR_MSG _INVALID_OPTION_FOR_V2_ERROR_MSG _INVALID_OPTION_FOR_V1_ERROR_MSGCOMPOSER3_IS_REQUIRED_MSGCOMPOSER3_IS_NOT_SUPPORTED_MSGr, _StoreActionr.r8RegexpValidator_AIRFLOW_VERSION_TYPE_IMAGE_VERSION_TYPErENVIRONMENT_NAME_ARGMULTI_ENVIRONMENT_NAME_ARGMULTI_OPERATION_NAME_ARGOPERATION_NAME_ARGArgRequiredInUniverse StorePropertyVALUEScomposerlocation LOCATION_FLAG_ENV_VAR_NAME_ERROR_INVALID_IPV4_CIDR_BLOCK_ERROR)_INVALID_GKE_MASTER_IPV4_CIDR_BLOCK_ERROR)_INVALID_WEB_SERVER_IPV4_CIDR_BLOCK_ERROR(_INVALID_CLOUD_SQL_IPV4_CIDR_BLOCK_ERROR/_INVALID_COMPOSER_NETWORK_IPV4_CIDR_BLOCK_ERROR0_INVALID_COMPOSER_INTERNAL_IPV4_CIDR_BLOCK_ERROR_ENVIRONMENT_SIZE_MAPPING_ENVIRONMENT_SIZE_MAPPING_ALPHAr r ArgDictstr UpdateActionr ArgListr rrrrrrrrrrrr*rrrr6r=r7rHrYrrrrrKrJrIrrdrerbrrrWEB_SERVER_ALLOW_IPWEB_SERVER_DENY_ALLWEB_SERVER_ALLOW_ALLUPDATE_WEB_SERVER_ALLOW_IPr_r`raCLOUD_SQL_MACHINE_TYPEWEB_SERVER_MACHINE_TYPEfloatr+r>r8r,r- BinarySizer.r@r:r/r0r1rAr2r3r4r5rBr?r9ENABLE_HIGH_RESILIENCEDISABLE_HIGH_RESILIENCE!ENABLE_LOGS_IN_CLOUD_LOGGING_ONLY"DISABLE_LOGS_IN_CLOUD_LOGGING_ONLYCLOUD_SQL_PREFERRED_ZONErcrfrgDeprecationActionr;r<ChoiceEnumMapperGetMessagesModulerrEnvironmentConfigEnvironmentSizeValueValuesEnumr'rr(rr)AIRFLOW_DATABASE_RETENTION_DAYSrZr[STORAGE_BUCKET_FLAGryCustomFunctionValidator IPV4_CIDR_BLOCK_FORMAT_VALIDATORrrrrrrrrCONNECTION_TYPE_FLAG_HELPNetworkingConfigConnectionTypeValueValuesEnumrrrrr _IS_VALID_MASTER_IPV4_CIDR_BLOCK'MASTER_IPV4_CIDR_BLOCK_FORMAT_VALIDATORr$_IS_VALID_WEB_SERVER_IPV4_CIDR_BLOCK+WEB_SERVER_IPV4_CIDR_BLOCK_FORMAT_VALIDATORr#_IS_VALID_CLOUD_SQL_IPV4_CIDR_BLOCK*CLOUD_SQL_IPV4_CIDR_BLOCK_FORMAT_VALIDATORr*_IS_VALID_COMPOSER_NETWORK_IPV4_CIDR_BLOCK1COMPOSER_NETWORK_IPV4_CIDR_BLOCK_FORMAT_VALIDATORr3_IS_VALID_COMPOSER_INTERNAL_NETWORK_IPV4_CIDR_BLOCK:COMPOSER_INTERNAL_NETWORK_IPV4_CIDR_BLOCK_FORMAT_VALIDATOR COMPOSER_INTERNAL_IPV4_CIDR_FLAGrrr!r r"DatetimerrOrPrVrQrNrUSKIP_PYPI_PACKAGES_INSTALLATION"SKIP_ENVIRONMENT_VARIABLES_SETTINGSKIP_AIRFLOW_OVERRIDES_SETTINGSKIP_COPYING_GCS_DATArrrrrrrENV_VAR_NAME_FORMAT_VALIDATORCREATE_ENV_VARS_FLAGrrrrrrrrr rrr%rFrLrSrWr]rkrtr{r+rrrs: <+/(.7D:<* '!)+3('.$!%!2.$ $ " 9>/t/OQMX22MQM/u/OQOX22OQO$331$ "11o?@}} F!>@"]] F#,IK == F#,OQ]] F!DF   . .T <  !2!2!;!;!D!D E  =#GA*C*C)A0$1 %2%'%$1 %2%'%$1 #B'"]]   #mm    cc :  # #   $#mm       # #   >%!MM    cc :  # #   &!MM       # #    ==    G#mm      !MM     0"]]&  ;*Q&G%# fEF& %v&NO- &78, &./0 !!'(F!G$ O-#1 ==     == 3     0!MM       # #   }}     +/--*    + '*.)    * &#'--"        # %)MM$   % !}}  4  -- )]]  $% &*]]%   & "MM   mm    #   .mm   }}   "]]"   #    $"]]"    $%"]]"     $% #mm#     $%  !   -- !       !   MM   !  $%     ! -/LMO ]]   !      !   ==   &*D\    !   }}   &*D\    !  $% ==   &*D\    !  -/LM O    &*D\   "    MM   &*D\   "    MM   &*D\   "        &*D\   "   $%    &*D\   "    ]]   &*D\   "    mm  !   mm !        mm !  $%--  ! -/LM     --     %)MM)     %!&*]]*     &" ==  !   ==     $% *."    $%*&+/--#    $%+'==    $ $. /  -/LM OMM    $ $0 1  -/LM O 00 ! "?++''**66- "22 ! "?++'',,66- #33 ! ++''--663 #'--'   # .2]]-    . */3mm.    / +mm !   <$/#F#F9$;   )   --  )   $!MM      #'--"    # $(==#    $  $}}      )- (    ) %"]]  !   '77 & ++''--//?/?"" $&66 & ++'',,..>.>"" $$44 & ++$:K:K:N:NO33 57"C,G!+6*M*M$&O+Q'   0   G%/:.Q.Q(-//+!MM  4   F$.9-P-P',..* ==  3   G+5@4W4W.3551#'--"  : !  # G4'';8;$(==)  C !  $% $' &*]]*      78 &:"'+mm+     78':#"]]"  !  78:MM !   78:"]]" !   78:!%     # #   ! #mm    # #    !%     $%!'&*]]%   & "C*Q1#'--'    # &*]]*    & ""&&    "       >*.$.* .  5 @!, C C+!-}}    .3 @  # # A BK*>*7; !0 M).;8 > J L 78K(.+b D 88" # I:#GL6r