
    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dS )    )annotationsN)dask_deserializedask_serializedeserialize	serializec                    t          | j                  \  }}t          | j                  \  }}||| j        t	          |          t	          |          gd}|||z   fS )N)coords-headerdata-headershapenframes)r   coordsdatar   len)xcoords_headercoords_framesdata_headerdata_framesheaders         ;lib/python3.11/site-packages/distributed/protocol/sparse.pyserialize_sparser      sm    #,QX#6#6 M=(00K '"&&K(8(89	 F =;...    c                    |d | d         d                  }|| d         d         d          }t          | d         |          }t          | d         |          }| d         }t          j        |||          S )Nr   r   r	   r
   r   )r   )r   sparseCOO)r   framesr   r   r   r   r   s          r   deserialize_sparser      s~    1VI.q112M	*1-//0K0-@@Fvm,k::D7OE:fd%0000r   )
__future__r   r   distributed.protocol.serializer   r   r   r   registerr   r   r    r   r   <module>r"      s    " " " " " "             $$
/ 
/ %$
/ 6:&&	1 	1 '&	1 	1 	1r   