How to set retries at dag level in Airlfow if a task fails?

Question

I want the whole flow to restart if a particular task in a DAG fails. In short, I want retries in DAG level instead of Task level

ozs · Answer

You can set under default_args, retries=N

@dag(
"test",
schedule_interval=None,
default_args={
    "retries": 3,
},
)

def test_dag():

    ...