
    y                     V    S 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.    )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.Run5   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)	r.   googlecloudsdk.api_lib.dataflowr   googlecloudsdk.callioper   #googlecloudsdk.command_lib.dataflowr   Commandr   r)   r   r   <module>r6      s%    0 1 ( >-0T\\ -0r   