File: //lib/google-cloud-sdk/lib/surface/dataflow/jobs/__pycache__/cancel.cpython-312.pyc
�
���
� �8 � d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z dd l
mZ dd
lmZ e
j" e
j$ j& e
j$ j( � e
j* G d � d e
j, � � � Zy
)z6Implementation of gcloud dataflow jobs cancel command.� )�absolute_import)�division)�unicode_literals)�apis)�
exceptions)�base)� job_utils)�log)�
console_ioc �& � e Zd ZdZed� � Zd� Zy)�Cancelz7Cancels all jobs that match the command line arguments.c �Z � t j | d�� | j ddd�� y)z Register flags for this command.�+)�nargsz--force�
store_truez�Forcibly cancels a Dataflow job. Regular cancel must have been attempted at least 30 minutes prior for a job to be force cancelled.)�action�helpN)r �ArgsForJobRefs� add_argument)�parsers �#lib/surface/dataflow/jobs/cancel.py�Argsz Cancel.Args" s2 � � � � �V�3�/�
�����
� � � c �x � t j |� D ]� } |j rt j dd�� t
j j |j |j |j |j �� t j j dj |j � � �� y# t j $ rc}t j j dj |j |j" j$ |j � � Y d}~�� d}~ww xY w)z�This is what gets called when the user runs this command.
Args:
args: all the arguments that were provided to this command invocation.
zeForce cancellation will leak VMs the cancelled Dataflow job created that must be manually cleaned up.T)�message� cancel_on_no)�
project_id� region_idzCancelled job [{0}]z�Failed to cancel job [{0}]: {1} Ensure that you have permission to access the job and that the `--region` flag, {2}, matches the job's region.N)r �ExtractJobRefs�forcer �PromptContinuer �Jobsr
�jobId� projectId�locationr
�status�Print�formatr �
HttpException�payload�status_message)�self�args�job_ref�errors r �Runz
Cancel.Run0 s� � � �+�+�D�1��
� �:�:�
�
#�
#�}� � �
� � ��� �M�M� �J�J� �(�(� �&�&� � (�
�
�
���.�5�5�g�m�m�D�E� 2�� �
%�
%�
� �
�
���
� #�V��
�
�u�}�}� ;� ;�W�=M�=M� �
�
��
�s �B&C�D9�AD4�4D9N)�__name__�
__module__� __qualname__�__doc__� staticmethodr r0 � r r r
r
s � � @�� � � �
r r
N)r4 �
__future__r r r � googlecloudsdk.api_lib.dataflowr �googlecloudsdk.api_lib.utilr �googlecloudsdk.callioper �#googlecloudsdk.command_lib.dataflowr �googlecloudsdk.corer
�googlecloudsdk.core.consoler �
ReleaseTracks� ReleaseTrack�BETA�GA�DefaultUniverseOnly�Commandr
r6 r r �<module>rD sz �� =� &� � '� 0� 2� (� 9� #� 2� ����D�%�%�*�*�D�,=�,=�,@�,@�A����+
�T�\�\� +
� � B�+
r