w%JSrSSKrSSKJr SSKJr SSKJr SSKJr SSS .r"S S \R5r "S S \R5r "SS\ 5r S\ S40r SrSrSrSrSrSrSrSrSrSrSrS&SjrSrS'SjrS(S jrS!rS"rS#rS$r S%r!g))z,Flags and helpers for the Managed Flink CLI.N) arg_parsers)base) completers)parameter_info_libz$The number of taskmanagers is fixed.zIThe number of taskmanagers is scaled automatically according to workload.)fixedelasticc6^\rSrSrSrSU4SjjrSrU=r$)ListCommandParameterInfo"z&Helper class for ListCommandCompleter.c,>[[U] UUUUS9$)N)check_properties for_update)superr GetFlag)selfparameter_nameparameter_valuer r __class__s 5lib/googlecloudsdk/command_lib/managed_flink/flags.pyr ListCommandParameterInfo.GetFlag%s+ )4 8) 9 )NTF)__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__ __classcell__rs@rr r "s.   rr c\rSrSrSrSrSrg)ListCommandCompleter4z%Helper class for DeploymentCompleter.c6[UUUR[S9$)N)updaters)r collectionCOMPLETERS_BY_CONVENTION)r parsed_args argumentss r ParameterInfo"ListCommandCompleter.ParameterInfo7s # )  rrN)rrrrrr*rrrrr"r"4s -rr"c,^\rSrSrSrU4SjrSrU=r$)DeploymentCompleter@z"Completer for listing deployments.c 4>[[U] "SSSS.UD6 g)Nz+managedflink.projects.locations.deploymentszmanaged-flink deployments list)r& list_commandr)rr-__init__)rkwargsrs rr1DeploymentCompleter.__init__Cs( t-@5 rr)rrrrrr1rrr s@rr-r-@s*rr- deploymentFcLURSSSSS9 URSSSS S9 g ) zAdds network config arguments.z--network-config-vpcNETWORKnetworkzThe network to use for the job.metavardesthelpz--network-config-subnetwork SUBNETWORK subnetworkz"The subnetwork to use for the job.N add_argumentparsers rAddNetworkConfigArgsrBOsB  ,   #  / rc(URSSSSS9 g)z Adds workload identity argument.z--workload-identityWORKLOAD_IDENTITYworkload_identityzpThe workload identity to use for the job. Managed Flink Default Workload Identity will be used if not specified.r8Nr>r@s rAddWorkloadIdentityArgumentrF_s$!  F rc V[R"SSSSS/SS9RU5 g) zCreates location argument.z --locationLOCATIONTlocationz--regionzThe location to run the job in.)r9requiredr:suggestion_aliasesr;NrArgument AddToParserr@s rAddLocationArgumentrOls.-- $ , KrcV[R"SS/SQSSS9RU5 g)zJob type arguments.z --job-typeJOB_TYPE)autojarpythonsqlrRzdThe type of job to run. If "auto" will be selected based on the file extension for the job argument.)r9choicesdefaultr;NrLr@s rAddJobTypeArgumentrXxs+--. - KrcN[R"SSSS9RU5 g)zCreates the job argument.jobz JAR|PY|SQLzLThe file containing the Flink job to run. Can be a jar, python, or sql file.r9r;NrLr@s rAddJobJarArgumentr\s%--   Krcx[R"SS[R"5SSS9R U5 g)z Creates the extra jars argument.z--jarsJAR extra_jarszEThe extra jars to pass to the job. Can be a jar, python, or sql file.r9typer:r;NrrMrArgListrNr@s rAddExtraJarsArgumentrds4--      Krc T[R"SSSSSSS9RU5 g)zCreates dry run argument.z --dry-run store_truedry_runFz9Return command used to submit a job without invoking API.actionr:rWrJr;NrLr@s rAddDryRunArgumentrjs,--   F KrcP[R"SSSSS9RU5 g)Creates main class argument.z--classCLASS main_classzaThe main class of the Flink job. Required if the jar file manifest does not contain a main class.r8NrLr@s rAddMainClassArgumentros(--  , KrcBURS[RSS9 g)z0Collects extra arguments into the job_args list.job_argszThe job arguments to pass.)nargsr;N)r?argparse REMAINDERr@s rAddJobArgsCollectorrus$    'rcR[R"SSSSSS9RU5 g)zCreates name argument.z--nameNAMEnameFz@The name of the job. The Flink job name will be used if not set.r9r:rJr;NrLr@s rAddNameArgumentrzs)--  M  KrcN[R"SSSS9RU5 g)zCreates job id argument.job_idJOBIDzThe id of the job.r[NrLr@s rAddJobIdArgumentr~s#-- Krc T[R"SSSUSSS9RU5 g)zCreates async argument.z--asyncrf async_submitFz(Return immediately after job submission.rhNrL)rArWs rAddAsyncArgumentrs,--   5 KrcR[R"SSSSSS9RU5 g)z"Creates staging location argument.z--staging-locationSTAGING_LOCATIONstaging_locationTzLThe Google Cloud Storage staging location for the job. Must start with gs://ryNrLr@s rAddStagingLocationArgumentrs+--   Krc U(aUnOSnU(aSRX45n[R"SSUS[US9R U5 g)zCreates deployment argument.z: The Flink Deployment to use for this invocation. z z --deploymentDEPLOYMENT_NAMEr4)r9rJr: completerr;N)joinrrMr-rN)rAhelp_text_to_prependhelp_text_to_overwriterJ help_texts rAddDeploymentArgumentrsT&II 1=>I-- #  Krc ^[R"SS[UUSSS9RU5 g)z!Creates autotuning mode argument.z--autotuning-modeAUTOTUNING_MODEautotuning_modez%Selects the autotuning mode for jobs.)r9rVrWrJr:r;N)rrM_AUTOTUNING_MODESrN)rArWrJs rAddAutotuningModeArgumentrs1--  2KrcLURS[R"SSS9SS9 g)z!Adds fixed parallelism arguments.z --parallelism' lower_bound upper_boundz;The parallelism of the job when in "fixed" autotuning mode.rar;Nr?r BoundedIntr@s rAddFixedParallelismArgsr's+  ! !aU C HrcURS[R"SSS9SS9 URS[R"SSS9SS9 g ) z#Adds elastic parallelism arguments.z--min-parallelismrrrz{The minimum parallelism of the job when in "elastic" autotuning mode. This will also be the initial parallelism of the job.rz--max-parallelismzEThe maximum parallelism of the job when in "elastic" autotuning mode.Nrr@s rAddElasticParallelismArgsr0s[  ! !aU C I    ! !aU C  rc T[R"SSSSSSS9RU5 g)zCreates show output argument.z--enable-outputrf show_outputFz%Shows the output of the Flink client.rhNrLr@s rAddShowOutputArgumentrDs,--   2 Krcx[R"SS[R"5SSS9R U5 g)z$Creates the extra archives argument.z --archivesZIParchivesz_The extra archives to pass to the job. Can be a zip file containing resource files for the job.r`Nrbr@s rAddExtraArchivesArgumentrPs4--     ) KrcP[R"SSSSS9RU5 g)rlz --python-venvr python_venvzThe path to the zip file to manage the virtualenv for Python dependencies. Required if the job type is python. Must start with gs://.r8NrLr@s rAddPythonVirtualEnvArgumentr^s(--   Kr)F)NNF)rF)"rrsgooglecloudsdk.callioperrgooglecloudsdk.command_lib.utilrrrParameterInfoByConventionr r"r-r'rBrFrOrXr\rdrjrorurzr~rrrrrrrrrrrrrs3/(6>4 1KK$ ::: .)+>*FG       2      8 (   r