3 ms·
@task.python(task_id="this_is_my_task_name") def my_func(): ...
by flowair 4y ago
@task.python(task_id="this_is_my_task_name")
def my_func():
...
- mywittyname 4y agoThis 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, ...
- flowair 4y agoHow about the dynamic task mapping that is now available in 2.3?