agentsociety.commercial.executor.kubernetes

Module Contents

Classes

KubernetesExecutor

Data

__all__

API

agentsociety.commercial.executor.kubernetes.__all__

[‘KubernetesExecutor’]

class agentsociety.commercial.executor.kubernetes.KubernetesExecutor(kube_config_search_paths: list[str])

Initialization

async _ensure_config_loaded()

确保 Kubernetes 配置已加载

async create(config_base64: Optional[str] = None, config_path: Optional[str] = None, callback_url: str = '', callback_auth_token: str = '', tenant_id: str = '')

async delete(tenant_id: str, exp_id: str) → None

Delete experiment pod in kubernetes using labels and wait until it’s gone

Args: tenant_id: Tenant ID exp_id: Experiment ID

Raises: HTTPException: If pod not found or deletion timeout

async get_logs(tenant_id: str, exp_id: str) → str

Get experiment pod logs from kubernetes using labels

Args: tenant_id: Tenant ID exp_id: Experiment ID

Returns: str: Pod logs

Raises: Exception: If failed to get pod logs

async get_status(tenant_id: str, exp_id: str) → str

Get experiment pod status from kubernetes using labels

Args: tenant_id: Tenant ID exp_id: Experiment ID

Returns: str: Pod status

Raises: Exception: If failed to get pod status

Kubernetes

本文件下的内容不采用开源许可，仅供商业版使用。

【商业版】Kubernetes 配置文件。