aiq.eval.runtime_event_subscriber

Attributes

logger

Functions

pull_intermediate(→ asyncio.Future[list[dict]])

Subscribes to the runner's event stream using callbacks.

Module Contents

logger

pull_intermediate() → asyncio.Future[list[dict]]

Subscribes to the runner’s event stream using callbacks. Intermediate steps are collected and, when complete, the future is set with the list of dumped intermediate steps.