Как повторить задание вверх по течению? - PullRequest
Новая
       0

Как повторить задание вверх по течению?

0 голосов
/ 28 февраля 2020

task a > task b > task c

Если C не удается, я хочу повторить попытку A. Возможно ли это? Есть несколько других билетов, которые включают подпаки, но я хотел бы просто иметь возможность очистить A.

Я надеюсь использовать on_retry_callback в задании C, но я не знаю, как это сделать. вызов задачи A.

Есть еще один вопрос, который делает это в подпадаре, но я не использую подваги.

Я пытаюсь это сделать, но, похоже, он не работает : 

def callback_for_failures(context):
    print("*** retrying ***")
    if context['task'].upstream_list:
        context['task'].upstream_list[0].clear()
...