aztk package

• aztk.models package
• aztk.spark package
  • aztk.spark.models package
    • aztk.spark.models.plugins package
  • aztk.spark.client module

aztk.client module

class aztk.client.Client(secrets_config: aztk.models.secrets_configuration.SecretsConfiguration)

Bases: object

get_cluster_config(cluster_id: str) → aztk.models.cluster_configuration.ClusterConfiguration

create_cluster(cluster_conf, wait: bool = False)

create_clusters_in_parallel(cluster_confs)

delete_cluster(cluster_id: str)

get_cluster(cluster_id: str)

list_clusters()

wait_until_cluster_is_ready(cluster_id)

create_user(cluster_id: str, username: str, password: str = None, ssh_key: str = None) → str

get_remote_login_settings(cluster_id, node_id)

cluster_run(cluster_id, command)

cluster_copy(cluster_id, source_path, destination_path)

cluster_download(cluster_id, source_path, destination_path)

submit_job(job)

aztk.error module

Contains all errors used in Aztk. All error should inherit from AztkError

exception aztk.error.AztkError

Bases: Exception

exception aztk.error.AztkAttributeError

Bases: aztk.error.AztkError

exception aztk.error.ClusterNotReadyError

Bases: aztk.error.AztkError

exception aztk.error.AzureApiInitError

Bases: aztk.error.AztkError

exception aztk.error.InvalidPluginConfigurationError

Bases: aztk.error.AztkError

exception aztk.error.InvalidModelError(message: str, model=None)

Bases: aztk.error.AztkError

exception aztk.error.MissingRequiredAttributeError(message: str, model=None)

Bases: aztk.error.InvalidModelError

exception aztk.error.InvalidCustomScriptError(message: str, model=None)

Bases: aztk.error.InvalidModelError

exception aztk.error.InvalidPluginReferenceError(message: str, model=None)

Bases: aztk.error.InvalidModelError

exception aztk.error.InvalidModelFieldError(message: str, model=None, field=None)

Bases: aztk.error.InvalidModelError