6,SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SS K J r SS K Jr S rS-S jrSrSrSrSrSrSrSrSrS.SjrS/SjrS.SjrS.SjrS.SjrS.SjrS.SjrS.Sjr S.Sjr!S.Sjr"S.S jr#S.S!jr$S.S"jr%S.S#jr&S.S$jr'S.S%jr(S.S&jr)S.S'jr*S.S(jr+S.S)jr,S.S*jr-S.S+jr.S.S,jr/g )0z3Flags and helpers for the compute related commands.)absolute_import)division)unicode_literals)actions) arg_parsers)base)concepts)concept_parsers) propertiesc,[R"SSS9$)Nregionz$The Cloud region for the {resource}.name help_textr ResourceParameterAttributeConfig5lib/googlecloudsdk/command_lib/datapipelines/flags.pyRegionAttributeConfigrs  2 2 E GGrNc^^UU4SjnT=(d Sm[RRSRU(aSOST5U"5TUS9$)z6Constructs and returns the Pipeline Resource Argument.c z>UU4Sjn[R"SSU"5[5[RSS9$)z?Constructs and returns the Resource specification for Pipeline.c.>[R"TTS9$)Nrr)arg_namersrPipelineAttributeConfigXGetPipelineResourceArg..GetPipelineResourceSpec..PipelineAttributeConfig+s  6 69..rz*datapipelines.projects.locations.pipelinespipelineF) resource_name pipelinesId locationsId projectsIddisable_auto_completers)r ResourceSpecr DEFAULT_PROJECT_ATTRIBUTE_CONFIG)rrrs rGetPipelineResourceSpec7GetPipelineResourceArg..GetPipelineResourceSpec(s;.  4 +-)+<< %  ''rz%Name for the Data Pipelines Pipeline.z{}{}z--required)r ConceptParser ForResourceformat)rr positionalr)r%s`` rGetPipelineResourceArgr."sQ 'BB)  & & 2 2 mm*B$9 3 rc6[5RU5 gNr. AddToParserparsers rAddCreatePipelineFlagsr5@&&v.rc6[5RU5 gr0r1r3s rAddUpdatePipelineFlagsr8Dr6rc6[5RU5 gr0r1r3s rAddDescribePipelineFlagsr:Hr6rc6[5RU5 gr0r1r3s rAddDeletePipelineFlagsr<Lr6rc6[5RU5 gr0r1r3s rAddStopPipelineFlagsr>Pr6rc6[5RU5 gr0r1r3s rAddRunPipelineFlagsr@Tr6rc4[SS9RU5 g)NF)r-r1r3s rAddListJobsFlagsrBXsE*66v>rc[R"SS[5[RS9n[R R SUSRU5SS9RU5 g) zAdd a resource argument for a Vertex AI region. NOTE: Must be used only if it's the only resource arg in the command. Args: parser: the parser for the command. verb: str, the verb to describe the resource, such as 'to update'. z datapipelines.projects.locationsr )rr r!z--regionzCloud region {}.Tr(N) r r#rr$r r*r+r,r2)r4verbregion_resource_specs rAddRegionResourceArgrF\sh"..('):: < ++% ,![(rcH[R"SUSRUS9S9$)Nz--display-namezDisplay name of the {noun}.)noun)r)help)rArgumentr,)rHr)s rGetDisplayNameArgrKrs*  ( / /T / : < c  rc0[R"SUSSS9$)Nz --dataflow-service-account-emailz7Default service account to run the dataflow workers as.r\r]r(s r!GetDataflowServiceAccountEmailArgr s! ( H  JJrc0[R"SUSSS9$)Nz!--scheduler-service-account-emailzKDefault service account used by the Cloud Scheduler job for launching jobs.r\r]r(s r"GetSchedulerServiceAccountEmailArgrs! ) \  ^^rc[R"SUS[R"[R R R5SS9$)Nz--enable-streaming-enginez@Specifies that enabling Streaming Engine for the job by default.r)rrJrrr rrenable_streaming_enginer(s rGetEnableStreamingEngineArgrsC !  ) )    ) ) A AC Q  rc x[R"SUSS[R"5[RSS9$)Nz--additional-experimentsADDITIONAL_EXPERIMENTSz%Default experiment flags for the job.rk)rrJrArgListrpr(s rGetAdditionalExperimentsArgr$s7  &     % % 6 88rc x[R"SUSS[R"5[RSS9$)Nz--additional-user-labelsADDITIONAL_USER_LABELSzDefault user labels to be specified for the job. Keys and values must follow the restrictions specified in https://cloud.google.com/compute/docs/labeling-resources#restrictions.rkrnr(s rGetAdditionalUserLabelsArgr/s:  &     % % C rc [R"USS9nUR[R"SUSSS95 UR[R"SUSSS95 U$) 3Defines the Streaming Update Args for the Pipeline.T)r)mutexz--worker-regionNzDDefault Compute Engine region in which worker processing will occur.r\z --worker-zonezBDefault Compute Engine zone in which worker processing will occur.)r ArgumentGroup AddArgumentrJ)r)worker_region_argss rGetWorkerRegionArgsr;sk))84H   mm Y     mm W   rc6[R"SUSSSS/S9$)Nz --flexrs-goalz&FlexRS goal for the flex template job.COST_OPTIMIZEDSPEED_OPTIMIZED)r)rYrIrOr]r(s rGetFlexRsGoalArgrOs(  7!23  55rc *[R"US9nUR[R"SU[R SS95 UR[R"SUSS[R "5[RSS 95 U$) rr(z--updatez+Set this to true for streaming update jobs.)r)rmrIz--transform-name-mappingsNTRANSFORM_NAME_MAPPINGSz5Transform name mappings for the streaming update job.rk)rrrrJrStoreTrueFalseActionrorp)r)streaming_update_argss rGetStreamingUpdateArgsrXs,,h?## mm 11@ BC ## mm %+""$))JLM r)rNTT)F)T)0__doc__ __future__rrrgooglecloudsdk.callioperrr googlecloudsdk.calliope.conceptsr (googlecloudsdk.command_lib.util.conceptsr googlecloudsdk.corer rr.r5r8r:r<r>r@rBrFrKrTrZr^r`rhrqrurwryr{r}rrrrrrrrrrrrrrrs:&'+/(5D*G %/%)&*$(<//////?),< K <J^8 (5r