
    }                         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r
S	rS
rSr " S S\5      rS rS r " S S\5      r " S S\5      r " S S\5      r " S S\5      rg)z"API Library for gcloud cloudtasks.    )cmek_config)	locations)queues)tasks)apis)base
cloudtasksv2beta2v2beta3v2c                       \ rS rSrSrSrg)UnsupportedReleaseTrackError    z?Raised when requesting an api for an unsupported release track. N)__name__
__module____qualname____firstlineno____doc____static_attributes__r       ,lib/googlecloudsdk/api_lib/tasks/__init__.pyr   r       s    Gr   r   c                     U [         R                  R                  :X  a  [        $ U [         R                  R                  :X  a  [
        $ U [         R                  R                  :X  a  [        $ [        U 5      eN)	r   ReleaseTrackALPHAALPHA_API_VERSIONBETABETA_API_VERSIONGAGA_API_VERSIONr   release_tracks    r   ApiVersionFromReleaseTrackr$   $   s[    d''---d'',,,d''***
&}
55r   c                    U [         R                  R                  :X  a
  [        5       $ U [         R                  R                  :X  a
  [        5       $ U [         R                  R                  :X  a
  [        5       $ [        U 5      er   )	r   r   r   AlphaApiAdapterr   BetaApiAdapterr    GaApiAdapterr   r"   s    r   GetApiAdapterr)   /   sc    d''---d'',,,d''***>
&}
55r   c                       \ rS rSrS rSrg)BaseApiAdapter:   c                    [         R                  " [        U5      U l        U R                  R                  U l        [        R                  " U R                  R                  U R                  R                  5      U l        [        R                  " U R                  R                  U R                  R                  5      U l	        g r   )r   GetClientInstanceAPI_NAMEclientMESSAGES_MODULEmessagesr   	Locationsprojects_locationsr   
CmekConfig)selfapi_versions     r   __init__BaseApiAdapter.__init__<   s    ((;?DKKK//DM(()D)D)-)G)GIDN"--##T[[%C%CDr   )r0   r   r   r2   N)r   r   r   r   r8   r   r   r   r   r+   r+   :   s    r   r+   c                   (   ^  \ rS rSrU 4S jrSrU =r$ )r&   F   c                 D  > [         [        U ]  [        5        [        R
                  " U R                  R                  U R                  R                  5      U l        [        R                  " U R                  R                  U R                  R                  5      U l	        g r   )superr&   r8   r   r   AlphaQueuesr0   r1   projects_locations_queuesr   
AlphaTasksprojects_locations_queues_tasksr6   	__class__s    r   r8   AlphaApiAdapter.__init__H   sk    	/4)*;<$$T[[%@%@%)[[%J%JLDK!!$++"="="&++"M"MODJr   r   r   r   r   r   r   r8   r   __classcell__rC   s   @r   r&   r&   F   s    O Or   r&   c                   (   ^  \ rS rSrU 4S jrSrU =r$ )r'   P   c                 D  > [         [        U ]  [        5        [        R
                  " U R                  R                  U R                  R                  5      U l        [        R                  " U R                  R                  U R                  R                  5      U l	        g r   )r=   r'   r8   r   r   
BetaQueuesr0   r1   r?   r   TasksrA   rB   s    r   r8   BetaApiAdapter.__init__R   si    	.$()9:##DKK$?$?$(KK$I$IKDKT[[88![[HHJDJr   rE   rF   rH   s   @r   r'   r'   P       J Jr   r'   c                   (   ^  \ rS rSrU 4S jrSrU =r$ )r(   Z   c                 D  > [         [        U ]  [        5        [        R
                  " U R                  R                  U R                  R                  5      U l        [        R                  " U R                  R                  U R                  R                  5      U l	        g r   )r=   r(   r8   r!   r   Queuesr0   r1   r?   r   rM   rA   rB   s    r   r8   GaApiAdapter.__init__\   sf    	,&~6-- ; ; $ E EGDKT[[88![[HHJDJr   rE   rF   rH   s   @r   r(   r(   Z   rO   r   r(   N)r   googlecloudsdk.api_lib.tasksr   r   r   r   googlecloudsdk.api_lib.utilr   googlecloudsdk.callioper   r/   r   r   r!   	Exceptionr   r$   r)   objectr+   r&   r'   r(   r   r   r   <module>rZ      s    ) 5 2 / . , (   H9 H66	V 	On OJ^ JJ> Jr   