Pipelines your agent can write and you can read.

from segmentstream.connections import GoogleAdsConnection, HubSpotConnectionconnections = (    GoogleAdsConnection(key="google_ads"),    HubSpotConnection(key="hubspot"),)

@s.ingestion(    tier=s.Tier.Bronze,    partitioning=s.Partitioning.Daily(column="order_date", start_date="2026-01-01"),    schema={"order_id": "string", "order_date": "date", "amount": "float64"},    primary_key=("order_id",),)def raw_orders(context: s.Context) -> Iterator[s.IngestionRow]:    for day in context.partition_keys:        yield from fetch_orders(day)

@s.model(    tier=s.Tier.Gold,    partitioning=s.Partitioning.Daily(column="order_date", start_date="2026-01-01"),    schema={"order_date": "date", "customer_count": "int64", "total_revenue": "float64"},)def revenue_summary(customer_revenue: ir.Table) -> ir.Table:    return customer_revenue.group_by("order_date").aggregate(        customer_count=customer_revenue.count(),        total_revenue=customer_revenue.revenue.sum(),    )

@s.asset_check(asset=raw_orders)def positive_order_amounts(raw_orders: ir.Table, warehouse: s.WarehouseResource) -> s.CheckResult:    invalid = int(warehouse.execute(raw_orders.filter(raw_orders.amount <= 0).count()))    return s.CheckResult(passed=invalid == 0, metadata={"invalid_order_count": invalid})

revenue = s.job("revenue_pipeline", assets=[revenue_summary], include_upstream=True)defs = s.definitions(    assets=[raw_orders, revenue_summary],    checks=[positive_order_amounts],    jobs=[revenue],    schedules=[        s.schedule(            "revenue_morning",            job=revenue,            cron="0 6 * * *",            timezone="Europe/London",            partitions=s.LatestPartitions(3),        ),    ],)

client = s.evaluation_client("evaluation")result = client.evaluate(    state={"job_title": "Head of Learning & Development", "company": "Acme"},    questions={        "relevant": {            "type": "boolean",            "instructions": "Would sales accept this demo request as an opportunity?",        },    },)relevant = result["answers"]["relevant"]["probability"]