Skip to content

Arize-ai/client_python

Folders and files

NameName
Last commit message
Last commit date

Latest commit

Β 

History

258 Commits
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 

Repository files navigation



Table of Contents

Overview

A helper package to interact with Arize AI APIs.

Arize is an AI engineering platform. It helps engineers develop, evaluate, and observe AI applications and agents.

Arize has both Enterprise and OSS products to support this goal:

  • Arize AX β€” an enterprise AI engineering platform from development to production, with an embedded AI Copilot
  • Phoenix β€” a lightweight, open-source project for tracing, prompt engineering, and evaluation
  • OpenInference β€” an open-source instrumentation package to trace LLM applications across models and frameworks

We log over 1 trillion inferences and spans, 10 million evaluation runs, and 2 million OSS downloads every month.

Key Features

  • Tracing - Trace your LLM application's runtime using OpenTelemetry-based instrumentation.
  • Evaluation - Leverage LLMs to benchmark your application's performance using response and retrieval evals.
  • Datasets - Create versioned datasets of examples for experimentation, evaluation, and fine-tuning.
  • Experiments - Track and evaluate changes to prompts, LLMs, and retrieval.
  • Playground- Optimize prompts, compare models, adjust parameters, and replay traced LLM calls.
  • Prompt Management- Manage and test prompt changes systematically using version control, tagging, and experimentation.

Installation

Install the base package:

pip install arize

Optional Dependencies

The following optional extras provide specialized functionality:

Note: The otel extra installs the arize-otel package, which is also available as a standalone package. If you only need auto-instrumentation without the full SDK, install arize-otel directly.

Extra Install Command What It Provides
otel pip install arize[otel] OpenTelemetry auto-instrumentation package (arize-otel) for automatic tracing
embeddings pip install arize[embeddings] Automatic embedding generation for NLP, CV, and structured data (Pillow, datasets, tokenizers, torch, transformers)
mimic pip install arize[mimic] MIMIC explainer for model interpretability

Install multiple extras:

pip install arize[otel,embeddings,mimic]

Migrating from Version 7

If you're upgrading from version 7, please refer to the Migration Guide for detailed migration steps and breaking changes.

Usage

Space Resolution

Throughout the SDK, any parameter named space accepts either a space ID (e.g. "spc_abc123") or a space name (e.g. "my-space"). The SDK resolves the identifier automatically:

  • If the value looks like a base64-encoded resource ID, it is used as a space ID directly.
  • Otherwise, it is treated as a case-insensitive substring filter on space names.
# Both of these are equivalent if your space is named "my-space"
client.datasets.list(space="U3BhY2U6OTA1MDoxSmtS")
client.datasets.list(space="my-space")

Instrumentation

See arize-otel in PyPI:

from arize.otel import register
from openinference.instrumentation.openai import OpenAIInstrumentor

# Setup OpenTelemetry via our convenience function
tracer_provider = register(
    space_id=SPACE_ID,
    api_key=API_KEY,
    project_name="agents-cookbook",
)

# Start instrumentation
OpenAIInstrumentor().instrument(tracer_provider=tracer_provider)

Operations on Spans

Use arize.spans to interact with spans: log spans into Arize, update the span's evaluations, annotations and metadata in bulk.

Logging spans

from arize import ArizeClient

client = ArizeClient(api_key=API_KEY)
SPACE_ID = "<your-space-id>"
PROJECT_NAME = "<your-project-name>"

client.spans.log(
    space_id=SPACE_ID,
    project_name=PROJECT_NAME,
    dataframe=spans_df,
    # evals_df=evals_df, # Optionally pass the evaluations together with the spans
)

Update spans Evaluations, Annotations, and Metadata

from arize import ArizeClient

client = ArizeClient(api_key=API_KEY)
SPACE_ID = "<your-space-id>"
PROJECT_NAME = "<your-project-name>"

client.spans.update_evaluations(
    space_id=SPACE_ID,
    project_name=PROJECT_NAME,
    dataframe=evals_df,
    # force_http=... # Optionally pass force_http to update evaluations via HTTP instead of gRPC, defaults to False
)

client.spans.update_annotations(
    space_id=SPACE_ID,
    project_name=PROJECT_NAME,
    dataframe=annotations_df,
)

client.spans.update_metadata(
    space_id=SPACE_ID,
    project_name=PROJECT_NAME,
    dataframe=metadata_df,
)

Exporting spans

Use the export_to_df or export_to_parquet to export large amounts of spans from Arize.

from arize import ArizeClient
from datetime import datetime

FMT  = "%Y-%m-%d"
start_time = datetime.strptime("2024-01-01",FMT)
end_time = datetime.strptime("2026-01-01",FMT)

client = ArizeClient(api_key=API_KEY)
SPACE_ID = "<your-space-id>"
PROJECT_NAME = "<your-project-name>"

df = client.spans.export_to_df(
    space_id=SPACE_ID,
    project_name=PROJECT_NAME,
    start_time=start_time,
    end_time=end_time,
)

Operations on ML Models

Use arize.ml to interact with ML models: log ML data (training, validation, production) into Arize, either streaming or in batches.

Stream log ML Data for a Classification use-case

from arize import ArizeClient
from arize.ml.types import ModelTypes, Environments

client = ArizeClient(api_key=API_KEY)
SPACE_ID = "<your-space-id>"
MODEL_NAME = "<your-model-name>"

features=...
embedding_features=...

response = client.ml.log_stream(
    space_id=SPACE_ID,
    model_name=MODEL_NAME,
    model_type=ModelTypes.SCORE_CATEGORICAL,
    environment=Environments.PRODUCTION,
    prediction_label=("not fraud",0.3),
    actual_label=("fraud",1.0),
    features=features,
    embedding_features=embedding_features,
)

Log a batch of ML Data for a Object Detection use-case

from arize import ArizeClient
from arize.ml.types import ModelTypes, Environments

client = ArizeClient(api_key=API_KEY)
SPACE_ID = "<your-space-id>"
MODEL_NAME = "<your-model-name>"
MODEL_VERSION = "1.0"

from arize.ml.types import Schema, EmbeddingColumnNames, ObjectDetectionColumnNames, ModelTypes, Environments

tags = ["drift_type"]
embedding_feature_column_names = {
    "image_embedding": EmbeddingColumnNames(
        vector_column_name="image_vector", link_to_data_column_name="url"
    )
}
object_detection_prediction_column_names = ObjectDetectionColumnNames(
    bounding_boxes_coordinates_column_name="prediction_bboxes",
    categories_column_name="prediction_categories",
    scores_column_name="prediction_scores",
)
object_detection_actual_column_names = ObjectDetectionColumnNames(
    bounding_boxes_coordinates_column_name="actual_bboxes",
    categories_column_name="actual_categories",
)

# Define a Schema() object for Arize to pick up data from the correct columns for logging
schema = Schema(
    prediction_id_column_name="prediction_id",
    timestamp_column_name="prediction_ts",
    tag_column_names=tags,
    embedding_feature_column_names=embedding_feature_column_names,
    object_detection_prediction_column_names=object_detection_prediction_column_names,
    object_detection_actual_column_names=object_detection_actual_column_names,
)

# Logging Production DataFrame
response = client.ml.log_batch(
    space_id=SPACE_ID,
    model_name=MODEL_NAME,
    model_type=ModelTypes.OBJECT_DETECTION,
    dataframe=prod_df,
    schema=schema,
    environment=Environments.PRODUCTION,
    model_version = MODEL_VERSION, # Optionally pass a model version
)

Exporting ML Data

Use the export_to_df or export_to_parquet to export large amounts of spans from Arize.

from arize import ArizeClient
from datetime import datetime

FMT  = "%Y-%m-%d"
start_time = datetime.strptime("2024-01-01",FMT)
end_time = datetime.strptime("2026-01-01",FMT)

client = ArizeClient(api_key=API_KEY)
SPACE_ID = "<your-space-id>"
MODEL_NAME = "<your-model-name>"
MODEL_VERSION = "1.0"

df = client.ml.export_to_df(
    space_id=SPACE_ID,
    model_name=MODEL_NAME,
    environment=Environments.TRAINING,
    model_version=MODEL_VERSION,
    start_time=start_time,
    end_time=end_time,
)

Generate embeddings for your data

import pandas as pd
from arize.embeddings import EmbeddingGenerator, UseCases

# You can check available models
print(EmbeddingGenerator.list_pretrained_models())

# Example dataframe
df = pd.DataFrame(
    {
        "text": [
            "Hello world.",
            "Artificial Intelligence is the future.",
            "Spain won the FIFA World Cup on 2010.",
        ],
    }
)
# Instantiate the generator for your usecase, selecting the base model
generator = EmbeddingGenerator.from_use_case(
    use_case=UseCases.NLP.SEQUENCE_CLASSIFICATION,
    model_name="distilbert-base-uncased",
    tokenizer_max_length=512,
    batch_size=100,
)

# Generate embeddings
df["text_vector"] = generator.generate_embeddings(text_col=df["text"])

Operations on Datasets

List Datasets

You can list all datasets that the user has access to using client.datasets.list(). You can use the limit parameter to specify the maximum number of datasets desired in the response and you can specify space to filter by space. The space parameter accepts either a space ID (e.g. "U3BhY2U6OTA1MDoxSmtS") or a space name for substring filtering. You can also filter by dataset name.

resp = client.datasets.list(
    name=... # Optional, case-insensitive substring filter on dataset name
    space=... # Optional, space ID (e.g. "U3BhY2U6OTA1MDoxSmtS") or space name (e.g. "my-space")
    limit=... # Optional, defaults to 100
)

The response is an object of type DatasetsList200Response, and you can access the list of datasets via its datasets attribute. In addition, you can transform the response object to a dictionary, to JSON format, or a pandas dataframe.

# Get the list of datasets from the response
dataset_list = resp.datasets
# Get the response as a dictionary
resp_dict = resp.to_dict()
# Get the response in JSON format
resp_json = resp.to_json()
# Get the response as a pandas dataframe
resp_df = resp.to_df()

Create a Dataset

You can create a dataset using client.datasets.create(). You must pass examples β€” we currently don't support creating an empty dataset. Examples can be provided as a list of dictionaries or a pandas dataframe.

examples = [
    {
        "eval.Correctness Basic.explanation": "The query indicates that the user is having trouble accessing their account on their laptop, while access on their phone is still working. This suggests a potential issue with the login process on the laptop, which aligns with the 'Login Issues' queue. The mention of a possible change in the account could relate to login credentials or settings affecting the laptop specifically, but it still falls under the broader category of login issues.",
        "eval.Correctness Basic.label": "correct",
        "eval.Correctness Basic.score": 1,
        "llm output": "Login Issues",
        "query": "I can't get in on my laptop anymore, but my phone still works fine β€” could this be because I changed something in my account?"
    },
    {
        "eval.Correctness Basic.explanation": "The query is about a user who signed up but is unable to log in because the system says no account is found. This issue is related to the login process, as the user is trying to access their account and is facing a problem with the login system recognizing their account. Therefore, assigning this query to the 'Login Issues' queue is appropriate.",
        "eval.Correctness Basic.label": "correct",
        "eval.Correctness Basic.score": 1,
        "llm output": "Login Issues",
        "query": "Signed up ages ago but never got around to logging in β€” now it says no account found. Do I start over?"
    }
]

If the number of examples is too large, the client SDK will try to send the data via Arrow Flight via gRPC for better performance. If you want to force the data transfer to HTTP you can use the force_http flag. The response is a Dataset object.

created_dataset = client.datasets.create(
    space="<space-id-or-name>",
    name="<your-dataset-name>", # Name must be unique within a space
    examples=..., # List of dictionaries or pandas dataframe
    # force_http=... # Optionally pass force_http to create datasets via HTTP instead of gRPC, defaults to False
)

The Dataset object also has convenience methods:

# Get the response as a dictionary
dataset_dict = created_dataset.to_dict()
# Get the response in JSON format
dataset_json = created_dataset.to_json()

Get a Dataset

To get a dataset by its ID or name use client.datasets.get(). You can optionally pass space for disambiguation when looking up by name. The returned type is Dataset.

dataset = client.datasets.get(
    dataset=... # The dataset ID or name
    space=... # Optional, space ID or name (required when looking up by dataset name)
)

Delete a Dataset

To delete a dataset by its ID or name use client.datasets.delete(). The call returns None if successful deletion took place, error otherwise.

client.datasets.delete(
    dataset=... # The dataset ID or name
    space=... # Optional, space ID or name (required when looking up by dataset name)
)

List Dataset Examples

You can list the examples of a given dataset using client.datasets.list_examples(). You can specify the number of examples desired using the limit parameter. If you want all examples, use all=True, which exports data using Arrow Flight via gRPC for increased performance.

resp = client.datasets.list_examples(
    dataset="<your-dataset-id-or-name>",
    space=..., # Optional, space ID or name
    dataset_version_id=..., # Optional, defaults to latest version
    limit=... # number of desired examples. Defaults to 100
    all=... # Whether or not to export all of the examples. Defaults to False
)

The response is an object of type DatasetsExamplesList200Response, and you can access the list of examples via its examples attribute. In addition, you can transform the response object to a dictionary, to JSON format, or a pandas dataframe.

# Get the list of examples from the response
examples_list = resp.examples
# Get the response as a dictionary
resp_dict = resp.to_dict()
# Get the response in JSON format
resp_json = resp.to_json()
# Get the response as a pandas dataframe
resp_df = resp.to_df()

Append Dataset Examples

You can append examples to an existing dataset version using client.datasets.append_examples(). This creates a new dataset version with the appended data and returns the updated Dataset object.

updated_dataset = client.datasets.append_examples(
    dataset="<your-dataset-id-or-name>",
    space=..., # Optional, space ID or name
    dataset_version_id="<version-id-to-append-to>",
    examples=..., # List of dictionaries or pandas dataframe
)

Operations on Experiments

List Experiments

You can list all experiments that the user has access to using client.experiments.list(). You can use the limit parameter to specify the maximum number of experiments desired in the response and you can specify the dataset to target the list operation to a particular dataset.

resp = client.experiments.list(
    dataset=... # Optional, dataset ID or name
    space=... # Optional, space ID or name
    limit=... # Optional, defaults to 100
)

The response is an object of type ExperimentsList200Response, and you can access the list of experiments via its experiments attribute. In addition, you can transform the response object to a dictionary, to JSON format, or a pandas dataframe.

# Get the list of experiments from the response
experiment_list = resp.experiments
# Get the response as a dictionary
resp_dict = resp.to_dict()
# Get the response in JSON format
resp_json = resp.to_json()
# Get the response as a pandas dataframe
resp_df = resp.to_df()

Run an Experiment

You can run an experiment on a dataset using client.experiments.run() by defining a task, evaluators (optional), and passing the dataset id or name of the dataset you want to use, together with a name for the experiment. The function will download the entire dataset from Arize (unless cached, see caching section under "SDK Configuration"), execute the task to obtain an output, and perform evaluations (if evaluators were passed). The experiments will also be traced, and these traces will be visible in Arize. The experiment will be created and the data logged into Arize automatically. You can avoid logging to Arize by making dry_run=True. The function will return the Experiment object (or None if dry_run=True) together with the dataframe with the experiment data.

experiment, experiment_df = client.experiments.run(
    name="<name-your-experiment>",
    dataset="<your-dataset-id-or-name>",
    space=..., # Optional, space ID or name
    task=... # The task to be performed in the experiment.
    evaluators=... # Optional: The evaluators to use in the experiment.
    dry_run=..., # If True, the experiment result will not be uploaded to Arize. Defaults to False
    dry_run_count=..., # Number of examples of the dataset to use in the dry run. Defaults to 10
    concurrency=..., # The number of concurrent tasks to run. Defaults to 3.
    set_global_tracer_provider=..., # If True, sets the global tracer provider for the experiment. Defaults to False
    exit_on_error=..., # If True, the experiment will stop running on first occurrence of an error. Defaults to False
)

The Experiment object also has convenience methods:

# Get the response as a dictionary
experiment_dict = experiment.to_dict()
# Get the response in JSON format
experiment_json = experiment.to_json()

Create an Experiment

It is possible that you have run the experiment yourself without the above function, and hence you already have experiment data that you want to send to Arize. In this case, use the client.experiments.create() method by passing the runs data as a list of dictionaries or pandas dataframe.

NOTE: If you don't have experiment data and want to run an experiment, see the client.experiments.run() section above.

In addition, you must specify which columns are the example_id and the result using ExperimentTaskFieldNames. If you have evaluation data, indicate the evaluation columns using EvaluationResultFieldNames.

If the number of runs is too large, the client SDK will try to send the data via Arrow Flight via gRPC for better performance. If you want to force the data transfer to HTTP you can use the force_http flag. The response is an Experiment object.

from arize.experiments.types import ExperimentTaskFieldNames, EvaluationResultFieldNames

created_experiment = client.experiments.create(
    name="<your-experiment-name>", # Name must be unique within a dataset
    dataset="<your-dataset-id-or-name>",
    space=..., # Optional, space ID or name
    experiment_runs=..., # List of dictionaries or pandas dataframe
    task_fields=ExperimentTaskFieldNames(...),
    evaluator_columns=... # Optional
    # force_http=... # Optionally pass force_http to create experiments via HTTP instead of gRPC, defaults to False
)

Get an Experiment

To get an experiment by its ID or name use client.experiments.get(). The returned type is Experiment (does not include experiment runs β€” use list_runs() for those).

experiment = client.experiments.get(
    experiment=... # The experiment ID or name
    dataset=... # Optional, dataset ID or name (required when looking up by experiment name)
    space=... # Optional, space ID or name
)

Delete an Experiment

To delete an experiment by its ID or name use client.experiments.delete(). The call returns None if successful deletion took place, error otherwise.

client.experiments.delete(
    experiment=... # The experiment ID or name
    dataset=... # Optional, dataset ID or name
    space=... # Optional, space ID or name
)

List Experiment Runs

You can list the runs of a given experiment using client.experiments.list_runs() and passing the experiment ID or name. You can specify the number of runs desired using the limit parameter. If you want all runs, consider using the all=True parameter, which will make it so the SDK exports the data using Arrow Flight via gRPC, for increased performance.

resp = client.experiments.list_runs(
    experiment="<your-experiment-id-or-name>",
    dataset=..., # Optional, dataset ID or name
    space=..., # Optional, space ID or name
    limit=... # number of desired runs. Defaults to 100
    all=... # Whether or not to export all of the runs. Defaults to False
)

The response is an object of type ExperimentsRunsList200Response, and you can access the list of runs via its experiment_runs attribute. In addition, you can transform the response object to a dictionary, to JSON format, or a pandas dataframe.

# Get the list of runs from the response
run_list = resp.experiment_runs
# Get the response as a dictionary
resp_dict = resp.to_dict()
# Get the response in JSON format
resp_json = resp.to_json()
# Get the response as a pandas dataframe
resp_df = resp.to_df()

Operations on Prompts

Use client.prompts to manage prompts and their versions in Arize's Prompt Hub.

List Prompts

resp = client.prompts.list(
    name=..., # Optional, case-insensitive substring filter on prompt name
    space=..., # Optional, space ID or name
    limit=..., # Optional, defaults to 100
)
prompt_list = resp.prompts

Create a Prompt

Creating a prompt also creates its first version. You must specify the space, a name, and the prompt content.

from arize.prompts.types import InputVariableFormat, LlmProvider, LLMMessage, InvocationParams

prompt = client.prompts.create(
    space="<space-id-or-name>",
    name="<your-prompt-name>",
    commit_message="Initial version",
    input_variable_format=InputVariableFormat.FSTRING, # or MUSTACHE
    provider=LlmProvider.OPENAI,
    messages=[
        LLMMessage(role="system", content="You are a helpful assistant."),
        LLMMessage(role="user", content="Answer this question: {question}"),
    ],
    description=..., # Optional
    model=..., # Optional model name
    invocation_params=..., # Optional
)

Get a Prompt

To get a prompt by its ID or name use client.prompts.get(). You can optionally request a specific version by version_id or by label. Defaults to the latest version. The returned type is PromptWithVersion.

prompt = client.prompts.get(
    prompt="<your-prompt-id-or-name>",
    space=..., # Optional, space ID or name
    version_id=..., # Optional, get a specific version
    label=..., # Optional, get the version with this label (e.g. "production")
)

Update a Prompt

updated_prompt = client.prompts.update(
    prompt="<prompt-id-or-name>",
    space=..., # Optional
    description="Updated description",
)

Delete a Prompt

client.prompts.delete(
    prompt="<prompt-id-or-name>",
    space=..., # Optional
)

Prompt Versions

You can list all versions of a prompt, create new versions, and retrieve a specific version.

# List versions
versions = client.prompts.list_versions(
    prompt="<prompt-id-or-name>",
    space=..., # Optional
    limit=..., # Optional, defaults to 100
)

# Create a new version
new_version = client.prompts.create_version(
    prompt="<prompt-id-or-name>",
    space=..., # Optional
    commit_message="Update system prompt",
    input_variable_format=InputVariableFormat.FSTRING,
    provider=LlmProvider.OPENAI,
    messages=[...],
    model=..., # Optional
    invocation_params=..., # Optional
)

Prompt Labels

Labels allow you to tag a specific prompt version with a named alias (e.g. "production", "staging").

# Get the version currently tagged with a label
version = client.prompts.get_label(
    prompt="<prompt-id-or-name>",
    space=..., # Optional
    label_name="production",
)

# Set labels on a version (replaces all existing labels)
client.prompts.set_labels(
    version_id="<version-id>",
    labels=["production", "v2"],
)

# Delete a single label from a version
client.prompts.delete_label(
    version_id="<version-id>",
    label_name="staging",
)

Operations on Evaluators

Use client.evaluators to manage LLM evaluators and their versions.

List Evaluators

resp = client.evaluators.list(
    name=..., # Optional, case-insensitive substring filter on evaluator name
    space=..., # Optional, space ID or name
    limit=..., # Optional, defaults to 100
)
evaluator_list = resp.evaluators

Create an Evaluator

from arize.evaluators.types import TemplateConfig

evaluator = client.evaluators.create(
    name="<your-evaluator-name>",
    space="<space-id-or-name>",
    evaluator_type="template",
    commit_message="Initial version",
    template_config=TemplateConfig(...),
    description=..., # Optional
)

Get an Evaluator

evaluator = client.evaluators.get(
    evaluator="<evaluator-id-or-name>",
    space=..., # Optional
    version_id=..., # Optional, defaults to latest version
)

Update an Evaluator

updated = client.evaluators.update(
    evaluator="<evaluator-id-or-name>",
    space=..., # Optional
    name=..., # Optional
    description=..., # Optional
)

Delete an Evaluator

client.evaluators.delete(
    evaluator="<evaluator-id-or-name>",
    space=..., # Optional
)

Evaluator Versions

# List versions
versions = client.evaluators.list_versions(
    evaluator="<evaluator-id-or-name>",
    space=..., # Optional
    limit=..., # Optional, defaults to 100
)

# Get a specific version
version = client.evaluators.get_version(version_id="<version-id>")

# Create a new version
new_version = client.evaluators.create_version(
    evaluator="<evaluator-id-or-name>",
    space=..., # Optional
    commit_message="Updated template",
    template_config=TemplateConfig(...),
)

Operations on Tasks

Use client.tasks to manage online evaluation tasks that run continuously or on-demand against your production data.

List Tasks

resp = client.tasks.list(
    name=..., # Optional, case-insensitive substring filter on task name
    space=..., # Optional, space ID or name
    project=..., # Optional, filter by project (name or ID)
    dataset=..., # Optional, filter by dataset (name or ID)
    task_type=..., # Optional, "template_evaluation" or "code_evaluation"
    limit=..., # Optional, defaults to 100
)
task_list = resp.tasks

Create a Task

Tasks run evaluators against spans from a project or experiments from a dataset. Either project or dataset is required (not both). At least one evaluator is required.

from arize.tasks.types import TasksCreateRequestEvaluatorsInner

task = client.tasks.create(
    name="<your-task-name>",
    task_type="template_evaluation",
    evaluators=[TasksCreateRequestEvaluatorsInner(...)],
    project="<project-id-or-name>", # Required if not using dataset
    # dataset="<dataset-id-or-name>", # Required if not using project
    space=..., # Optional, space ID or name
    sampling_rate=..., # Optional, fraction of data to evaluate (0.0–1.0)
    is_continuous=..., # Optional, run continuously on new data
    query_filter=..., # Optional, filter expression for spans
)

Get a Task

task = client.tasks.get(
    task="<task-id-or-name>",
    space=..., # Optional
)

Trigger a Task Run

You can trigger an on-demand run of a task. The returned TaskRun will initially have "pending" status.

run = client.tasks.trigger_run(
    task="<task-id-or-name>",
    space=..., # Optional
    data_start_time=..., # Optional, start of data window
    data_end_time=..., # Optional, end of data window
    max_spans=..., # Optional, maximum spans to evaluate
    override_evaluations=..., # Optional, re-evaluate already-evaluated spans
)

Monitor Task Runs

# List runs for a task
runs_resp = client.tasks.list_runs(
    task="<task-id-or-name>",
    space=..., # Optional
    status=..., # Optional, filter by "pending", "running", "completed", "failed", or "cancelled"
    limit=..., # Optional, defaults to 100
)

# Get a specific run
run = client.tasks.get_run(run_id="<run-id>")

# Cancel a pending or running run
cancelled_run = client.tasks.cancel_run(run_id="<run-id>")

# Wait for a run to reach a terminal state (completed, failed, or cancelled)
finished_run = client.tasks.wait_for_run(
    run_id="<run-id>",
    poll_interval=5.0, # Optional, seconds between polls. Defaults to 5.0
    timeout=600.0, # Optional, seconds before TimeoutError. Defaults to 600.0
)

Operations on Projects

Use client.projects to manage projects, which are namespaces for organizing tracing data.

List Projects

resp = client.projects.list(
    name=..., # Optional, case-insensitive substring filter on project name
    space=..., # Optional, space ID or name
    limit=..., # Optional, defaults to 100
)
project_list = resp.projects

Create a Project

project = client.projects.create(
    name="<your-project-name>", # Must be unique within the space
    space="<space-id-or-name>",
)

Get a Project

project = client.projects.get(
    project="<project-id-or-name>",
    space=..., # Optional
)

Delete a Project

client.projects.delete(
    project="<project-id-or-name>",
    space=..., # Optional
)

Operations on Annotation Configs

Use client.annotation_configs to manage annotation configurations that define scoring schemas for human feedback.

List Annotation Configs

resp = client.annotation_configs.list(
    name=..., # Optional, case-insensitive substring filter
    space=..., # Optional, space ID or name
    limit=..., # Optional, defaults to 100
)
config_list = resp.annotation_configs

Create an Annotation Config

from arize.annotation_configs.types import AnnotationConfigType, CategoricalAnnotationValue, OptimizationDirection

# Continuous (numeric) annotation config
config = client.annotation_configs.create(
    name="quality-score",
    space="<space-id-or-name>",
    config_type=AnnotationConfigType.CONTINUOUS,
    minimum_score=0.0,
    maximum_score=1.0,
    optimization_direction=OptimizationDirection.MAXIMIZE,
)

# Categorical annotation config
config = client.annotation_configs.create(
    name="correctness",
    space="<space-id-or-name>",
    config_type=AnnotationConfigType.CATEGORICAL,
    values=[
        CategoricalAnnotationValue(label="correct", score=1),
        CategoricalAnnotationValue(label="incorrect", score=0),
    ],
    optimization_direction=OptimizationDirection.MAXIMIZE,
)

Get an Annotation Config

config = client.annotation_configs.get(
    annotation_config="<config-id-or-name>",
    space=..., # Optional
)

Delete an Annotation Config

client.annotation_configs.delete(
    annotation_config="<config-id-or-name>",
    space=..., # Optional
)

Operations on AI Integrations

Use client.ai_integrations to manage external LLM provider integrations used in the Arize Playground and online evaluations.

List AI Integrations

resp = client.ai_integrations.list(
    name=..., # Optional, case-insensitive substring filter
    space=..., # Optional, space ID or name
    limit=..., # Optional, defaults to 100
)
integration_list = resp.ai_integrations

Create an AI Integration

from arize.ai_integrations.types import AiIntegrationProvider, AiIntegrationAuthType

integration = client.ai_integrations.create(
    name="my-openai-integration",
    provider=AiIntegrationProvider.OPENAI,
    api_key="<your-provider-api-key>",
    base_url=..., # Optional, custom base URL
    model_names=..., # Optional, list of enabled model names
    enable_default_models=True, # Optional
)

Get an AI Integration

integration = client.ai_integrations.get(
    integration="<integration-id-or-name>",
    space=..., # Optional, space ID or name (used for disambiguation)
)

Update an AI Integration

updated = client.ai_integrations.update(
    integration="<integration-id-or-name>",
    space=..., # Optional
    api_key="<new-api-key>",
    model_names=["gpt-4o", "gpt-4o-mini"],
)

Delete an AI Integration

client.ai_integrations.delete(
    integration="<integration-id-or-name>",
    space=..., # Optional
)

SDK Configuration

Logging

In Code

You can use configure_logging to set up the logging behavior of the Arize package to your needs.

from arize.logging import configure_logging

configure_logging(
    level=..., # Defaults to logging.INFO
    structured=..., # if True, emit JSON logs. Defaults to False
)

Via Environment Variables

Configure the same options as the section above, via:

import os

# Whether or not you want to disable logging altogether
os.environ["ARIZE_LOG_ENABLE"] = "true"
# Set up the logging level
os.environ["ARIZE_LOG_LEVEL"] = "debug"
# Whether or not you want structured JSON logs
os.environ["ARIZE_LOG_STRUCTURED"] = "false"

The default behavior of Arize's logs is: enabled, INFO level, and not structured.

Caching

When downloading big segments of data from Arize, such as a Dataset with all of its examples, the SDK will cache the file in parquet format under ~/.arize/cache/datasets/dataset_<updated_at_timestamp>.parquet.

In Code

You can disable caching via the enable_caching parameter when instantiating the client, and also edit the "arize directory":

client = ArizeClient(
    enable_caching=False, # Optional parameter, defaults to True
    arize_directory="my-desired-directory", # Optional parameter, defaults to ~/.arize
)

Via Environment Variables

You can also configure the above via:

import os

# Whether or not you want to disable caching
os.environ["ARIZE_ENABLE_CACHING"] = "true"
# Where you want the SDK to store the files
os.environ["ARIZE_DIRECTORY"] = "~/.arize"

Clean the cache

To clean the cache you can directly rm the files or directory. In addition, the client has the option to help with that as well using client.clear_cache(), which will delete the cache/ directory inside the arize directory (defaults to ~/.arize).

Community

Join our community to connect with thousands of AI builders.

Copyright 2025 Arize AI, Inc. All Rights Reserved.