o ¹­§imã@sRddlmZddlmZddlmZer ddlmZddlm Z Gdd„dƒZ dS) é)Ú annotations)Ú TYPE_CHECKING)Úwrap_df)Ú DataFrame)ÚPyInProcessQueryc@s8eZdZdZddd„Zddd „Zdd d „Zddd„ZdS)Ú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. ÚipqrÚreturnÚNonecCs ||_dS)N)Ú_inner)Úselfr©r úR/home/app/Keep/.python/lib/python3.10/site-packages/polars/lazyframe/in_process.pyÚ__init__s zInProcessQuery.__init__cCs|j ¡dS)z)Cancel the query at earliest convenience.N)r Úcancel©r r r rrózInProcessQuery.cancelúDataFrame | NonecCs|j ¡}dur t|ƒSdS)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 Úoutr r rrszInProcessQuery.fetchrcCst|j ¡ƒS)zAwait the result synchronously.)rr Úfetch_blockingrr r rr(rzInProcessQuery.fetch_blockingN)rrr r )r r )r r)r r)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrrrr r r rr s     rN) Ú __future__rÚtypingrZpolars._utils.wraprZpolarsrZ polars._plrrrr r r rÚs