VldZddlmZddlmZddlmZddlmZddlm Z ddl mZddl m Z ddl mZdd l mZdd l mZdd lmZdd lmZe j(d de j*e j,j.e j,j0Gdde j2Zy)z*Cloud Pub/Sub subscription modify command.)absolute_import)division)unicode_literals) exceptions) subscriptions)base)flags) resource_args)util)log) propertiesFzPThis command has been renamed. Please use `modify-message-ack-deadline` instead.) is_removedwarningc&eZdZdZedZdZy)ModifyAckDeadlinezModifies the ACK deadline for a specific Cloud Pub/Sub message. This method is useful to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted. ctj|dtj|ddtj|dy)Nzmessages belong to.zmodify the deadline for.T)add_deprecated)required)r AddSubscriptionResourceArgr AddAckIdFlagAddAckDeadlineFlag)parsers 7lib/surface/pubsub/subscriptions/modify_ack_deadline.pyArgszModifyAckDeadline.Args.s6,,V5JK v9$O Vd3ctj}|jjj }t j |}d}i} |j|||j}|D cgc]} | d } } |D cgc] } | | vs|  } } t"j$j'dj)|jdj+| |j-| rWt"j$j'dj)|jdj+| |j-|r|St.j0j2j4j7} | r|j-||jd}|S#tj$rL}tj|}tj|jj }|sYd}~d}~wwxYwcc} wcc} w)a<This 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. Returns: Display dictionary with information about the new ACK deadline seconds for the given subscription and ackId. NAckIdzUSet ackDeadlineSeconds to [{0}] for messages with ackId [{1}]] for subscription [{2}],z\Set ackDeadlineSeconds to [{0}] for messages with ackId [{1}]] failed for subscription [{2}])subscriptionIdackIdackDeadlineSeconds)rSubscriptionsClientCONCEPTS subscriptionParser ParseAckIdsArgsr ack_deadlineapi_ex HttpErrorr HttpExceptionr ParseExactlyOnceErrorInfopayloaddetailsr statusPrintformatjoin RelativeNamer VALUESpubsub legacy_outputGetBool)selfargsclientsubscription_refack_idsresultack_ids_and_failure_reasonserrorexcackfailed_ack_idsack_idsuccessfully_processed_ack_idsr5s rRunzModifyAckDeadline.Run4s . . 0F}}11779##D)G F"$ ''(8'(,(9(9;f/JJ.Isc'l.INJ$&$6n(DW#&JJ55;V**"@A)6686:;  jj 117.!9++-2/0 # ((%%,,::BBDM,99; $ 1 1f MI     $ $U +c$($B$B ++  %!) ) K&s+F4 H HHG=1AG88G=N)__name__ __module__ __qualname____doc__ staticmethodrrDrrrr!s 44 8rrN)rH __future__rrrapitools.base.pyrr(googlecloudsdk.api_lib.pubsubrgooglecloudsdk.api_lib.utilgooglecloudsdk.callioper!googlecloudsdk.command_lib.pubsubr r r googlecloudsdk.corer r Deprecate ReleaseTracks ReleaseTrackBETAALPHACommandrrJrrrXs1&'172(3;2#* -.D%%**D,=,=,C,CDF FE . Fr