# Bootstrap


<!-- WARNING: THIS FILE WAS AUTOGENERATED! DO NOT EDIT! -->

## Pipeline

Container returned by `create_pipeline`. Holds the assembled
`CapabilityManager`, `JobQueue`, and a `bindings` dict mapping
capability names to `CapabilityBinding` views for the capabilities that
loaded successfully. Implements async context-manager semantics for
ergonomic teardown:

``` python
async with create_pipeline(capabilities=["whisper", "sys-mon"]) as pipe:
    result = await pipe.bindings["whisper"].execute_async(audio=path)
```

The context-manager exit calls `queue.stop()` + `manager.unload_all()`.

------------------------------------------------------------------------

### Pipeline

``` python

def Pipeline(
    manager:CapabilityManager, queue:JobQueue, bindings:Dict=<factory>
)->None:

```

*Assembled substrate stack: manager + queue + capability bindings.*

## Spec normalization

Callers can describe each capability entry in three forms — a bare name
(use defaults), a `(name, config)` tuple, or a mapping with `name` +
`config` keys. The internal helper normalizes all three into a
`(name, config)` pair.

## create_pipeline

The canonical assembly factory. Substitutes for the ~70-line boilerplate
that 5 audited demos have been repeating. Returns a `Pipeline` whose
queue hasn’t been started yet — callers either use it as an async
context manager or call `await pipeline.start()` explicitly.

------------------------------------------------------------------------

### create_pipeline

``` python

def create_pipeline(
    capabilities:Optional=None, # Capabilities to discover + load
    scheduler:Optional=None, # Resource policy (default: permissive)
    system_monitor:Optional=None, # Capability name to register as system monitor
    search_paths:Optional=None, # Custom manifest search paths
    queue_kwargs:Optional=None, # Extra kwargs forwarded to JobQueue
    strict:bool=True, # SG-5 strict config validation on each load
)->Pipeline: # Assembled stack ready to start

```

*Assemble a CapabilityManager + JobQueue + capability bindings in one
call.*

Steps performed: 1. Construct CapabilityManager with the given
scheduler + search paths 2. discover_manifests() 3. For each spec in
`capabilities`: load the capability and create a CapabilityBinding 4. If
`system_monitor` is set, register that capability as the sys-mon 5.
Construct JobQueue (NOT started — caller starts via context manager)

Capabilities that fail to load are logged but do not raise; their
entries are omitted from `Pipeline.bindings`. Use the returned
`Pipeline.manager` to inspect which loads succeeded.

``` python
# SG-18 regression: spec normalization handles all three accepted forms.
from typing import cast

# Bare string
assert _normalize_spec("whisper") == ("whisper", None)

# Tuple — one-element
assert _normalize_spec(("whisper",)) == ("whisper", None)

# Tuple — name + config
assert _normalize_spec(("whisper", {"model": "large"})) == ("whisper", {"model": "large"})

# Mapping with config
assert _normalize_spec({"name": "whisper", "config": {"model": "tiny"}}) == (
    "whisper", {"model": "tiny"},
)

# Mapping without config
assert _normalize_spec({"name": "whisper"}) == ("whisper", None)

# Bad forms raise
try:
    _normalize_spec(cast(Any, 42))
except TypeError as e:
    print(f"✓ rejected int spec: {e}")

try:
    _normalize_spec(("a", "b", "c"))  # type: ignore
except ValueError as e:
    print(f"✓ rejected 3-tuple: {e}")

try:
    _normalize_spec({"config": {}})  # type: ignore
except ValueError as e:
    print(f"✓ rejected mapping without name: {e}")

# Pipeline dataclass round-trips
from unittest.mock import MagicMock
mgr = MagicMock(spec=CapabilityManager)
q = MagicMock(spec=JobQueue)
pipe = Pipeline(manager=mgr, queue=q)
assert pipe.bindings == {}
assert pipe.manager is mgr
assert pipe.queue is q

print("SG-18 spec normalization + Pipeline shape: PASS")
```

    ✓ rejected int spec: unsupported capability spec type: int
    ✓ rejected 3-tuple: capability spec tuple must be (name,) or (name, config); got ('a', 'b', 'c')
    ✓ rejected mapping without name: capability spec mapping missing 'name' key: {'config': {}}
    SG-18 spec normalization + Pipeline shape: PASS