HomeElementl

initial async solids support

Description

initial async solids support

Summary:
This adds bare minimum support for

@solid
async def function_name(...):

by running async generators to completion close to where we execute the user function.

We convert the async generator to a generator by using (the compat equivalent to) asyncio.run to move the iterator forward each tick until it completes.

Test Plan: basic tests added

Reviewers: dgibson, prha, cdecarolis, sandyryza

Reviewed By: dgibson

Differential Revision: https://dagster.phacility.com/D6017

Details

Provenance
alangenfeldAuthored on Jan 14 2021, 7:02 PM
Reviewer
dgibson
Differential Revision
D6017: initial async solids support
Parents
R1:059255fe3f4a: improve dynamic map & collect api docs
Branches
Unknown
Tags
Unknown