Как присвоить имя control_flow в префекте?

Question

Как назначить name задаче merge в потоке?

thing_three = merge(thing_one, thing_two)

Конечная цель - получить merge, используя flow.get_tasks(name="thing_merger")

Заранее спасибо.

Answer 1

Самый простой способ справиться с этим - использовать:

thing_three = merge(thing_one, thing_two)

thing_three.name = "thing_merger"

Затем, когда вы вызовете flow.get_tasks(name="thing_merger"), он вернет:

[<Task: thing_merger>]