+~SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r Sr S*S jr S r S rS rSrSrSrSrSrS+SjrS,SjrS+SjrS+SjrS+SjrS+SjrS+SjrS+SjrS+SjrS+SjrS+SjrS+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+g )-z3Flags and helpers for the compute related commands.)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$)Nr r)arg_namer srPipelineAttributeConfigXGetPipelineResourceArg..GetPipelineResourceSpec..PipelineAttributeConfig(s  6 69..rz*datapipelines.projects.locations.pipelinespipelineF) resource_name pipelinesId locationsId projectsIddisable_auto_completers)r ResourceSpecr DEFAULT_PROJECT_ATTRIBUTE_CONFIG)rrr s 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 rAddCreatePipelineFlagsr2=&&v.rc6[5RU5 gr-r.r0s rAddUpdatePipelineFlagsr5Ar3rc6[5RU5 gr-r.r0s rAddDescribePipelineFlagsr7Er3rc6[5RU5 gr-r.r0s rAddDeletePipelineFlagsr9Ir3rc6[5RU5 gr-r.r0s rAddStopPipelineFlagsr;Mr3rc6[5RU5 gr-r.r0s rAddRunPipelineFlagsr=Qr3rc4[SS9RU5 g)NF)r*r.r0s rAddListJobsFlagsr?UsE*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 )rrrz--regionzCloud region {}.Tr%N) rr rr!rr'r(r)r/)r1verbregion_resource_specs rAddRegionResourceArgrCYsh"..('):: < ++% ,![(rcH[R"SUSRUS9S9$)Nz--display-namezDisplay name of the {noun}.)noun)r&help)rArgumentr))rEr&s rGetDisplayNameArgrHos*  ( / /T / : < c  rc0[R"SUSSS9$)Nz --dataflow-service-account-emailz7Default service account to run the dataflow workers as.rYrZr%s r!GetDataflowServiceAccountEmailArgrs! ( H  JJrc0[R"SUSSS9$)Nz!--scheduler-service-account-emailzKDefault service account used by the Cloud Scheduler job for launching jobs.rYrZr%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)rrGrrrrrenable_streaming_enginer%s rGetEnableStreamingEngineArgrsC !  ) )    ) ) A AC Q  rc x[R"SUSS[R"5[RSS9$)Nz--additional-experimentsADDITIONAL_EXPERIMENTSz%Default experiment flags for the job.rh)rrGrArgListrmr%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.rhrkr%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.rYz --worker-zonezBDefault Compute Engine zone in which worker processing will occur.)r ArgumentGroup AddArgumentrG)r&worker_region_argss rGetWorkerRegionArgsr8sk))84H   mm Y     mm W   rc6[R"SUSSSS/S9$)Nz --flexrs-goalz&FlexRS goal for the flex template job.COST_OPTIMIZEDSPEED_OPTIMIZED)r&rVrFrLrZr%s rGetFlexRsGoalArgrLs(  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&rjrFz--transform-name-mappingsNTRANSFORM_NAME_MAPPINGSz5Transform name mappings for the streaming update job.rh)rrrrGrStoreTrueFalseActionrlrm)r&streaming_update_argss rGetStreamingUpdateArgsrUs,,h?## mm 11@ BC ## mm %+""$))JLM r)rNTT)F)T),__doc__googlecloudsdk.callioperrr googlecloudsdk.calliope.conceptsr(googlecloudsdk.command_lib.util.conceptsrgooglecloudsdk.corerrr+r2r5r7r9r;r=r?rCrHrQrWr[r]rernrrrtrvrxrzr|r~rrrrrrrrrrrrrs:,/(5D*G %/%)&*$(<//////?),< K <J^8 (5r