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,
Await the result of the query asynchronously and return the result.
- await_result(
- *,
- raise_on_failure: bool = True,
Block the current thread until the query is processed and get a result.
- cancel() None
Cancel the execution of the query.