Noam polak
08/07/2023, 7:20 AM@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?