minitrino.core.cluster.validator module

Cluster validation utilities for Minitrino CLI.

class minitrino.core.cluster.validator.ClusterValidator(ctx: MinitrinoContext, cluster: Cluster)

Bases: object

Validate cluster configuration and environment variables.

Parameters:

• ctx (MinitrinoContext) – An instantiated MinitrinoContext object with user input and context.

• cluster (Cluster) – An instantiated Cluster object.

check_cluster_name()

Validate that the cluster name is valid.

check_cluster_ver()

Validate that the current CLUSTER_VER and CLUSTER_DIST environment variables meet minimum requirements for either Trino or Starburst distributions.

check_dependent_clusters(modules: list[str] | None = None)

Identify dependent clusters for the specified modules.

check_dup_config()

Check for duplicate entries in config.properties and jvm.config and log warnings if duplicates are found.

check_cluster_name() → None

Validate that the cluster name is valid.

Raises:

UserError – If the cluster name is invalid.

check_cluster_ver() → None

Validate that the cluster version meets minimum requirements.

Raises:

UserError – If the provided version is too low or formatted incorrectly.

check_dependent_clusters(modules: list[str] | None = None) → list[dict]

Identify dependent clusters for the specified modules.

Parameters:

modules (list[str]) – A list of module names to check for dependencies.

Returns:

A list of cluster definitions that should be treated as dependencies.

Return type:

list[dict]

check_dup_config(cluster_cfgs=None, jvm_cfgs=None) → None

Check for duplicate entries in cluster config files.