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.