
    
                     L   d Z ddlmZ ddlmZ ddlmZ ddl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iZ ej"                  dd       ej$                  ej&                  j(                  ej&                  j*                         G d dej,                                      Zy)Run a workflow template.    )absolute_import)division)unicode_literalsN)dataproc)util)base)flags)logEXAMPLESz      To run a workflow template 'my-workflow-template' in region 'us-central1'
      , run:

        $ {command} my-workflow-template --region=us-central1
      FzWorkflow template run command is deprecated, please use instantiate command: "gcloud beta dataproc workflow-templates instantiate")
is_removedwarningc                   *    e Zd ZdZeZed        Zd Zy)Runr   c                     t        j                  | dd       t        j                  | d       t        j                  j                  |        y )Nrunv1)api_version24h)default)r
   AddTemplateResourceArgAddTimeoutFlagr	   
ASYNC_FLAGAddToParser)parsers    .lib/surface/dataproc/workflow_templates/run.pyArgszRun.Args2   s6    	  DA	/OO'    c                    t        j                  | j                               }|j                  }|j                  j
                  j                         }|j                  j                         }t        j                         j                  |_        |j                  ||j                               }|j                  j                  j!                  |      }|j"                  r=t$        j&                  j)                  dj+                  |j-                                      y t/        j0                  |||j2                        }|S )N)"instantiateWorkflowTemplateRequestnamezRunning [{0}].)	timeout_s)dpDataprocReleaseTrackmessagesCONCEPTStemplateParse"InstantiateWorkflowTemplateRequestuuiduuid4hex	requestId:DataprocProjectsRegionsWorkflowTemplatesInstantiateRequestRelativeNameclient"projects_regions_workflowTemplatesInstantiateasync_r   statusPrintformatNamer    WaitForWorkflowTemplateOperationtimeout)selfargsr   msgstemplate_refinstantiate_requestrequest	operations           r   r   zRun.Run8   s    {{4,,./HD==))//1L"++NNP$(JJL$4$4!MM+>&&( N *G BBNNI{{	jj'..|/@/@/BCD55)t||5Ir   N)	__name__
__module____qualname____doc__DETAILED_HELPdetailed_helpstaticmethodr   r    r   r   r   r   (   s#     !-( (
r   r   )rE   
__future__r   r   r   r+   googlecloudsdk.api_lib.dataprocr   r#   r   googlecloudsdk.callioper	   #googlecloudsdk.command_lib.dataprocr
   googlecloudsdk.corer   rF   	DeprecateReleaseTracksr%   ALPHABETACreateCommandr   rI   r   r   <module>rT      s     &  '  : 0 ( 5 # 	
 5:; D%%++T->->-C-CD $

   E	;
 r   