У меня 6 искровых заданий, которые должны выполняться в порядке и зависят от предыдущего, и седьмое задание, которое должно выполняться независимо от предыдущих заданий. Я установил правило триггера «ALL_DONE» для моей 7-й работы. Это точный сценарий.
Теперь, что говорит требование, т.е. моя 3-я работа провалилась, моя 7-я работа должна знать, что работа провалилась, 3. Теперь я определил функцию в deafult_args как 'on_failure_callback': 'find_failed_job ()', которая проверяет состояние всех заданий с самого начала и возвращает точное имя задания, которое не удалось.
Здесь идут моя проблема, я могу XcomPu sh значение с ключом в качестве «сбой» и значение в качестве «jobName» Теперь, как я могу получить это значение в моей 7-й работе?
В общем, если это было задача, которую я могу вытащить, используя xcom.pull (task_Id, key) .... но здесь это просто определение функции, но не задача, так что я могу дать переменную 'task_Id' в xcom_pull.
Согласно моему требованию клиента, я не должен создавать задачу и вызывать ее. Если бы это было так, у меня было бы решение.
Если быть точным, как мы можем получить переменную, которая была нажата в определении функции.
Быстрая справка очень признателен. Спасибо.