
                             S r SSKJr  SSKJr  \R
                  R                  S\R
                  R                  S\R
                  R                  S0r	 " S S\
5      r\R
                  R                  4S	 jrg
)zBCommon utility functions for getting the Managed Flink API client.    )apis)basev1alphav1betav1c                       \ rS rSrSrS rSrg)FlinkClient   z6Wrapper for Flink API client and associated resources.c                 r    [         R                  U5      nXl        [        R                  " SU5      U l        g Nmanagedflink)VERSION_MAPgetrelease_trackr   GetClientInstanceclient)selfr   api_versions      0lib/googlecloudsdk/api_lib/managed_flink/util.py__init__FlinkClient.__init__   s*    //-0K&((EDK    )r   r   N)__name__
__module____qualname____firstlineno____doc__r   __static_attributes__ r   r   r	   r	      s    >Fr   r	   c                 Z    [         R                  U 5      n[        R                  " SU5      $ r   )r   r   r   GetMessagesModule)r   r   s     r   r!   r!   %   s#    .+				<<r   N)r   googlecloudsdk.api_lib.utilr   googlecloudsdk.callioper   ReleaseTrackALPHABETAGAr   objectr	   r!   r   r   r   <module>r)      sq     I , ( 	YH$F& F %)$5$5$8$8 =r   