
                             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
  \R                  " \R                  R                  \R                  R                  5       " S S	\R                  5      5       rg
)z0`gcloud tasks queues create-pull-queue` command.    )GetApiAdapter)base)	constants)flags)parsers)logc                   8    \ rS rSrSrSSS.r\S 5       rS rSr	g	)

CreatePull   a\  Create a pull queue.

The flags available to this command represent the fields of a pull queue
that are mutable.

If you have early access to Cloud Tasks, refer to the following guide for
more information about the different queue target types:
https://cloud.google.com/cloud-tasks/docs/queue-types.
For access, sign up here: https://goo.gl/Ya0AZd
z#
          {description}
          z
          To create a Cloud Tasks pull queue:

              $ {command} my-queue
              --max-attempts=10 --max-retry-duration=10s
         )DESCRIPTIONEXAMPLESc                     [         R                  " U S5        [         R                  " U 5        [         R                  " U 5        g )Nz	to create)r   AddQueueResourceArgAddLocationFlagAddCreatePullQueueFlags)parsers    -lib/surface/tasks/queues/create_pull_queue.pyArgsCreatePull.Args5   s.    	fk2	&!	!!&)    c                    [        U R                  5       5      nUR                  n[        R                  " UR
                  UR                  5      n[        R                  " U5      n[        R                  " U[        R                  UR                  U R                  5       S9nU R                  5       [        R                  R                  :X  a2  UR                  UUUR                  UR                   UR"                  S9nO1UR                  UUUR                  UR                   UR$                  S9n[&        R(                  " [        R*                  " UR-                  5       5      S5        U$ )N)release_track)retry_configrate_limitspull_target)r   r   
queue_typequeue)r   ReleaseTrackqueuesr   
ParseQueuer   locationExtractLocationRefFromQueueRefParseCreateOrUpdateQueueArgsr   
PULL_QUEUEmessagesr   ALPHACreateretryConfig
rateLimits
pullTargettyper   CreatedResourceGetConsolePromptStringRelativeName)selfargsapiqueues_client	queue_reflocation_refqueue_configcreate_responses           r   RunCreatePull.Run;   s4   
))+
,CJJM""4::t}}=I99)DL77'')	+L
 d//555%,,

#//"--"-- - /o &,,

#//"--!&& - (o &&y'='='?@'Kr    N)
__name__
__module____qualname____firstlineno____doc__detailed_helpstaticmethodr   r7   __static_attributes__r9   r   r   r
   r
      s1    	- * *
r   r
   N)r>   googlecloudsdk.api_lib.tasksr   googlecloudsdk.callioper    googlecloudsdk.command_lib.tasksr   r   r   googlecloudsdk.corer   ReleaseTracksr   r&   BETACreateCommandr
   r9   r   r   <module>rI      se    7 7 ( 6 2 4 # D%%++T->->-C-CD:## : E:r   