← back to Atmos Game

assets/gen/.venv/lib/python3.12/site-packages/fsspec/__pycache__/utils.cpython-312.pyc

296 lines

�

c�bjG\���UddlmZddlZddlZddlZddlZddlZddlZddlZddl	m
Z
mZmZm
Z
ddlmZddlmZddlmZddlmZmZmZmZddlmZerddlZdd	lmZdd
lmZdZed�Z 	d)					d*d
�Z!	d)					d+d�Z"iZ#de$d<d,d�Z%d-d�Z&d.d�Z'		d/											d0d�Z(d1d�Z)d2d�Z*								d3d�Z+d4d�Z,		d5									d6d�Z-d7d�Z.d8d�Z/d9d�Z0d9d�Z1d:d�Z2d;d�Z3				d<									d=d �Z4d>d!�Z5						d?d"�Z6ejnd@d#��Z8			dA													dBd$�Z9dCd%�Z:ejndDdEd&��Z;d'�Z<d(�Z=y)F�)�annotationsN)�Callable�Iterable�Iterator�Sequence)�partial)�md5)�version)�IO�
TYPE_CHECKING�Any�TypeVar)�urlsplit)�	TypeGuard)�AbstractFileSystemiP�Tc��tjd|�stjd|��d|d�St|�}|jxsd}|jr(dj|j|jg�}n|j}|dk(r2tjd|�}|r|j�\}}|�d|��}|dvr||d�S||d�}|jr�|jjd	d
�djdd
�d|d
<|dvr|d
|dz|d<n|d
|d
<|jr|j|d<|jr|j|d<|jr|j|d<|jr|j|d<|jr|j|d<|rt||�|S)a�Infer storage options from URL path and merge it with existing storage
    options.

    Parameters
    ----------
    urlpath: str or unicode
        Either local absolute file path or URL (hdfs://namenode:8020/file.csv)
    inherit_storage_options: dict (optional)
        Its contents will get merged with the inferred information from the
        given path

    Returns
    -------
    Storage options dict.

    Examples
    --------
    >>> infer_storage_options('/mnt/datasets/test.csv')  # doctest: +SKIP
    {"protocol": "file", "path", "/mnt/datasets/test.csv"}
    >>> infer_storage_options(
    ...     'hdfs://username:pwd@node:123/mnt/datasets/test.csv?q=1',
    ...     inherit_storage_options={'extra': 'value'},
    ... )  # doctest: +SKIP
    {"protocol": "hdfs", "username": "username", "password": "pwd",
    "host": "node", "port": 123, "path": "/mnt/datasets/test.csv",
    "url_query": "q=1", "extra": "value"}
    z^[a-zA-Z]:[\\/]z^[a-zA-Z0-9]+://�file)�protocol�path�#z^/([a-zA-Z])[:|]([\\/].*)$�:)�http�https�@������r�host)�s3�s3a�gcs�gsr�port�username�password�	url_query�url_fragment)�re�matchr�scheme�fragment�joinr�groups�netloc�rsplitr#r$r%�query�update_storage_options)�urlpath�inherit_storage_options�parsed_pathrr�windows_path�drive�optionss        �c/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/fsspec/utils.py�infer_storage_optionsr9s���@	���#�W�-�
�8�8�'��1�9�"�G�4�4��7�#�K��!�!�+�V�H�����x�x��)�)�;�+?�+?�@�A�������6���x�x� =�t�D���&�-�-�/�K�E�4��W�A�d�V�$�D��$�$�$�g�6�6�+3�T�B�G����&�,�,�3�3�C��;�B�?�F�F�s�A�N�q�Q�����1�1�%�f�o����?�G�F�O�%�f�o�G�F�O����)�.�.�G�F�O����"-�"6�"6�G�J�����"-�"6�"6�G�J�����*�0�0�������"-�"6�"6������w�(?�@��N�c���|si}t|�t|�z}|r8|D]3}|j|�|j|�k7s�'td|����|j|�y)Nz9Collision between inferred and specified storage option:
)�set�get�KeyError�update)r7�	inherited�
collisions�	collisions    r8r1r1rso����	��W���I��.�J��#�I��{�{�9�%����y�)A�A�� � )�{�,���$��N�N�9�r:zdict[str, str]�compressionsc��tjj|�djd�j	�}|t
vr	t
|Sy)aInfer compression, if available, from filename.

    Infer a named compression type, if registered and available, from filename
    extension. This includes builtin (gz, bz2, zip) compressions, as well as
    optional compressions. See fsspec.compression.register_compression.
    r�.N)�osr�splitext�strip�lowerrC)�filename�	extensions  r8�infer_compressionrL�sG����� � ��*�2�.�4�4�S�9�?�?�A�I��L� ��I�&�&�r:c���|dz
}ttjtj|����d�fd�}|S)a�Returns a function that receives a single integer
    and returns it as a string padded by enough zero characters
    to align with maximum possible integer

    >>> name_f = build_name_function(57)

    >>> name_f(7)
    '07'
    >>> name_f(31)
    '31'
    >>> build_name_function(1000)(42)
    '0042'
    >>> build_name_function(999)(42)
    '042'
    >>> build_name_function(0)(0)
    '0'
    g:�0�yE>c�8��t|�j��S�N)�str�zfill)�i�
pad_lengths �r8�
name_functionz*build_name_function.<locals>.name_function�s����1�v�|�|�J�'�'r:)rR�int�returnrP)rU�math�ceil�log10)�max_intrTrSs  @r8�build_name_functionr[�s7���&�t�O�G��T�Y�Y�t�z�z�'�2�3�4�J�(��r:c�v�|j�dk(ryd}	|j|�}|sy|r||zn|}	||vrL|j|�}|j|j�t	|�|z
z
t	|�z�yt	|�|kry	|t	|�d}��#t
tf$rY�!wxYw)a�Seek current file to file start, file end, or byte after delimiter seq.

    Seeks file to next chunk delimiter, where chunks are defined on file start,
    a delimiting sequence, and file end. Use file.tell() to see location afterwards.
    Note that file start is a valid split, so must be at offset > 0 to seek for
    delimiter.

    Parameters
    ----------
    file: a file
    delimiter: bytes
        a delimiter like ``b'\n'`` or message sentinel, matching file .read() type
    blocksize: int
        Number of bytes to read from the file at once.


    Returns
    -------
    Returns True if a delimiter was found, False if at file start or end.

    rFNT)�tell�read�index�seek�len�OSError�
ValueError)r�	delimiter�	blocksize�last�current�fullrRs       r8�seek_delimiterri�s���.�y�y�{�a����D�
��)�)�I�&����!%�t�g�~�7��		��D� ��J�J�y�)���	�	�$�)�)�+��T��Q��7�#�i�.�H�I���W��	�)��*�
�S��^�O�%�&��!����$�	��	�s�AB&�B&�&B8�7B8c��|r�|j|�t||d�}|�|j�S|j�}|||z
z}|j||z�t||d�}|j�}|r|r|t	|�z}|r|r|t	|�z}|}||z
}|j|�|�J�|j|�}	|	S)a�Read a block of bytes from a file

    Parameters
    ----------
    f: File
        Open file
    offset: int
        Byte offset to start read
    length: int
        Number of bytes to read, read through end of file if None
    delimiter: bytes (optional)
        Ensure reading starts and stops at delimiter bytestring
    split_before: bool (optional)
        Start/stop read *before* delimiter bytestring.


    If using the ``delimiter=`` keyword argument we ensure that the read
    starts and stops at delimiter boundaries that follow the locations
    ``offset`` and ``offset + length``.  If ``offset`` is zero then we
    start at zero, regardless of delimiter.  The bytestring returned WILL
    include the terminating delimiter string.

    Examples
    --------

    >>> from io import BytesIO  # doctest: +SKIP
    >>> f = BytesIO(b'Alice, 100\nBob, 200\nCharlie, 300')  # doctest: +SKIP
    >>> read_block(f, 0, 13)  # doctest: +SKIP
    b'Alice, 100\nBo'

    >>> read_block(f, 0, 13, delimiter=b'\n')  # doctest: +SKIP
    b'Alice, 100\nBob, 200\n'

    >>> read_block(f, 10, 10, delimiter=b'\n')  # doctest: +SKIP
    b'Bob, 200\nCharlie, 300'
    i)r`rir^r]ra)
�f�offset�lengthrd�split_before�found_start_delim�start�found_end_delim�end�bs
          r8�
read_blockrt�s���V�	���v��*�1�i��?���>��6�6�8�O�������%�&�.� ��	���u�v�~��(��I�u�=���f�f�h�����S��^�#�E��|��3�y�>�!�C����u����F�F�6�N�����	���v��A��Hr:c���|r||fz
}	tt|�j��}|j	�S#t$r6tt|�j�d��}Y|j	�SwxYw)z�Deterministic token

    (modified from dask.base)

    >>> tokenize([1, 2, '3'])
    '9d71491b50023b06fc76928e6eddb952'

    >>> tokenize('Hello') == tokenize('Hello')
    True
    F)�usedforsecurity)r	rP�encoderc�	hexdigest)�args�kwargs�hs   r8�tokenizer|+ss�����	���;���D�	� � �"�#��
�;�;�=����;���D�	� � �"�E�:���;�;�=��;�s�"<�-A;�:A;c��t|t�r|St|d�r|j�St|d�r|jS|S)a6Attempt to convert a path-like object to a string.

    Parameters
    ----------
    filepath: object to be converted

    Returns
    -------
    filepath_str: maybe a string version of the object

    Notes
    -----
    Objects supporting the fspath protocol are coerced according to its
    __fspath__ method.

    For backwards compatibility with older Python version, pathlib.Path
    objects are specially coerced.

    Any other object is passed through unchanged, which includes bytes,
    strings, buffers, or anything else that's not even path-like.
    �
__fspath__r)�
isinstancerP�hasattrr~r)�filepaths r8�stringify_pathr�@sE��,�(�C� ���	��<�	(��"�"�$�$�	��6�	"��}�}���r:c�6�||i|��}|j�|SrO)�_determine_worker)�clsryrz�insts    r8�
make_instancer�`s$�������D������Kr:c����|D�cgc]}|jd���c}�td��D��}d}t|�D]�t��fd��D��}|r�n�|z
�dj	�dd��Scc}w)z;For a list of paths, find the shortest prefix common to all�/c3�2K�|]}t|����y�wrO)ra)�.0�ps  r8�	<genexpr>z common_prefix.<locals>.<genexpr>ks����%�u�!�s�1�v�u���rc3�:�K�|]}|��d�k(���y�w)rN�)r�r�rR�partss  ��r8r�z common_prefix.<locals>.<genexpr>ns#�����5�u�!�!�A�$�%��(�1�+�%�u�s�N)�split�min�range�allr,)�pathsr��lmaxrrrRr�s    @@r8�
common_prefixr�hs����#(�)�5�a�Q�W�W�S�\�5�)�E��%�u�%�%�D�
�C�
�4�[���5�u�5�5�������H�A��8�8�E�!�H�R�a�L�!�!��
*s�A;c	���t|t�r�|jd�}|r4|D�cgc]'}dj||j	d�df���)}}|St|�}|r|j
dd�d}|s4td�|D��r"|D�cgc]}dj||g���}}|S|D�cgc]}|j||d���}}|St|�t|�k(sJ�|Scc}wcc}wcc}w)a�In bulk file operations, construct a new file tree from a list of files

    Parameters
    ----------
    paths: list of str
        The input file tree
    path2: str or list of str
        Root to construct the new list in. If this is already a list of str, we just
        assert it has the right number of elements.
    exists: bool (optional)
        For a str destination, it is already exists (and is a dir), files should
        end up inside.
    flatten: bool (optional)
        Whether to flatten the input directory tree structure so that the output files
        are in the same directory.

    Returns
    -------
    list of str
    r�rrrc3�@K�|]}|jd����y�w)r�N)�
startswith�r��ss  r8r�zother_paths.<locals>.<genexpr>�s����C�U��!�,�,�s�"3�3�U�s�)
rrP�rstripr,r�r�r/r��replacera)r��path2�exists�flattenr��cps      r8�other_pathsr�us��6�%������S�!���BG�H�%�Q�S�X�X�u�a�g�g�c�l�2�&6�7�8�%�E�H��L��u�%�B���Y�Y�s�A�&�q�)���#�C�U�C�C�7<�=�u�!����5�!�*�-�u��=�
�L�;@�@�%�Q����2�u�a�0�%��@��L��5�z�S��Z�'�'�'��L��I��>��@s�,C-�C2�4C7c�"�t|t�SrO)r�
BaseException��objs r8�is_exceptionr��s���c�=�)�)r:c�,��t�fd�dD��S)Nc3�6�K�|]}t�|����y�wrO)r�)r��attrrks  �r8r�zisfilelike.<locals>.<genexpr>�s�����F�,E�D�w�q�$��,E�s�)r^�closer])r�)rks`r8�
isfileliker��s����F�,E�F�F�Fr:c�p�t|�}tjd|d��}t|�dkDr|dSy)Nz(\:\:|\://)r)�maxsplitrr)r�r(r�ra)�urlr�s  r8�get_protocolr��s5��
��
�C��H�H�^�S�1�5�E�
�5�z�A�~��Q�x��r:c�d�t|�}|jdd�}t|�dkDr|dSy)NrErr�)r�r/ra)r��	ext_partss  r8�get_file_extensionr��s5��
��
�C��
�
�3��"�I�
�9�~�����}��
r:c�r�ddlm}	t|t|��dd�S#tt
f$rYywxYw)z*Can the given URL be used with open_local?r)�get_filesystem_class�
local_fileF)�fsspecr��getattrr�rc�ImportError)rr�s  r8�can_be_localr��s;��+���+�L��,>�?��u�U�U����$����s�$�6�6c��|tjvr+tj|}t|d�r|jS	t	|�S#YnxYw	ddl}|j
|�}|jS#ttf$rYywxYw)aFor given package name, try to find the version without importing it

    Import and package.__version__ is still the backup here, so an import
    *might* happen.

    Returns either the version string, or None if the package
    or the version was not readily  found.
    �__version__rN)	�sys�modulesr�r�r
�	importlib�
import_moduler��AttributeError)�name�modr�s   r8�"get_package_version_without_importr��s����s�{�{���k�k�$����3�
�&��?�?�"�
��t�}���
������%�%�d�+���������(����s�
A
�
A� A3�3B�Bc�F�|�
|�td��|xstj|�}tj�}tjd�}|j|�|r|jj�|j|�|j|�|S)Nz+Provide either logger object or logger namezD%(asctime)s - %(name)s - %(levelname)s - %(funcName)s -- %(message)s)
rc�logging�	getLogger�
StreamHandler�	Formatter�setFormatter�handlers�clear�
addHandler�setLevel)�logger�logger_name�levelr��handle�	formatters      r8�
setup_loggingr��s����~�+�-��F�G�G�
�
5�w�(�(��5�F�
�
"�
"�
$�F��!�!�N��I����	�"��������
���f��
�O�O�E���Mr:c�$�|j|�SrO)�unstrip_protocol)r��fss  r8�_unstrip_protocolr��s��
���t�$�$r:c�&����d�fd��d��fd�}|S)zqMirror attributes and methods from the given
    origin_name attribute of the instance to the
    decorated classc�4��t|��}t||�SrO)r�)�method�self�origin�origin_names   �r8�
origin_getterz"mirror_from.<locals>.origin_getter�s�����{�+���v�v�&�&r:c�Z���D]$}t�|�}t||t|���&|SrO)r�setattr�property)r�r��wrapped_method�methodsr�s   ��r8�wrapperzmirror_from.<locals>.wrappers1����F�$�]�F�;�N��C���.�!9�:���
r:)r�rPr�r
rVr
)r��type[T]rVr�r�)r�r�r�r�s`` @r8�mirror_fromr��s���'���Nr:c#�K�|��y�wrOr�r�s r8�nullcontextr�s����

�I�s�c�������t|t�st�t|t�s|gt|�z}t|t�s|gt|�z}t|�t|�k7st|�t|�k7rt�t|�dkr|||fS|D�cgc]}|xsd��
}}|r'd�tt
t|||���D�\}}}g}tt|||��D]F\�\���t����fd�tt|||��D��s�6|j���Ht|�D��	cgc]\}}	||vs�|	��}}}	t|�D��cgc]\}}||vs�|��}}}t|�D��
cgc]\}}
||vs�|
��}}}
|r�|dd}|dd}|dd}
tdt|��D]��|�|�dz
k(r|
d��|�|�dz
k7s|�|
dz
|kDs|�K|�|dz
|kDr=|j|��|j|��|
j|����|�|
d<��|||
fS|||fScc}wcc}	}wcc}}wcc}
}w)a}Merge adjacent byte-offset ranges when the inter-range
    gap is <= `max_gap`, and when the merged byte range does not
    exceed `max_block` (if specified). By default, this function
    will re-order the input paths and byte ranges to ensure sorted
    order. If the user can guarantee that the inputs are already
    sorted, passing `sort=False` will skip the re-ordering.
    rrc3�2K�|]}t|����y�wrO)�list)r��vs  r8r�z&merge_offset_ranges.<locals>.<genexpr>1s ����
���
��G��r�c3�l�K�|]+\}\}}}|duxr|�k(xr�|k\xr�|kxr�|k7���-y�wrOr�)	r��i2r�r��errrRrrps	     ����r8r�z&merge_offset_ranges.<locals>.<genexpr>;sN�����
�!D�
��I�Q��1�
�T�M�O�a�4�i�O�E�Q�J�O�3�!�8�O��R��O�!D�s�14Nr)rr��	TypeErrorrarc�zip�sorted�	enumerate�any�appendr�)r��starts�ends�max_gap�	max_block�sortr��removerRr�r��	new_paths�
new_starts�new_endsrrrrps        `     @@@r8�merge_offset_rangesrs���� �e�T�"����f�d�#���C��J�&���d�D�!��v��E�
�"��
�6�{�c�%�j� �C��I��U��$;����6�{�a���f�d�"�"�$�
%�f��a�f�1�f�f�F�
%��
�����v�t�,���
���v�t��F�!*�3�u�f�d�+C�!D����D�%���
�!*�3�u�f�d�+C�!D�
�
�
�M�M�!��"E�%�U�+�?�+�4�1�a�q���Q�+�E�?�%�f�-�
A�-�D�A�q��&��a�-�F�
A�#�D�/�=�/�$�!�Q�Q�f�_�A�/�D�=���"�1�I�	��B�Q�Z�
����8���q�#�e�*�%�A��Q�x�5��Q��<�'�H�R�L�,@���a��E�!�a�%�L�(��A�Y��"��-��8��)�t�A�w��B��/G�9�.T�� � ��q��*��!�!�&��)�,�����Q��(� $�A�w����!&�"�*�h�.�.��&�$����a&��$
@��
A��=s*�$
I�I"�I"�-I(�:I(�I.�I.c��|j�}	|jdd�|j|�S#|j|�wxYw)z+Find length of any open read-mode file-liker�)r]r`)�filelike�poss  r8�	file_sizeras9��
�-�-�/�C���}�}�Q��"��
�
�c����
�
�c��s	�5�Ac#��K�tjtjj	|�tjj|�dz��\}}	t
||�5}|��ddd�tj||�y#1swY� xYw#t$rEtjt�5tj|�ddd��#1swY�xYwwxYw�w)z�
    A context manager that opens a temporary file next to `path` and, on exit,
    replaces `path` with the temporary file, thereby updating `path`
    atomically.
    �-)�dir�prefixN)
�tempfile�mkstemprFr�dirname�basename�openr�r��
contextlib�suppress�FileNotFoundError�unlink)r�mode�fd�fn�fps     r8�atomic_writerjs������
�
��G�G�O�O�D�!�"�'�'�*:�*:�4�*@�3�*F��F�B���
�"�d�^�r��H��	�
�
�2�t���^����
�
 �
 �!2�
3��I�I�b�M�4�
�4�
���sN�AC(�B�'B�,B�4C(�B�B�"C%�9C�	C%�C!	�C%�%C(c�`�g}|j}dt|�}}||k�r||}|dz}|dk(r|r|d|u�r�||��n�|dk(r
||��n�|dk(�r�|}||kr
||dk(r|dz}||kr
||dk(r|dz}||kr||dk7r|dz}||kr	||dk7r�||k\r
|d	��nq|||}	d
|	vr|	jdd�}	n�g}
||dk(r|d
zn|dz}	|jd
||�}|dkrn|
j|||�|dz}|dz}�8|||}|r|
j|�n
|
dxxd
z
cc<t	t|
�dz
dd�D]4}|
|dz
d|
|dkDs�|
|dz
dd|
|ddz|
|dz
<|
|=�6d
jd�|
D��}	t
jdd|	�}	|dz}|	s	|d�nS|	dk(r	|d�nE|	ddk(r	d|	ddz}	n|	ddvrd|	z}	|d|	�d��n|t
j|��||kr��||k(sJ�|S)Nrr�*r�?�[�!�]z\[r
�\�\\r�c3�`K�|]&}|jdd�jdd����(y�w)r!r"r
z\-N)r�r�s  r8r�z_translate.<locals>.<genexpr>�s,����%�LR�q��	�	�$��.�6�6�s�E�B�F�s�,.z([&~|])z\\\1z(?!)rE�^)r%r)	r�rar��findr�r,r(�sub�escape)
�pat�STAR�
QUESTION_MARK�res�addrR�n�c�j�stuff�chunks�k�chunks
             r8�
_translater5s����C�

�*�*�C��c�#�h�q�A�
�a�%���F��
��E����8��C��G�4�/��D�	�
�#�X��
��
�#�X��A��1�u��Q��3����E���1�u��Q��3����E���a�%�C��F�c�M���E���a�%�C��F�c�M��A�v��E�
��A�a����e�#�!�M�M�$��6�E��F�!$�Q��3���A��A��E�A���H�H�S�!�Q�/���q�5�!��
�
�c�!�A�h�/���E����E��
� ��!�H�E���
�
�e�,��r�
�c�)�
�"�3�v�;��?�A�r�:��!�!�a�%�=��,�v�a�y��|�;�,2�1�q�5�M�#�2�,>����1�2��,N�F�1�q�5�M� &�q�	�;� �H�H�%�LR�%��E����z�7�E�:����E�����K��c�\���H��Q�x�3�� #�e�A�B�i����q��Z�/� $�u����!�E�7�!��%���	�	�!���A�a�%�B
��6�M�6��Jr:c�,�tjjr6tjjtjjz}ntjj}dj	ttj|��}t|�dkDrd|�d�n|}d|�d�}|�d�}|�|��}d|�d�}d	}g}	t
j||�}
t|
�dz
}t|
�D]�\}}
|
d
k(r|	j||kr|n|��$|
dk(r|	j||kr|n|��Bd|
vrtd��|
r|	jt|
|�d
�|��||ks�x|	j|���dj	|	�}d
|�d�S)zBTranslate a pathname with shell wildcards to a regular expression.r�rrr z[^�+z(?:.+z)?z.*rz**z:Invalid pattern: '**' can only be an entire path componentz(?s:z)\Z)rFr�altsep�sepr,�mapr(r(rar�r�r�rc�extendr5)r)�seps�escaped_seps�any_sep�not_sep�one_last_segment�one_segment�any_segments�any_last_segments�resultsr��
last_part_idx�idx�partr,s               r8�glob_translaterH�s���

�w�w�~�~��w�w�{�{�R�W�W�^�^�+���w�w�{�{���7�7�3�r�y�y�$�/�0�L�%(��Y��]��,��q�!��G��<�.��"�G�!��!�}��%�&�w�i�0�K��7�)�2�&�L����G��H�H�W�c�"�E���J��N�M��u�%�	��T��3�;��N�N�#�
�*=�;�CS�T���4�<��N�N�3��+>�<�DU�V��
�T�\��L��
���N�N�:�d�w�i�q�M�7�C�D�����N�N�7�#�&�
�'�'�'�
�C��3�%�s��r:rO)r2rPr3�dict[str, Any] | NonerV�dict[str, Any])r7rJr@rIrV�None)rJrPrV�
str | None)rZ�floatrVzCallable[[int], str])r�	IO[bytes]rd�bytesrerUrV�bool)NF)rkrNrlrUrm�
int | Nonerdzbytes | NonernrPrVrO)ryr
rzr
rVrP)r�z%str | os.PathLike[str] | pathlib.PathrVrP)r�zCallable[..., T]ryz
Sequence[Any]rzrJrVr)r��
Iterable[str]rVrP)FF)
r��	list[str]r�zstr | list[str]r�rPr�rPrVrS)r�r
rVrP)rkr
rVzTypeGuard[IO[bytes]])r�rPrVrP)rrPrVrP)r�rPrVrL)NN�DEBUGT)
r�zlogging.Logger | Noner�rLr�rPr�rPrVzlogging.Logger)r�rPr�rrVrP)r�rPr�rRrVzCallable[[type[T]], type[T]])r�rrVzIterator[T])rNT)r�rSr��list[int] | intr�rUr�rUr�rQr�rPrVz&tuple[list[str], list[int], list[int]])rrNrVrU)�wb)rrPrrP)>�
__future__rrr�rWrFr(r�r
�collections.abcrrrr�	functoolsr�hashlibr	�importlib.metadatar
�typingrrr
r�urllib.parser�pathlibr�fsspec.specr�DEFAULT_BLOCK_SIZErr9r1rC�__annotations__rLr[rirtr|r�r�r�r�r�r�r�r�r�r�r�r�r��contextmanagerr�rrrr5rHr�r:r8�<module>rcs���"����	�	�
��B�B���&�2�2�!��� �.����C�L��DH�R�
�R�+@�R��R�lAE�
�
�
�(=�
�	�
�" "��n�!�
��:.'�j#��G
��G
��G
�
�G
��	G
�
�G
��
G
�T�*�@�	��!.��8F����
"� ��	*��*��*�
�*��	*�
�*�Z*�G�����6%)�"���	�!�������	�
��*%����,��!��(������� ��
M��M��M��M��	M�
�M��
M�,�M�`�������(G�T#r: