
    )                     8   S r SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSK	J
r
  SSK	Jr  SS	KJr  \R                  " \R                  R                   \R                  R"                  \R                  R$                  5       " S
 S\R&                  5      5       rg)z%`gcloud tasks queues buffer` command.    )absolute_import)division)unicode_literals)GetApiAdapter)base)flags)parsers)logc                   8    \ rS rSrSrSSS.r\S 5       rS rSr	g	)
Buffer   zBuffers a task into a queue.z"          {description}
          zn          To buffer into a queue:

              $ {command} --queue=my-queue --location=us-central1
         )DESCRIPTIONEXAMPLESc                     [         R                  " U SS9  [         R                  " U SSS9  [         R                  " U 5        g )NT)requiredz$The location where the queue exists.)r   helptext)r   AddQueueResourceFlagAddLocationFlagAddTaskIdFlag)parsers    lib/surface/tasks/buffer.pyArgsBuffer.Args-   s8    	v5	(N 
    c                    [        U R                  5       5      nUR                  n[        R                  " UR
                  UR                  5      n[        R                  " U5      nUc  SOUnUR                  XE5        [        R                  R                  SR                  [        R                  " UR                  5       5      5      5        g )N zBuffered task in queue [{}].)r   ReleaseTracktasksr	   
ParseQueuequeuelocationParseTaskIdr   r
   statusPrintformatGetConsolePromptStringRelativeName)selfargsapitasks_client	queue_reftask_ids         r   Run
Buffer.Run5   s    
))+
,C99L""4::t}}=I!!$'GObG	+JJ&--**9+A+A+CD	
r    N)
__name__
__module____qualname____firstlineno____doc__detailed_helpstaticmethodr   r.   __static_attributes__r0   r   r   r   r      s1     %		-    r   r   N)r5   
__future__r   r   r   googlecloudsdk.api_lib.tasksr   googlecloudsdk.callioper    googlecloudsdk.command_lib.tasksr   r	   googlecloudsdk.corer
   ReleaseTracksr   ALPHABETAGACommandr   r0   r   r   <module>rC      sw    , &  ' 6 ( 2 4 # T..33T5F5F5I5I"T\\ ""r   