aiq.front_ends.fastapi.intermediate_steps_subscriber#
Attributes#
Functions#
|
Subscribes to the runner's event stream (which is now a simplified Observable) |
Module Contents#
- logger#
- async pull_intermediate(_q, adapter)#
Subscribes to the runner’s event stream (which is now a simplified Observable) using direct callbacks. Processes each event with the adapter and enqueues results to
_q.