
    0FieD                    6   d dl mZ d dlZd dlmZmZ  ej        ej                  d             Z ej        ej                  d             Z	 ej        ej
        ej        f          d             Z ej        ej
        ej        f          d             ZdS )    )annotationsN)dask_deserializedask_serializec                L    | j         dk    rt          d          d| j        ig fS )Nrz'Can only serialize read-only h5py filesfilename)mode
ValueErrorr   )fs    9lib/python3.11/site-packages/distributed/protocol/h5py.pyserialize_h5py_filer      s.    v}}BCCC
#R''    c                :    dd l } |j        | d         d          S )Nr   r   r   )r	   )h5pyFile)headerframesr   s      r   deserialize_h5py_filer      s'    KKK49VJ'c2222r   c                L    t          | j                  \  }}| j        |d<   |g fS Nname)r   filer   )xr   _s      r   serialize_h5py_datasetr      s*    #AF++IFAVF6N2:r   c                >    t          | |          }|| d                  S r   )r   )r   r   r   s      r   deserialize_h5py_datasetr      s      00Dvr   )
__future__r   r   distributed.protocol.serializer   r   registerr   r   r   GroupDatasetr   r    r   r   <module>r$      s    " " " " " "  K K K K K K K K ##( ( $#( 49%%3 3 &%3 $*dl344  54 DJ566    76     r   