
    >ie                    6    d dl mZ d Zd Zd Zd Zd Zd ZdS )	    )annotationsc                     d S N )argss    .lib/python3.11/site-packages/dask/bag/chunk.pybarrierr	      s    4    c                    | |         S )znLike :func:`operator.getitem`, but allows setting key using partial
    ``partial(chunk.getitem, key=key)
    r   )xkeys     r   getitemr      s     S6Mr
   c                &     | ||d                   S )N   r   )combineaccr   s      r   foldby_combine2r      s    73!r
   c                .     | ||                     | fS r   r   )r   hashgroupers      r   groupby_tasks_group_hashr      s    4

Qr
   c                F    d\  }}}| D ]}||dz  z  }||z  }|dz  }|||fS )N)        r   r      r   r   )seqsquarestotalnr   s        r   	var_chunkr      sK    #GUA  1a4
	QE1r
   c                    t          t          |            \  }}}t          t          |                    t          t          |                    t          |          }} }||z  | |z  dz  z
  }||z  ||z
  z  S )Nr   )listzipfloatsum)r   ddofr   totalscountsx2r   results           r   var_aggregater*       sp    "37mmGVVS\\""E#f++$6$6F1B1fQ1$FA:T""r
   N)
__future__r   r	   r   r   r   r   r*   r   r
   r   <module>r,      s{    " " " " " "          # # # # #r
   