如何在气流重试期间保持一个值

Question

每次dag触发任务时我都想生成一个值并在重试期间保留该值（如果任务因任何原因无法运行）

我尝试在dag中声明一个变量（基本上将当前时间设置为变量）当任务失败并重试时，它再次使用最新时间设置变量

Answer 1

• 你可以利用on_failure_callback and on_retry_callback params的BaseOperator来推动你想要坚持的价值，因为xcom
• 此后，你可以在你的retrieve that data from Xcom部署的任何task的任何DAG Airflow，包括相同/不同的task的重试尝试

---

另外看看

• Can a failed Airflow DAG Task Retry with changed parameter
• Airflow Task failure/retry workflow