nemo_curator.stages.text.experimental.translation.utils.async_utils

Small async helpers shared by translation stages.

Module Contents

Functions

Name	Description
`run_async_safe`	Run a coroutine from sync code, even if a loop is already active.

Data

_T

API

nemo_curator.stages.text.experimental.translation.utils.async_utils.run_async_safe(
    coro_fn: collections.abc.Callable[[], collections.abc.Coroutine[object, object, nemo_curator.stages.text.experimental.translation.utils.async_utils._T]]
) -> nemo_curator.stages.text.experimental.translation.utils.async_utils._T

Run a coroutine from sync code, even if a loop is already active.

nemo_curator.stages.text.experimental.translation.utils.async_utils._T = TypeVar('_T')