with_options

1
from baml_client import b
2
from baml_py import ClientRegistry, Collector
3
4
# Set up default options for this client
5
collector = Collector(name="my-collector")
6
client_registry = ClientRegistry()
7
client_registry.set_primary("openai/gpt-4o-mini")
8
9
# Create client with default options
10
my_b = b.with_options(collector=collector, client_registry=client_registry)
11
12
# Uses the default options
13
result = my_b.ExtractResume("...")
14
15
# Override options for a specific call
16
other_collector = Collector(name="other-collector")
17
result2 = my_b.ExtractResume("...", baml_options={"collector": other_collector})

1
from baml_client import b
2
from baml_py import ClientRegistry, Collector
3
4
def run():
5
    # Configure options
6
    collector = Collector(name="my-collector")
7
    client_registry = ClientRegistry()
8
    client_registry.set_primary("openai/gpt-4o-mini")
9
10
    # Create configured client
11
    my_b = b.with_options(collector=collector, client_registry=client_registry)
12
13
    # All calls will use the configured options
14
    res = my_b.ExtractResume("...")
15
    invoice = my_b.ExtractInvoice("...")
16
17
    # Access configuration
18
    print(my_b.client_registry)
19
    # Access logs from the collector
20
    print(collector.logs)
21
    print(collector.last)

1
from baml_client.async_client import b
2
from baml_py import ClientRegistry, Collector
3
import asyncio
4
5
async def run():
6
    collector = Collector(name="my-collector")
7
    my_b = b.with_options(collector=collector, client_registry=client_registry)
8
9
    # Run multiple functions in parallel
10
    res, invoice = await asyncio.gather(
11
        my_b.ExtractResume("..."),
12
        my_b.ExtractInvoice("...")
13
    )
14
15
    # Access results and logs
16
    print(res)
17
    print(invoice)
18
    print(collector.id(res.id).usage)
19
    print(collector.id(invoice.id).usage)

1
from baml_client.async_client import b
2
from baml_py import Collector
3
4
async def run():
5
    collector = Collector(name="my-collector")
6
    my_b = b.with_options(collector=collector, client_registry=client_registry)
7
8
    stream = my_b.stream.ExtractResume("...")
9
    async for chunk in stream:
10
        print(chunk)
11
    
12
    result = await stream.get_final_result()
13
    print(collector.id(stream.id).usage)