小编Ant*_*ton的帖子

目前正在致力于为 Airflow 中长时间运行的任务设置警报。为了取消/使气流 dag 失败，我在 default_args 中放入了“dagrun_timeout”，它执行了我需要的操作，当 dag 运行时间过长（通常被卡住）时，它会失败/出错。唯一的问题是，当超过 dagrun_timeout 时，“on_failure_callback”中的函数不会被调用，因为“on_failure_callback”位于任务级别（我认为），而 dagrun_timeout 位于 dag 级别。

当超过 dagrun_timeout 时，如何执行“on_failure_callback”，或者如何指定 dag 失败时要调用的函数？或者我应该重新考虑我的方法？

我可以通过将值列表传递给 draw_network 函数来动态更改节点大小或节点颜色。但是我怎样才能用 ArrowStyle 做到这一点？假设我想根据值列表更改 ArrowStyle（宽度和长度）。除了单个 int 值外，箭头大小也不接受任何其他内容。

这是一个示例代码：

import matplotlib.patches
import networkx as nx
G = nx.DiGraph()
G.add_edge("reddit", "youtube")
G.add_edge("reddit", "google")
G.add_edge("google", "reddit")
G.add_edge("youtube", "reddit")
print(G.adj)

testArrow = matplotlib.patches.ArrowStyle.Fancy(head_length=.4, head_width=.4, tail_width=.1)


nx.draw_networkx(G,
             arrowsize=30,
             node_size=[5000,50,300],
             arrowstyle=testArrow)