InteractiveQuery#

class polars_cloud.InteractiveQuery(query_id: UUID, address: str, client_options: ClientOptions)

A Polars Cloud interactive query.

Note

This object is returned when spawning a new query on a compute cluster running in interactive mode. It should not be instantiated directly by the user.

Examples

>>> ctx = pc.ComputeContext(interactive=True)
>>> query = lf.remote(ctx).sink_parquet(...)
>>> type(query)
<class 'polars_cloud.query.query.InteractiveQuery'>

Methods:

`get_status`	Get the current status of the query.
`await_result_async`	Await the result of the query asynchronously and return the result.
`await_result`	Block the current thread until the query is processed and get a result.
`cancel`	Cancel the execution of the query.

get_status() → QueryStatus: Get the current status of the query.

async await_result_async( *, raise_on_failure: bool = True, ) → QueryResult: Await the result of the query asynchronously and return the result.

await_result( *, raise_on_failure: bool = True, ) → QueryResult: Block the current thread until the query is processed and get a result.

cancel() → None: Cancel the execution of the query.