simple constructor for using async functions like pipelines

async_pipeline.py

async def async_pipeline(pipe):
    if isinstance(pipe, tuple):
        for f in pipe:
            await async_pipeline(f)
    elif isinstance(pipe, set):
        await asyncio.gather(*map(async_pipeline, pipe))
    else:
        await pipe