Skip to main content

Clusters

Provision and manage Onehouse compute clusters.

Methods

MethodDescription
create_clusterCreate a new cluster
alter_clusterChange cluster size, state, name, or options
delete_clusterDelete a cluster
describe_clusterShow full configuration for a cluster
show_clustersList all clusters in the project

create_cluster

create_cluster(
name: str,
*,
type: str,
max_ocu: int | None = None,
min_ocu: int | None = None,
options: Mapping[str, str] | None = None,
unsafe_raw: bool = False,
timeout: float | None = None,
poll_interval: float | None = None,
)
ParameterRequiredType / values
nameyesstr
typeyes"Managed", "SQL", "Spark", "Open_Engines", "Notebook", "LakeBase"
max_ocunoint
min_ocunoint
optionsnoMapping[str, str] — passed as WITH (...)

Example

client.create_cluster(
"prod",
type="Managed",
max_ocu=10,
min_ocu=1,
options={"worker.type": "oh-general-4"},
)

alter_cluster

alter_cluster(
name: str,
*,
state: str | None = None,
max_ocu: int | None = None,
min_ocu: int | None = None,
new_name: str | None = None,
options: Mapping[str, str] | None = None,
unsafe_raw: bool = False,
timeout: float | None = None,
poll_interval: float | None = None,
)

At least one of state, max_ocu, min_ocu, new_name, or options must be supplied.

ParameterRequiredType / values
nameyesstr
stateno"START", "STOP"
max_ocunoint
min_ocunoint
new_namenostr
optionsnoMapping[str, str]

Examples

# Stop a cluster
client.alter_cluster("prod", state="STOP")

# Resize
client.alter_cluster("prod", min_ocu=2, max_ocu=20)

# Rename
client.alter_cluster("prod", new_name="prod-east")

delete_cluster

delete_cluster(name: str, *, unsafe_raw=False, timeout=None, poll_interval=None)

Example

client.delete_cluster("prod")

describe_cluster

describe_cluster(name: str, *, unsafe_raw=False, timeout=None, poll_interval=None)

Example

result = client.describe_cluster("prod")
print(result.api_response)

show_clusters

show_clusters(*, timeout=None, poll_interval=None)

Example

result = client.show_clusters()