
                         "   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  ej$                  ej&                  j(                  ej&                  j*                         G d dej,                               Zy)z3Command to trigger one-time run of a Dataplex task.    )absolute_import)division)unicode_literalsN)task)
exceptions)arg_parsers)base)resource_args)labels_utilc                   X    e Zd ZdZddiZed        Z ej                  d      d        Z	y)Runz(Trigger one-time run of a Dataplex task.EXAMPLESz          To trigger a one-time run of a Dataplex task `test-task` within
          lake `test-lake` in location `us-central1`, run:

           $ {command} test-task --location=us-central1 --lake=test-lake
          c           	          t        j                  | d       | j                  ddt        j                  g dt        j                                t        j                  |        y )Nzto run.ARGSzexecution-spec-argszSExecution spec arguments to pass to the driver. Follows the format argKey=argValue.)metavarnargsdefaulthelptype)	r
   AddTaskResourceArgadd_argumentargparse	REMAINDERr   ArgListr   AddCreateLabelsFlags)parsers    !lib/surface/dataplex/tasks/run.pyArgszRun.Args,   sZ    $$VY7
%      "  
 $$V,    z-Status code: {status_code}. {status_message}.c                 z    |j                   j                  j                         }t        j                  ||      }|S )N)CONCEPTSr   ParseRunTask)selfargstask_refrun_task_responses       r   r   zRun.Run<   s3     }}!!'')HXt4r   N)
__name__
__module____qualname____doc__detailed_helpstaticmethodr   gcloud_exception CatchHTTPErrorRaiseHTTPExceptionr    r   r   r   r      sO    0  - - - 5445r   r   )r+   
__future__r   r   r   r   googlecloudsdk.api_lib.dataplexr   googlecloudsdk.api_lib.utilr   r.   googlecloudsdk.callioper   r	   #googlecloudsdk.command_lib.dataplexr
   $googlecloudsdk.command_lib.util.argsr   ReleaseTracksReleaseTrackALPHAGACommandr   r0   r   r   <module>r<      so    : &  '  0 F / ( = < D%%++T->->-A-AB"$,, " C"r   