
    0Fie                       d dl mZ d dlZd dlmZmZmZmZ  ej        ej	                  d             Z
 ej        ej	                  d             Z ej        ej                  d             Z ej        ej                  d             Z ej        ej                  d             Z ej        ej                  d	             ZdS )
    )annotationsN)dask_deserializedask_serializedeserialize	serializec                2    d|                                  ig fS )Nfilename)filepath)dss    <lib/python3.11/site-packages/distributed/protocol/netcdf4.pyserialize_netcdf4_datasetr      s     &**    c                :    t          j        | d         d          S )Nr	   r)mode)netCDF4Dataset)headerframess     r   deserialize_netcdf4_datasetr      s    ?6*-C8888r   c                    t          |                                           \  }}|d         |d<   |d         |d<   | j        |d<   |g fS )Ntypeparent-typetype-serializedparent-type-serializedname)r   groupr   )xr   _s      r   serialize_netcdf4_variabler       sO    !''))$$IFA"6NF='-.?'@F#$VF6N2:r   c                t    | d         | d<   | d         | d<   t          | |          }|j        | d                  S )Nr   r   r   r   r   )r   	variables)r   r   parents      r   deserialize_netcdf4_variabler$   !   sB    M*F6N &'? @F((FF6N++r   c                p    | }|j         r|j         }|j         t          |          \  }}| j        |d<   |g fS Npath)r#   r   r'   )gr#   r   r   s       r   serialize_netcdf4_groupr)   )   sJ    F
-  - )&11IFAVF6N2:r   c                >    t          | |          }|| d                  S r&   )r   )r   r   files      r   deserialize_netcdf4_groupr,   3   s     &vv66Dvr   )
__future__r   r   distributed.protocol.serializer   r   r   r   registerr   r   r   Variabler    r$   Groupr)   r,    r   r   <module>r3      sm   " " " " " "             ))+ + *)+
 7?++9 9 ,+9 )**  +* 7+,,, , -,, ''  (' 7=))    *)     r   