is there a way to use epression on async methods like: async def enrich_inputs(a): return a*2 a = await Seq.of(graph_connections).pipe( seq.map(enrich_inputs), )