
    
                     F   S r SSKJr  SSKJr  SSKJr  SSK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0r\R"                  " SSS9\R$                  " \R&                  R(                  \R&                  R*                  5       " S S\R,                  5      5       5       rg)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                   2    \ rS rSrSr\r\S 5       rS r	Sr
g)Run(   r   c                     [         R                  " U SSS9  [         R                  " U SS9  [        R                  R                  U 5        g )Nrunv1)api_version24h)default)r
   AddTemplateResourceArgAddTimeoutFlagr	   
ASYNC_FLAGAddToParser)parsers    .lib/surface/dataproc/workflow_templates/run.pyArgsRun.Args2   s6    	  DA	/OO'    c                    [         R                  " U R                  5       5      nUR                  nUR                  R
                  R                  5       nUR                  R                  5       n[        R                  " 5       R                  Ul        UR                  UUR                  5       S9nUR                  R                  R!                  U5      nUR"                  (       a=  [$        R&                  R)                  SR+                  UR-                  5       5      5        g [.        R0                  " X'UR2                  S9nU$ )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   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____firstlineno____doc__DETAILED_HELPdetailed_helpstaticmethodr   r   __static_attributes__rE   r    r   r   r   (   s#     !-( (
r    r   )rJ   
__future__r   r   r   r-   googlecloudsdk.api_lib.dataprocr   r%   r   googlecloudsdk.callioper	   #googlecloudsdk.command_lib.dataprocr
   googlecloudsdk.corer   rK   	DeprecateReleaseTracksr'   ALPHABETACreateCommandr   rE   r    r   <module>rY      s     &  '  : 0 ( 5 # 	
 5:; D%%++T->->-C-CD $

   E	;
 r    