
    hm                    b    S SK Jr  S SKJr  S SKJr  \(       a  S SKJr  S SKJ	r	   " S S5      r
g)	    )annotations)TYPE_CHECKING)wrap_df)	DataFrame)PyInProcessQueryc                  @    \ rS rSrSrS	S jrS
S jrSS jrSS jrSr	g)InProcessQuery   z
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                    Xl         g )N_inner)selfipqs     U/home/james-whalen/.local/lib/python3.13/site-packages/polars/lazyframe/in_process.py__init__InProcessQuery.__init__   s        c                8    U R                   R                  5         g)z)Cancel the query at earliest convenience.N)r   cancelr   s    r   r   InProcessQuery.cancel   s    r   c                T    U R                   R                  5       =nb  [        U5      $ g)zt
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   InProcessQuery.fetch   s)     ;;$$&&C33<r   c                H    [        U R                  R                  5       5      $ )zAwait the result synchronously.)r   r   fetch_blockingr   s    r   r   InProcessQuery.fetch_blocking(   s    t{{11344r   r   N)r   r   returnNone)r   r    )r   zDataFrame | None)r   r   )
__name__
__module____qualname____firstlineno____doc__r   r   r   r   __static_attributes__ 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   