File: //lib/google-cloud-sdk/lib/surface/storage/__pycache__/rm.cpython-312.pyc
�
��8) � �0 � d Z ddlmZ ddlmZ ddlmZ ddlZddlmZ ddlmZ ddl
m Z dd l m
Z
dd
l mZ dd l mZ dd l mZ dd
l mZ ddl mZ ddl mZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ e j8 G d� de j: � � Z y)z4Implementation of rm command for deleting resources.� )�absolute_import)�division)�unicode_literalsN)� cloud_api)�errors)�base)�flags)� folder_util)�name_expansion)� plurality_checkable_iterator)�rm_command_util)�stdin_iterator)�user_request_args_factory)�
task_executor)�task_graph_executor)� task_status)� delete_task_iterator_factory)�logc �0 � e Zd ZdZddd�Zed� � Zd� Zy)�RmzDelete objects and buckets.z)
Delete objects and buckets.
a�
The following command deletes a Cloud Storage object named ``my-object''
from the bucket ``my-bucket'':
$ {command} gs://my-bucket/my-object
The following command deletes all objects directly within the directory
``my-dir'' but no objects within subdirectories:
$ {command} gs://my-bucket/my-dir/*
The following command deletes all objects and subdirectories within the
directory ``my-dir'':
$ {command} gs://my-bucket/my-dir/**
Note that for buckets that contain
[versioned objects](https://cloud.google.com/storage/docs/object-versioning),
the above command only affects live versions. Use the `--recursive` flag
instead to delete all versions.
The following command deletes all versions of all resources in
``my-bucket'' and then deletes the bucket.
$ {command} --recursive gs://my-bucket/
The following command deletes all text files in the top-level of
``my-bucket'', but not text files in subdirectories:
$ {command} -recursive gs://my-bucket/*.txt
The following command deletes one wildcard expression per line passed
in by stdin:
$ some_program | {command} -I
)� DESCRIPTION�EXAMPLESc �T � |j ddd�� |j ddddd �
� |j d d dd
�
� |j dddd�� t j |� t j |� t j |� t j
|� y )N�urls�*z$The URLs of the resources to delete.)�nargs�helpz --recursivez-Rz-r�
store_truead Recursively delete the contents of buckets or directories that match the path expression. By default, this will delete managed folders as well. If the path is set to a bucket, like ``gs://bucket'', the bucket is also deleted. This option implies the `--all-versions` option. If you want to delete only live object versions, use the ``**'' wildcard instead.)�actionr z--all-versionsz-az\Delete all [versions](https://cloud.google.com/storage/docs/object-versioning) of an object.z--exclude-managed-foldersFa Excludes managed folders from command operations. By default gcloud storage includes managed folders in recursive removals. Please note that this flag would not be applicable for hierarchical namespace buckets as we always list managed folders for these buckets.)r �defaultr )� add_argumentr �add_additional_headers_flag�add_continue_on_error_flag�add_precondition_flags� add_read_paths_from_stdin_flag)�cls�parsers �lib/surface/storage/rm.py�ArgszRm.ArgsY s� � �
�����
3� � 5� ���� � ��
F�
� � ���� ��� � � ���#���
"� � �
�%�%�f�-� �$�$�V�,� � � ��(� �(�(��0� c �� � |j rOt j j }t j
j }t j j }nIt j j }t j |� }t j j }|j xr
|j }t j � }t j t! j" |j$ |j& � t j( j* |t, j. j0 t, j2 j4 ||j ||�� }t7 j8 |� }t: j< j? � } tA jB || |�� }
tD jF jI d� tK jL |
jO � d| tQ jR tP jT jV d �� |jX �� } |j rWt j |j$ t, j2 jZ | ||�� } t] j^ | | d�� }
nd }
|rpt j |j$ t, j. jj dd t j j |�
� } t] jl ||| d�� }nd }to jp |
js � � }|j r�|ju � sqtD jF jI d� tK jL |d| tQ jR tP jT jV d �� |jX �� }nd }tw | ||
|� | _< y # t` jb $ r<}|jd jf d k7 r� tE jh d
� d }
Y d }~���d }~ww xY w# t` jb $ r<}|jd jf d k7 r� tE jh d� d }Y d }~��bd }~ww xY w)N)� fields_scope�include_buckets�managed_folder_setting�folder_setting� object_state� raise_error_for_unmatched_urls�recursion_requested�url_found_match_tracker)�task_status_queue�user_request_argszRemoving objects:T)�increment_type�
manifest_path)�parallelizabler4 �progress_manager_args�continue_on_error)r/ r1 r2 r3 )�verbosei� z4Unable to delete folders due to missing permissions.r F)r. r1 �(raise_managed_folder_precondition_errorsr2 r3 z<Unable to delete managed folders due to missing permissions.zRemoving buckets:)=� recursiver �
BucketSetting�YESr � ObjectState�LIVE_AND_NONCURRENT�RecursionSetting�NOr �get_object_state_from_flags�NO_WITH_WARNING�exclude_managed_folders� collections� OrderedDict�NameExpansionIteratorr �get_urls_iterabler �read_paths_from_stdin� FieldsScope�SHORTr
�ManagedFolderSetting� DO_NOT_LIST�
FolderSetting�LIST_AS_PREFIXESr �'get_user_request_args_from_command_argsr �multiprocessing_context�Queuer �DeleteTaskIteratorFactoryr �status�Printr �
execute_tasks�object_iteratorr �ProgressManagerArgs�
IncrementType�INTEGERr: �LIST_AS_FOLDERSr
�remove_folders�
api_errors� GcsApiError�payload� status_code�warning�LIST_WITHOUT_OBJECTS�remove_managed_foldersr �PluralityCheckableIterator�bucket_iterator�is_empty�max� exit_code)�self�args�bucket_settingr0 �recursion_setting�(should_perform_managed_folder_operationsr3 �name_expansion_iteratorr5 r4 �task_iterator_factory�object_exit_code�folder_expansion_iterator�folder_exit_code�error�!managed_folder_expansion_iterator�managed_folder_exit_coderg �bucket_exit_codes r( �RunzRm.Run� s� � � �~�~�%�3�3�7�7�n� �*�*�>�>�l�(�9�9�=�=��%�3�3�6�6�n��6�6�t�<�l�(�9�9�I�I��
���;�t� ;� ;�;� -� *� 5� 5� 7�� -� B� B��(�(����D�4N�4N�O� �*�*�0�0�&� *� ?� ?� K� K�"�0�0�A�A�!�+/�>�>�'9� -� 7�
�� "�I�I�$�O� �+�C�C�I�I�K��$�>�>� #� /� /� 1� � �J�J���(�)�$�2�2� �-�-�/��+� )� =� =�&�4�4�<�<�D�
� �0�0��� �~�~�"0�"F�"F�
�)�)�$�2�2�B�B�-U�)U� /�"9� #� � �*�9�9� %� ��
�� ��/�*8�*N�*N�
�)�)�!,�!A�!A�!V�!V�)-� 49� ,� =� =� A� A�"9�
+�'�%�#2�#I�#I� � -� �� $
� � "#� �2�M�M� �-�-�/��O�
�~�~�o� 6� 6� 8� �j�j���*�+�&�4�4�
� � -� +� ?� ?� (� 6� 6� >� >� �! � !� 2� 2� �� ���� ��� �D�N��w �
#�
#� � �=�=� $� $�� +�
� � � �J�K� ��� ��8 �
#�
#� %� �=�=� $� $�� +�
� � � � J�
� $%� ��%�s0 � O �3P' �P$�(1P � P$�'Q6�:1Q1�1Q6N)�__name__�
__module__� __qualname__�__doc__�
detailed_help� classmethodr) ry � r* r( r r ( s2 � �#�
�$
�
+�-�Z �,1� �,1�\Hr* r ) r} �
__future__r r r rG � googlecloudsdk.api_lib.storager r r_ �googlecloudsdk.callioper �"googlecloudsdk.command_lib.storager r
r r r
r r �(googlecloudsdk.command_lib.storage.tasksr r r �+googlecloudsdk.command_lib.storage.tasks.rmr �googlecloudsdk.corer �UniverseCompatible�Commandr r� r* r( �<module>r� sk �� ;� &� � '� � 4� ?� (� 4� :� =� K� >� =� H� B� H� @� T� #� ���g�� � � g� �gr*