dZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z ddl m Zd Zd Zd Ze j$e j&j(Gd de j*Ze j.dde j$e j&j0GddeZy)z&Command to update a Datastream Stream.)absolute_import)division)unicode_literals)streams)util)base)flags) resource_argsz Update a Datastream stream. If successful, the response body contains a newly created instance of Operation. To get the operation result, call: describe OPERATION a To update a stream with a new source and new display name: $ {command} STREAM --location=us-central1 --display-name=my-stream --source=source --update-mask=display_name,source To update a stream's state to RUNNING: $ {command} STREAM --location=us-central1 --state=RUNNING --update-mask=state To update a stream's oracle source config: $ {command} STREAM --location=us-central1 --oracle-source-config=good_oracle_cp.json --update-mask=oracle_source_config.include_objects a  To update a stream with a new source and new display name: $ {command} STREAM --location=us-central1 --display-name=my-stream --source-name=source --update-mask=display_name,source_name To update a stream's state to RUNNING: $ {command} STREAM --location=us-central1 --state=RUNNING --update-mask=state To update a stream's oracle source config: $ {command} STREAM --location=us-central1 --oracle-source-config=good_oracle_cp.json --update-mask=oracle_source_config.allowlist c@eZdZdZeedZedZedZ dZ y)UpdateUpdates a Datastream stream. DESCRIPTIONEXAMPLESc<tj|d|dtj|tj|dtj |dtj |dtj|tj|y)a/Common arguments for all release tracks. Args: parser: An argparse parser that you can use to add arguments that go on the command line after this command. Positional arguments are allowed. release_track: Some arguments are added based on the command release track. updateF)requiredr N) r AddStreamResourceArg streams_flagsAddUpdateMaskFlagAddDisplayNameFlagAddBackfillStrategyGroupAddValidationGroup AddStateFlagr AddLabelsUpdateFlags)parser release_tracks (lib/surface/datastream/streams/update.py CommonArgszUpdate.CommonArgsDsu&&-%9##F+$$Ve<**6EB$$VX6v& v&c`tj|tjjyz@Args is called by calliope to gather arguments for this command.N)r rr ReleaseTrackGArs rArgsz Update.ArgsWs  fd//223r c|jjj}tj}|j |j |j|}tj}tj}tj}|jd|j|j|j}|j j#|j%|j&S)aCreate a Datastream stream. Args: args: argparse.Namespace, The arguments that this command was invoked with. Returns: A dict object representing the operations resource describing the create operation if the create was successful. z(datastream.projects.locations.operations) operationsId projectsId locationsId)name)CONCEPTSstreamParser StreamsClientr RelativeNamer#rGetClientInstanceGetMessagesModuleGetResourceParserCreater+r)r*projects_locations_operationsGet/DatastreamProjectsLocationsOperationsGetRequestr() selfargs stream_ref stream_clientresult_operationclientmessagesresource_parser operation_refs rRunz Update.Run\s%%++-J))+M$++J,C,C,E,0,=,=,?G # # %F%%'H,,.O#**2%**((** +,M  / / 3 3@@++ A - ..r N) __name__ __module__ __qualname____doc__rr detailed_help staticmethodrr&rAr rr r ?s:$"-8D-''$44.r r FzdDatastream beta version is deprecated. Please use`gcloud datastream streams update` command instead.) is_removedwarningc*eZdZdZeedZedZy) UpdateBetar rc`tj|tjjyr")r rrr#BETAr%s rr&zUpdateBeta.Argss  fd//445r N) rBrCrDrEr EXAMPLES_BETArFrGr&rHr rrLrL|s#%"-=I-66r rLN)rE __future__rrr!googlecloudsdk.api_lib.datastreamrrgooglecloudsdk.callioper%googlecloudsdk.command_lib.datastreamr r -googlecloudsdk.command_lib.datastream.streamsrrrrO ReleaseTracksr#r$Commandr DeprecaterNrLrHr rrXs-&'52(7?P   D%%(()9.T\\9.*9.x; D%%**+66,  6r