
    bi                     :    d dl mZ d dlZ edefi       Zd Zd Zy)    )annotationsNCombinedOutputc                   |D cg c]  }t        |t              s| }}|d   \  }}}	|D 
cg c]  }
t        |
t              r|
d   n|
 }}
 | |i |}|d }t        |t        j                        r|}d }|j                  d   dk7  r|j                  d   |j                  d   z  }|r|r||z  }|	|j
                  |d  S t        |t        j                        r|	}|r|r||z  }|j
                  ||  S c c}w c c}
w )Nr   )
isinstancer   datetime	timedeltashapeiloc)funcbeforeafterargskwargsdfdfscombinedprev_part_lengthnext_part_lengthargout	expansions                Q/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/dask/dataframe/rolling.pyoverlap_chunkr      s   
?"
2~ >2
?C
?36q60H 0JNO3jn5CF3>ODO


C&(,,-!I~~aAIIaLHNN1$55	))xx  %++, 88FE6""/ @ Ps   C8C8C=c                \    ||j                   | j                   j                         |z   k     S )zReturn rows of ``next_`` whose index is before the last
    observation in ``current`` + ``after``.

    Parameters
    ----------
    current : DataFrame
    next_ : DataFrame
    after : timedelta

    Returns
    -------
    overlapped : DataFrame
    )indexmax)currentnext_r   s      r   _head_timedeltar   #   s*      1 1 3e ;<==    )
__future__r   r   typetupler   r   r    r    r   <module>r%      s&    " &"5#6>r    