dZddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z dd l mZdd l mZdd lmZdd lmZdd Ze j(e j*j,Gdde j.Ze j(e j*j2e j*j4GddeZy)z(Cloud Pub/Sub subscriptions ack command.)absolute_import)division)unicode_literals) exceptions) subscriptions)base)flags) resource_args)util)log) propertiesc>tj}|jjj }|sj|j ||}t jjdjdj||r|j|difS|ifSd}i} |j ||}tj ||\} } t jjdjdj| | r=t jjdjdj| |r|j|d}||fS#tj$r}tj|}Yd}~d}~wwxYw)zAcks one or more messages.z2Acked the messages with the following ackIds: [{}],)subscriptionIdackIdsNz:Failed to ack the messages with the following ackIds: [{}])rSubscriptionsClientCONCEPTS subscriptionParseAckr statusPrintformatjoin RelativeNameapi_ex HttpErrorr HandleExactlyOnceDeliveryError'ParseExactlyOnceAckIdsAndFailureReasons) argsack_ids legacy_outputcapture_failuresclientsubscription_refresultack_ids_and_failure_reasonserrorfailed_ack_idssuccessfully_processed_ack_idss 'lib/surface/pubsub/subscriptions/ack.py_Runr, s  , , .&]]//557  ZZ!1 2FJJ<CC HHW   ,99;   RZ & "M ZZ!1 2F483_3_!74,0.0**GNN hh-.01JJDKK HH^ $ &'*779F , ,,%   M"&"E"Ee"LMs*E**F=FFc.eZdZdZddiZedZdZy)r@Acknowledges one or more messages on the specified subscription. DESCRIPTIONa Acknowledges one or more messages as having been successfully received. If a delivered message is not acknowledged within the Subscription's ack deadline, Cloud Pub/Sub will attempt to deliver it again. To automatically acknowledge messages when pulling from a Subscription, you can use the `--auto-ack` flag on `gcloud pubsub subscriptions pull`. c\tj|dtj|dy)Nto ACK messages on. acknowledge.r AddSubscriptionResourceArgr AddAckIdFlagparsers r+ArgszAck.Args[s#,,V5JK v~.cDt||jd\}}|r|S|S)NT)r#)r,r!)selfr r&r's r+RunzAck.Run`s+*. dllT+3'F '" (( Mr9N)__name__ __module__ __qualname____doc__ detailed_help staticmethodr8r<r9r+rrKs/H  -//r9rc&eZdZdZedZdZy)AckBetar.c`tj|dtj|ddy)Nr1r2T)add_deprecatedr3r6s r+r8z AckBeta.Argsls%,,V5JK v~dCr9ctj|}tjjj j }t||d|\}}|r|S|S)NT)r#r")r ParseAckIdsArgsr VALUESpubsubr"GetBoolr,)r;r r!r"r&r's r+r<z AckBeta.RunqsZ##D)G%%,,::BBDM*. gM+K'F '" (( Mr9N)r=r>r?r@rBr8r<rCr9r+rErEhsHDDr9rEN)FF)r@ __future__rrrapitools.base.pyrrgooglecloudsdk.api_lib.pubsubrgooglecloudsdk.callioper!googlecloudsdk.command_lib.pubsubr r r googlecloudsdk.corer r r, ReleaseTracks ReleaseTrackGACommandrBETAALPHArErCr9r+rYs/&'17(3;2#*(-VD%%(()$,,*8D%%**D,=,=,C,CDcEr9