Hi everyone, I have a question about running

async

tasks.

from prefect import task, Flow

@task
async def extract():
    return [1,2,3]

@task
async def transform(some_list):
    transformed = [x + 1 for x in some_list]
    return transformed

@task
async def load(transformed):
    print('load somewhere')
    
with Flow('async testing') as flow:
    extract_nums = extract()
    transformed = transform(extract_nums)
    load(transformed)

flow.run()

This creates a flow and all, but how do I actually run this flow asynchronously?

In case anyone is reading this in the distant future, read the full discussion regarding this inquiry here.