nemo_flow.utils

Functions

run_sync(coro)

Run coro synchronously, handling the case where an event loop is

Module Contents

nemo_flow.utils.run_sync(coro: Any) → Any

Run coro synchronously, handling the case where an event loop is already running.

When offloading to a ThreadPoolExecutor worker, this helper propagates both Python contextvars and the Rust thread-local scope stack so that NeMo Flow telemetry is preserved on the worker thread.