
                             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lm
Z ddlmZ ddlmZ ddiZ G d dej.                        Zy),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                   *    e Zd ZdZeZed        Zd Zy)InstantiateFromFiler   c                     t        j                  |       t        j                  |dd       t        j                  j                  |       y )Nzworkflow templaterun)r   AddRegionFlagAddFileFlagr
   
ASYNC_FLAGAddToParser)clsparsers     @lib/surface/dataproc/workflow_templates/instantiate_from_file.pyArgszInstantiateFromFile.Args0   s5    		f159OO'    c                    t        j                  | j                               }|j                  }t	        j
                         j                  }t        j                  |      }|j                  j                  d      r t        j                  |j                        }n!t        j                  |j                  d      }t        j                   |j"                  |      }|j%                  |j'                         |      }||_        |j*                  j,                  j/                  |      }	|j0                  r9t2        j4                  j7                  dj9                  |	j:                               y t        j<                  ||	      }	|	S )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   RunzInstantiateFromFile.Run6   s?   {{4,,./HD **,""K%%h/KyyG$''		2d++DIIeDd!!**49H
 KK))+# L % 
 $G oo88JJ
  {{	jj<CC
.. 889MIr   N)	__name__
__module____qualname____doc__DETAILED_HELPdetailed_helpclassmethodr   rG    r   r   r   r   +   s!    4-( (
r   r   )rK   
__future__r   r   r   r&   googlecloudsdk.api_lib.dataprocr   r"   r   r	   r)   googlecloudsdk.callioper
   #googlecloudsdk.command_lib.dataprocr   !googlecloudsdk.command_lib.exportr/   googlecloudsdk.corer   googlecloudsdk.core.consoler   rL   CreateCommandr   rO   r   r   <module>rX      sQ    3 &  '  : ; ; ( 5 A # 2 	
*$,, *r   