
    +                     B   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  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\
R6                  " \
R8                  R:                  5      \
R<                   " S S\
R>                  5      5       5       r g)z3Command to import an Anthos clusters on VMware API.    )absolute_import)division)unicode_literals)
operations)vmware_clusters)base)parser_arguments)	constants)flags)util)log)
console_io)gkeonprem_v1_messageszS
A cluster can be imported by running:

  $ {command} NAME --source=<path-to-file>
c                   f    \ rS rSrSrS\0r\S
S j5       r\S\	R                  4S j5       rS rSrg	)Import'   z(Import an Anthos on VMware user cluster.EXAMPLESc                 0    [         R                  " SSSU S9$ )N	gkeonpremv1VmwareClusterfor_help)export_utilGetSchemaPathr   s    /lib/surface/container/vmware/clusters/import.pyr   Import.GetSchemaPath.   s    $$T?X     parserc                     [         R                  " U S5        [        R                  " U [        R                  SS9S9  [        R                  R                  U 5        [         R                  " U 5        g )Nz	to importTr   )schema_path)
r   AddClusterResourceArgr   AddImportFlagsr   r   r   
ASYNC_FLAGAddToParserAddValidationOnly)r   s    r   ArgsImport.Args4   sU    	4F00$0? 	OO'	F#r   c                    UR                   R                  R                  5       n[        R                  " 5       n[
        R                  " UR                  =(       d    SSS9n[        R                  " [        R                  U[        R                  5       S9nUR                  XU5      nUR                  (       a+  UR                  S5      (       d  [         R"                  Ul        UR&                  (       a  g UR                  (       a$  [(        R*                  " USUR                  5        U$ [,        R.                  " 5       nUR1                  U5      n[(        R*                  " USUR                  5        U$ )N-F)binary)message_typestreamr!   formatzAnthos Cluster on VMware)CONCEPTSclusterParseapisClustersClientr   ReadFromFileOrStdinsourcer   r   messagesr   r   CreateFromImportasync_IsSpecifiedr
   OPERATIONS_FORMATr.   validate_onlyr   CreatedResourcer   OperationsClientWait)	selfargscluster_refcluster_clientdatavmware_cluster	operationoperation_clientoperation_responses	            r   Run
Import.Run=   s   --''--/K((*N))$++*<UKD ''++((*N //kI {{4++H55//dk{{	+'A4;;O#446+00;	+'A4;;Or    N)F)__name__
__module____qualname____firstlineno____doc__	_EXAMPLESdetailed_helpstaticmethodr   r	   ArgumentInterceptorr'   rH   __static_attributes__rJ   r   r   r   r   '   sJ     1y)- 
 $#77 $ $ r   r   N)!rO   
__future__r   r   r   *googlecloudsdk.api_lib.container.gkeonpremr   r   r2   googlecloudsdk.callioper   r	   .googlecloudsdk.command_lib.container.gkeonpremr
   +googlecloudsdk.command_lib.container.vmwarer   !googlecloudsdk.command_lib.exportr   r   googlecloudsdk.corer   googlecloudsdk.core.consoler   2googlecloudsdk.generated_clients.apis.gkeonprem.v1r   r6   rP   ReleaseTracksReleaseTrackALPHAHiddenCommandr   rJ   r   r   <module>rc      sz    : &  ' A N ( 4 D = A # 2 `	 D%%++,1 T\\ 1   -1 r   