Hey everyone I have a question 🙂 I have a task that calls an async task :

@prefect.task(max_retries=MAX_RETRIES_FOR_TASKS, retry_delay=timedelta(seconds=RETRY_DELAY_SECONDS))
def do_somejobs(url: str, job_tag: str, bq_env: str):
    ...
    ...
    dataset_paths: dict[str] = asyncio.run(create_dataset(df, job_tag))
    return dataset_paths

but when I try to register the flow with this task - it starts to run the async function - create_dataset during the registration Is that what it is supposed to do?