
                         z    S 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	\R                  5      rg
)z)Command to snapshot a Cloud Dataflow job.    )absolute_import)division)unicode_literals)apis)base)snapshot_utilsc                   8    \ rS rSrSrSSS.r\S 5       rS rSr	g	)
Create   z,Creates a snapshot for a Cloud Dataflow job.z{description}z          To create a Cloud Dataflow snapshot with sources for a running job, run:

            $ {command} --job-id=JOB_ID --region=JOB_REGION --snapshot-sources=true --snapshot-ttl=7d
          )DESCRIPTIONEXAMPLESc                     [         R                  " U 5        [         R                  " U 5        U R                  S[        SSS9  g)zfRegister flags for this command.

Args:
  parser: argparse.ArgumentParser to register arguments with.
z--snapshot-sourcesFz`If true, snapshots will also be created for the Cloud Pub/Sub sources of the Cloud Dataflow job.)typedefaulthelpN)r   ArgsForSnapshotJobRefArgsForSnapshotTtladd_argumentbool)parsers    (lib/surface/dataflow/snapshots/create.pyArgsCreate.Args(   sA     ((0%%f-
-	  .    c                     [         R                  " U5      n[        R                  R	                  UR
                  UR                  UR                  [         R                  " U5      UR                  S9$ )z~Runs the command.

Args:
  args: The arguments that were provided to this command invocation.

Returns:
  A Snapshot message.
)
project_id	region_idttlsnapshot_sources)
r   ExtractSnapshotJobRefr   JobsSnapshotjobId	projectIdlocationExtractSnapshotTtlDurationr   )selfargsjob_refs      r   Run
Create.Run8   s`     2248G99$$""55d;..  0 0r    N)
__name__
__module____qualname____firstlineno____doc__detailed_helpstaticmethodr   r*   __static_attributes__r,   r   r   r
   r
      s/    4 		- . .0r   r
   N)r1   
__future__r   r   r   googlecloudsdk.api_lib.dataflowr   googlecloudsdk.callioper   #googlecloudsdk.command_lib.dataflowr   Commandr
   r,   r   r   <module>r:      s,    0 &  ' 0 ( >-0T\\ -0r   