octomachinery.utils.asynctools module

Asynchronous tools set.

octomachinery.utils.asynctools.amap(callback, async_iterable)[source]

Map asyncronous generator with a coroutine or a function.

octomachinery.utils.asynctools.dict_to_kwargs_cb(callback)[source]

Return a callback mapping dict to keyword arguments.

async octomachinery.utils.asynctools.try_await(potentially_awaitable)[source]

Try awaiting the arg and return it regardless.