SrSSKJr SSKJr SSKJr SSKJr SSKJ r SSK Jr SSK J r SSK Jr SS K Jr SS KJr SS KJr \ R(\ R*"\ R,R.\ R,R05"S S \ R2555r\ R*"\ R,R65"SS\55rg)z'Cloud Pub/Sub snapshots create command.)absolute_import)division)unicode_literals) exceptions) snapshots)base)flags)util) labels_util)logc.\rSrSrSr\S5rSrSrg)Create ,Creates one or more Cloud Pub/Sub snapshots.cURSSSS9 URSSSS9 URS S S S 9 [R"U5 [R"U5 g )z!Registers flags for this command.snapshot+z%One or more snapshot names to create.)nargshelpz--subscriptionTaThe subscription whose backlog the snapshot retains. Specifically, the created snapshot is guaranteed to retain a) The existing backlog on the subscription, i.e., the set of messages in the subscription that are unacknowledged upon the successful completion of the create snapshot request, b) Any messages published to the subscription's topic following the successful creation of the snapshot.)requiredrz--subscription-projectz~The name of the project the provided subscription belongs to. If not set, it defaults to the currently selected cloud project.)defaultrN) add_argumentr AddCreateLabelsFlagsr AddTagsFlag)parsers &lib/surface/pubsub/snapshots/create.pyArgs Create.Args%s~ #$KM 6 8   "$$V, fc ## [R"5n[R"URUR 5n[ R"XRRR5n[R"XRRR5n/nURHgn[R"U5nUR!XXES9n [R8"U 5n [*R,"UR/5SS9 U v Mi U(a[R:"US5eg!["R$an [&R("U 5n [*R,"UR/5S[R0"U R2R45S9 UR7U5 Sn A GMSn A ff=f7f)aThis is what gets called when the user runs this command. Args: args: an argparse namespace. All the arguments that were provided to this command invocation. Yields: A serialized object (dict) describing the results of the operation. This description fits the Resource described in the ResourceRegistry under 'pubsub.projects.snapshots'. Raises: util.RequestFailedError: if any of the requests to the API failed. )labelstagsr)kindfailedN)r$create)rSnapshotsClientr ParseSubscription subscriptionsubscription_projectr ParseCreateArgsmessagesCreateSnapshotRequest LabelsValuer GetTagsMessage TagsValuer ParseSnapshotrapi_ex HttpErrorr HttpExceptionr CreatedResource RelativeNameCreateFailureErrorMessagepayloadstatus_messageappendSnapshotDisplayDictRequestsFailedError) selfargsclientsubscription_refr"r#r% snapshot_name snapshot_refresulterrorexcs rRun Create.RunAs & & (F--d.?.?.2.G.GI ( ( oo33??AF    oo33== DF '' 6l  6 ''/f ,335JG l''*  $ $VX 66  &&u-   % % '11#++2L2LM  m$s2CGE#A GGA3G GGGN) __name__ __module__ __qualname____firstlineno____doc__ staticmethodrrF__static_attributes__rHr rrr s5627r rc6^\rSrSrSr\U4Sj5rSrU=r$) CreateAlphavrc4>[[[] U5 g)N)superrQr)r __class__s rrCreateAlpha.Argszs +{(0r rH) rIrJrKrLrMrNrrO __classcell__)rUs@rrQrQvs411r rQN)rM __future__rrrapitools.base.pyrr2googlecloudsdk.api_lib.pubsubrgooglecloudsdk.api_lib.utilgooglecloudsdk.callioper!googlecloudsdk.command_lib.pubsubr r $googlecloudsdk.command_lib.util.argsr googlecloudsdk.corer DefaultUniverseOnly ReleaseTracks ReleaseTrackGABETA CreateCommandrALPHArQrHr rrgs.&'132(32<#D%%(($*;*;*@*@AQ7T  Q7BQ7hD%%++,1&1-1r