gSrSSKJr SSKJr SSKJr SSKJr SSKJ r SSK Jr SSK J r SSK Jr SSKJr SS KJr SS KJr SS KrS rS rSSjr\ R,"\ R.R05"SS\ R255r\ R,"\ R.R6\ R.R85"SS\55rg )z(Cloud Pub/Sub subscription pull command.)absolute_import)division)unicode_literals) exceptions) subscriptions)base)flags) resource_args)utilNztable[box]( message.data.decode(base64).decode(utf-8), message.messageId, message.orderingKey, message.attributes.list(separator=' '), deliveryAttempt, ackId.if(NOT auto_ack) ) ztable[box]( message.data.decode(base64).decode(utf-8), message.messageId, message.orderingKey, message.attributes.list(separator=' '), deliveryAttempt, ackId.if(NOT auto_ack), ackStatus.if(auto_ack) ) c$[R"5nURRR 5nUR XAU5n0n/nUR (abUR(aQURVs/sHoRPM n nURX5 U(dUH n U SXmS'M UR (d UR$/nURHn0nUR+5H1n[-UUR.5nU(dM"UUUR.'M3 URU;aXhRUS'OSUS'UR1U5 M U$s snf![Ran [R"U 5n [R"U R R"5nU(d.U H(n S[$R&"U R(5-Xl'M* Sn A GNaSn A ff=f)z#Pulls messages from a subscription.FAILURE_N FailureReasonAckId ackStatusSUCCESS)rSubscriptionsClientCONCEPTS subscriptionParsePullauto_ackreceivedMessagesackIdAckapi_ex HttpErrorutil_ex HttpExceptionr ParseExactlyOnceErrorInfopayloaddetailssix text_type status_code all_fieldsgetattrnameappend)args max_messagesreturn_immediatelyclientsubscription_ref pull_responsefailed_ack_idsack_ids_and_failure_reasonsmessageack_idserrorexcack_idack_ids_and_failure_reason return_val message_copyfieldvalues (lib/surface/pubsub/subscriptions/pull.py_Runr<8s  , , .&]]//557++.02-. " ]]}55,9,J,JK,J}},JGK Q jj+ (C $2?C   )D   ) ))*//gL##%guzz*e #( UZZ &}}&"0"?l;"+l;l#0 IL    Q  ! !% (c$($B$B ++  %! )F#- e>O>O0P#P.  QsE6E;;HA5H  Hc6\rSrSrSrSS0r\S5rSrSr g) rj=Pulls one or more Cloud Pub/Sub messages from a subscription. DESCRIPTIONa  Returns one or more messages from the specified Cloud Pub/Sub subscription, if there are any messages enqueued. By default, this command returns only one message from the subscription. Use the `--limit` flag to specify the max messages to return. Please note that this command is not guaranteed to return all the messages in your backlog or the maximum specified in the --limit argument. Receiving fewer messages than available occasionally is normal.cURR[5 [R"US5 [ R "U5 [RRUS5 g)Nto pull messages from.) display_info AddFormatMESSAGE_FORMAT_WITH_ACK_STATUSr AddSubscriptionResourceArgr AddPullFlagsr LIMIT_FLAG SetDefaultparsers r;Args Pull.Args~sJ !!"@A,,V5MN vOOvq)c,[XR5$)N)r<limit)selfr)s r;RunPull.Runs jj !!rON) __name__ __module__ __qualname____firstlineno____doc__ detailed_help staticmethodrMrS__static_attributes__rUrOr;rrjs/E - **"rOrc.\rSrSrSr\S5rSrSrg)PullBetar?cURR[5 [R"US5 [ R "USSSS9 g)NrBT)add_deprecatedadd_waitadd_return_immediately)rDrErFr rGr rHrKs r;rM PullBeta.Argss? !!"@A,,V5MN td4rOcjURS5(a:URS5(a[R"SS5eURnO URnSnURS5(a UR nO'URS5(aUR (+n[XU5$)NrQr*z--max-messagesz--limitFr+wait) IsSpecifiedrConflictingArgumentsExceptionrQr*r+rgr<)rRr)r*r+s r;rS PullBeta.Runs    . ) )667G7@B BZZl&&l ,--22  & ! !#yy= $6 77rOrUN) rVrWrXrYrZr\rMrSr]rUrOr;r_r_sE8rOr_)F)rZ __future__rrrapitools.base.pyrrgooglecloudsdk.api_lib.pubsubrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioper!googlecloudsdk.command_lib.pubsubr r r r"MESSAGE_FORMATrFr< ReleaseTracks ReleaseTrackGA ListCommandrBETAALPHAr_rUrOr;rxs/&'17=(.3;2   "/dD%%(()"4  "*">D%%**D,=,=,C,CD8t8E8rO