Migrate Stream Client

from arize.api import Client
client = Client(...)

from arize import ArizeClient
client = ArizeClient(...)

from arize.api import Client
from arize.utils.types import Environments, ModelTypes

# Client initialization
client = Client(
    api_key="your-api-key",
    space_id="your-space-id"
)

# Streaming a prediction
future = client.log(
    model_id="my-model",
    model_type=ModelTypes.BINARY_CLASSIFICATION,
    environment=Environments.PRODUCTION,
    model_version="v1.0",
    prediction_id="pred-123",
    prediction_timestamp=1609459200,
    prediction_label=1,
    features={"feature1": 0.5, "feature2": "value"},
    tags={"user_id": "user-456"},
    batch_id="batch-789"
)

# Get the result (blocks until complete)
response = future.result()

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

# Client initialization
client = ArizeClient(api_key="your-api-key")

# Streaming a prediction
future = client.ml.log_stream(
    space_id="your-space-id",  # Now required per call
    model_name="my-model",  # Renamed from model_id
    model_type=ModelTypes.BINARY_CLASSIFICATION,
    environment=Environments.PRODUCTION,
    model_version="v1.0",
    prediction_id="pred-123",
    prediction_timestamp=1609459200,
    prediction_label=1,
    features={"feature1": 0.5, "feature2": "value"},
    tags={"user_id": "user-456"},
    batch_id="batch-789",
    timeout=30.0  # Optional, new parameter
)

# Get the result (blocks until complete)
response = future.result()