ProxyQuery

class polars_cloud.ProxyQuery(query_id: UUID, workspace_id: UUID)

A Polars Cloud proxy mode query.

Note

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

Examples

>>> ctx = pc.ComputeContext(connection_mode="proxy")
>>> query = lf.remote(ctx).sink_parquet(...)
>>> type(query)
<class 'polars_cloud.query.query.ProxyQuery'>

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.