Airflow DAG自动重启可以通过以下几种方式实现：

1. 使用Airflow的on_failure_callback参数，在DAG定义中设置一个回调函数，在DAG运行失败时自动触发重启。示例代码如下：

from airflow import DAG
from datetime import datetime
from airflow.operators.dummy_operator import DummyOperator

def restart_failed_task(context):
    dag_run = context.get("dag_run")
    task_instance = context.get("task_instance")
    if dag_run and task_instance:
        dag_run.set_state("running")
        task_instance.set_state("queued")

default_args = {
    'owner': 'airflow',
    'start_date': datetime(2021, 1, 1),
    'on_failure_callback': restart_failed_task
}

with DAG('dag_with_restart', default_args=default_args, schedule_interval='@once') as dag:
    task1 = DummyOperator(task_id='task1')
    task2 = DummyOperator(task_id='task2')
    task1 >> task2

在上面的示例中，restart_failed_task函数会在DAG运行失败时被调用，它会将DAG和任务实例的状态设置为"running"和"queued"，从而实现自动重启。

2. 使用Airflow的on_failure_callback参数结合Python的subprocess模块，在DAG运行失败时调用Airflow的命令行接口来重启DAG。示例代码如下：

from airflow import DAG
from datetime import datetime
import subprocess

def restart_failed_dag(context):
    dag_run = context.get("dag_run")
    if dag_run:
        subprocess.call(["airflow", "unpause", dag_run.dag_id])

default_args = {
    'owner': 'airflow',
    'start_date': datetime(2021, 1, 1),
    'on_failure_callback': restart_failed_dag
}

with DAG('dag_with_restart', default_args=default_args, schedule_interval='@once') as dag:
    task1 = DummyOperator(task_id='task1')
    task2 = DummyOperator(task_id='task2')
    task1 >> task2

在上面的示例中，restart_failed_dag函数会在DAG运行失败时被调用，它会调用airflow unpause命令来重启DAG。

以上两种方法可以根据实际需求选择其中一种来实现Airflow DAG的自动重启。