Pipelines

import { init, pipelines } from 'gentrace';

init({
  apiKey: process.env.GENTRACE_API_KEY,
});

// List pipelines
const pipelineList = await pipelines.list();

// Access the pipelines
for (const pipeline of pipelineList.data) {
  console.log(pipeline.slug);
  console.log(pipeline.displayName);
}

import os
from gentrace import init, pipelines

init(api_key=os.environ["GENTRACE_API_KEY"])

# List pipelines
pipeline_list = await pipelines.list()

# Access the pipelines
for pipeline in pipeline_list.data:
    print(pipeline.slug)
    print(pipeline.display_name)

const pipeline = await pipelines.create({
  slug: 'customer-support-ai',
  displayName: 'Customer Support AI Pipeline',
  folderId: 'folder-uuid', // optional
});

pipeline = await pipelines.create(
    slug="customer-support-ai",
    display_name="Customer Support AI Pipeline",
    folder_id="folder-uuid",  # optional
)

const pipeline = await pipelines.retrieve('pipeline-id');
console.log(pipeline.slug);

pipeline = await pipelines.retrieve("pipeline-id")
print(pipeline.slug)

const pipeline = await pipelines.update('pipeline-id', {
  displayName: 'Updated Pipeline Name',
  isArchived: false,
});

pipeline = await pipelines.update(
    "pipeline-id",
    display_name="Updated Pipeline Name",
    is_archived=False,
)

// Filter by folder or slug
const pipelineList = await pipelines.list({
  folderId: 'folder-id',
  slug: 'customer-support', // exact match or use advanced filters
});

# Filter by folder or slug
pipeline_list = await pipelines.list(
    folder_id="folder-id",
    slug="customer-support",  # exact match
)

// Use pipeline ID with interaction()
const tracedFunction = interaction('My AI Function', myAIFunction, {
  pipelineId: pipeline.id,
});

// Use pipeline ID with experiment()
experiment(pipeline.id, async () => {
  // Your experiment code
});

# Use pipeline ID with interaction()
@interaction(pipeline_id=pipeline.id, name="My AI Function")
async def traced_function():
    # Your AI function code
    pass

# Use pipeline ID with experiment()
@experiment(pipeline_id=pipeline.id)
async def my_experiment():
    # Your experiment code
    pass