
    )                     8   d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl	m
Z
 ddl	mZ dd	lmZ  ej                  ej                  j                   ej                  j"                  ej                  j$                         G d
 dej&                               Zy)z%`gcloud tasks queues buffer` command.    )absolute_import)division)unicode_literals)GetApiAdapter)base)flags)parsers)logc                   0    e Zd ZdZdddZed        Zd Zy)BufferzBuffers a task into a queue.z"          {description}
          zn          To buffer into a queue:

              $ {command} --queue=my-queue --location=us-central1
         )DESCRIPTIONEXAMPLESc                     t        j                  | d       t        j                  | dd       t        j                  |        y )NT)requiredz$The location where the queue exists.)r   helptext)r   AddQueueResourceFlagAddLocationFlagAddTaskIdFlag)parsers    lib/surface/tasks/buffer.pyArgszBuffer.Args-   s8    	v5	(N 
    c                    t        | j                               }|j                  }t        j                  |j
                  |j                        }t        j                  |      }|dn|}|j                  ||       t        j                  j                  dj                  t        j                  |j                                            y )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   Runz
Buffer.Run5   s    
))+
,C99L""4::t}}=I!!$'GObG	7+JJ&--**9+A+A+CD	
r   N)__name__
__module____qualname____doc__detailed_helpstaticmethodr   r,    r   r   r   r      s1     %		-    r   r   N)r0   
__future__r   r   r   googlecloudsdk.api_lib.tasksr   googlecloudsdk.callioper    googlecloudsdk.command_lib.tasksr   r	   googlecloudsdk.corer
   ReleaseTracksr   ALPHABETAGACommandr   r3   r   r   <module>r>      sy    , &  ' 6 ( 2 4 # T..33T5F5F5I5I"T\\ ""r   