Noam polak

08/07/2023, 7:20 AM
Hey everyone I have a question 🙂 I have a task that calls an async task :
Copy code
@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] =, 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?