Skip to content

get_pipe

faststream.redis.annotations.get_pipe async #

get_pipe(
    redis: Redis,
) -> AsyncGenerator[RedisPipeline, None]
Source code in faststream/redis/annotations.py 
51
52
53
async def get_pipe(redis: Redis) -> AsyncGenerator[RedisPipeline, None]:
    async with redis.pipeline() as pipe:
        yield pipe  # ruff: ignore[yield-in-context-manager-in-async-generator]