Hacker News new | ask | show | jobs
by flowair 1495 days ago
@task.python(task_id="this_is_my_task_name")

def my_func():

...

1 comments

This still has the problem that, when you call my_func multiple times in the same dag, the resulting tasks will be labelled, my_func, my_func__1, my_func__2, ...
How about the dynamic task mapping that is now available in 2.3?