Dynamically naming mapped tasks in Prefect 2.0

Show and Tell
1

Hello

I have a task in my flow which dynamically spawns children and I want to name them according to the search term they take as an input.

In the Prefect 1.0 this was possible - Templating names | Prefect Docs, but I was wondering if this is possible for Prefect 2.0?

I have tried to implement a solution according to this thread - python - How to dynamically rename a task run based on passed variable from within a Prefect flow for Prefect 2.0? - Stack Overflow but I am getting a strange error:

image

The pipeline itself runs but the overall state becomes failed. Any help on this would be appreciated.

Thanks,
Aniruddha

1 Like
2

Never mind, I was being an idiot. I solved by adding a None to the type hinting when defining the flow:

@flow
def complex_etl_flow() -> None:
3

all good, there are no silly questions! glad you figured it out :raised_hands: