Ë
    	êñim  ã                  óX   — d dl mZ d dlmZ d dlmZ erd dlmZ d dlm	Z	  G d„ d«      Z
y)	é    )Úannotations)ÚTYPE_CHECKING)Úwrap_df)Ú	DataFrame)ÚPyInProcessQueryc                  ó0   — e Zd ZdZdd„Zdd„Zd	d„Zd
d„Zy)ÚInProcessQueryzß
    A placeholder for an in process query.

    This can be used to do something else while a query is running.
    The queries can be cancelled. You can peek if the query is finished,
    or you can await the result.
    c                ó   — || _         y )N)Ú_inner)ÚselfÚipqs     ú]/var/www/pod-logistic/pod-ai/venv/lib/python3.12/site-packages/polars/lazyframe/in_process.pyÚ__init__zInProcessQuery.__init__   s	   € Øˆ�ó    c                ó8   — | j                   j                  «        y)z)Cancel the query at earliest convenience.N)r   Úcancel©r   s    r   r   zInProcessQuery.cancel   s   € à�‰×ÑÕr   c                óR   — | j                   j                  «       x}�t        |«      S y)z”
        Fetch the result.

        If it is ready, a materialized DataFrame is returned.
        If it is not ready it will return `None`.
        N)r   Úfetchr   )r   Úouts     r   r   zInProcessQuery.fetch   s)   € ð —;‘;×$Ñ$Ó&Ð&ˆCÐ3Ü˜3“<Ðàr   c                óH   — t        | j                  j                  «       «      S )zAwait the result synchronously.)r   r   Úfetch_blockingr   s    r   r   zInProcessQuery.fetch_blocking(   s   € ä�t—{‘{×1Ñ1Ó3Ó4Ð4r   N)r   r   ÚreturnÚNone)r   r   )r   zDataFrame | None)r   r   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   r   © r   r   r	   r	      s   „ ñóóó
ô5r   r	   N)Ú
__future__r   Útypingr   Úpolars._utils.wrapr   Úpolarsr   Úpolars._plrr   r	   r   r   r   ú<module>r%      s!   ðÝ "å  å &áÝ Ý,÷5ò 5r   