Nick DeCraene
@task(name="extract(ctx.id)") def extract(ctx):
extract(4)
Mason Menges
@flow(name="test") async def test_flow(some_obj): ta = await taskA.with_options(name=some_obj)(some_obj=some_obj)
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.