
                             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KJ
r  SSKJr  SSKJr  SS0r " S S\R.                  5      rg),Instantiate a workflow template from a file.    )absolute_import)division)unicode_literalsN)dataproc)storage_helpers)util)base)flags)log)
console_ioEXAMPLESz      To instantiate a workflow template from a yaml file 'template.yaml' in
      region 'us-central1', run:

        $ {command} --file=template.yaml --region=us-central1
      c                   2    \ rS rSrSr\r\S 5       rS r	Sr
g)InstantiateFromFile+   r   c                     [         R                  " U5        [         R                  " USS5        [        R                  R                  U5        g )Nzworkflow templaterun)r   AddRegionFlagAddFileFlagr
   
ASYNC_FLAGAddToParser)clsparsers     @lib/surface/dataproc/workflow_templates/instantiate_from_file.pyArgsInstantiateFromFile.Args0   s5    		f159OO'    c                     [         R                  " U R                  5       5      nUR                  n[        R
                  " 5       R                  n[        R                  " U5      nUR                  R                  S5      (       a!  [        R                  " UR                  5      nO[        R                  " UR                  SS9n[        R                   " UR"                  US9nUR%                  UR'                  5       US9nXHl        UR*                  R,                  R/                  U5      n	UR0                  (       a9  [2        R4                  R7                  SR9                  U	R:                  5      5        g [        R<                  " X)5      n	U	$ )Nzgs://F)binary)message_typestream)parentworkflowTemplatez#Instantiating with operation [{0}].)dpDataprocReleaseTrackmessagesuuiduuid4hexdp_utilParseRegionfile
startswithr   
ReadObjectr   ReadFromFileOrStdinexport_utilImportWorkflowTemplate@DataprocProjectsRegionsWorkflowTemplatesInstantiateInlineRequestRelativeName	requestIdclient"projects_regions_workflowTemplatesInstantiateInlineasync_r   statusPrintformatname WaitForWorkflowTemplateOperation)
selfargsr   msgsinstance_idregions_refdatatemplaterequest	operations
             r   RunInstantiateFromFile.Run6   s>   {{4,,./HD **,""K%%h/KyyG$$''		2d++DIIeDd!!**49H
 KK))+# L % 
 $ oo88JJ
  {{	jj<CC
.. 88MIr    N)__name__
__module____qualname____firstlineno____doc__DETAILED_HELPdetailed_helpclassmethodr   rI   __static_attributes__rK   r   r   r   r   +   s!    4-( (
r   r   )rP   
__future__r   r   r   r(   googlecloudsdk.api_lib.dataprocr   r$   r   r	   r+   googlecloudsdk.callioper
   #googlecloudsdk.command_lib.dataprocr   !googlecloudsdk.command_lib.exportr1   googlecloudsdk.corer   googlecloudsdk.core.consoler   rQ   CreateCommandr   rK   r   r   <module>r]      sQ    3 &  '  : ; ; ( 5 A # 2 	
*$,, *r   