Python client

Website Slack

Search…

0.42

Get started

Clusters

Workloads

Clients

Python client
​cortex​
​client​
​new_client​
​env_list​
​env_delete​
​cortex.client.Client​
​deploy​
​deploy_from_file​
​get_api​
​list_apis​
​get_job​
​refresh​
​delete​
​stop_job​
cortex
client
client(env: Optional[str] = None) -> Client
Initialize a client based on the specified environment. If no environment is specified, it will attempt to use the default environment.
Arguments:
env - Name of the environment to use.
Returns:
Cortex client that can be used to deploy and manage APIs in the specified environment.
new_client
new_client(name: str, operator_endpoint: str) -> Client
Create a new environment to connect to an existing cluster, and initialize a client to deploy and manage APIs on that cluster.
Arguments:
name - Name of the environment to create.
operator_endpoint - The endpoint for the operator of your Cortex cluster. You can get this endpoint by running the CLI command cortex cluster info.
Returns:
Cortex client that can be used to deploy and manage APIs on a cluster.
env_list
env_list() -> List
List all environments configured on this machine.
env_delete
env_delete(name: str)
Delete an environment configured on this machine.
Arguments:
name - Name of the environment to delete.
cortex.client.Client
deploy
 | deploy(api_spec: Dict[str, Any], force: bool = True, wait: bool = False)
Deploy or update an API.
Arguments:
api_spec - A dictionary defining a single Cortex API. See https://docs.cortex.dev/v/0.42/ for schema.
force - Override any in-progress api updates.
wait - Block until the API is ready.
Returns:
Deployment status, API specification, and endpoint for each API.
deploy_from_file
 | deploy_from_file(config_file: str, force: bool = False, wait: bool = False) -> Dict
Deploy or update APIs specified in a configuration file.
Arguments:
config_file - Local path to a yaml file defining Cortex API(s). See https://docs.cortex.dev/v/0.42/ for schema.
force - Override any in-progress api updates.
wait - Block until the API is ready.
Returns:
Deployment status, API specification, and endpoint for each API.
get_api
 | get_api(api_name: str) -> Dict
Get information about an API.
Arguments:
api_name - Name of the API.
Returns:
Information about the API, including the API specification, endpoint, status, and metrics (if applicable).
list_apis
 | list_apis() -> List
List all APIs in the environment.
Returns:
List of APIs, including information such as the API specification, endpoint, status, and metrics (if applicable).
get_job
 | get_job(api_name: str, job_id: str) -> Dict
Get information about a submitted job.
Arguments:
api_name - Name of the Batch/Task API.
job_id - Job ID.
Returns:
Information about the job, including the job status, worker status, and job progress.
refresh
 | refresh(api_name: str, force: bool = False)
Restart all of the replicas for a Realtime API without downtime.
Arguments:
api_name - Name of the API to refresh.
force - Override an already in-progress API update.
delete
 | delete(api_name: str, keep_cache: bool = False)
Delete an API.
Arguments:
api_name - Name of the API to delete.
keep_cache - Whether to retain the cached data for this API.
stop_job
 | stop_job(api_name: str, job_id: str, keep_cache: bool = False)
Stop a running job.
Arguments:
api_name - Name of the Batch/Task API.
job_id - ID of the Job to stop.