Apache Airflow: перезапуск для задач с параметрами даты

Question

У меня есть почасовой сценарий, который принимает в качестве входных параметров дату и час.Дата и час используются для построения входного пути для выборки данных для логики, содержащейся в DAG задания.Когда задание не выполняется, и мне нужно его повторно запустить (нажав «Очистить» для сбойного узла задачи, чтобы очистить состояние для повторного запуска нового запуска), как я могу убедиться, что дата и час, использованные для повторного запуска, совпадаюткак неудавшийся прогон, поскольку повторный запуск может произойти в другой час, чем исходный прогон?

Answer 1

У вас есть 3 варианта:

• При наведении на невыполненную задачу, которая будет очищаться, в ее отображаемом теге будет значение с ключом Run:, это дата и время выполнения..
• Нажмите на невыполненную задачу, которая будет очищена, заголовок ее всплывающего окна с опцией очистки будет [taskname] on [executiondatewithtime]
• Открыть журнал задач, первая строка после попытокв счет будет включена строка в формате Executing <Task([TaskName]): task_id> on [ExecutionDate withTime]