如何重复sql并将不同的日期传递到我的BigQueryOperator文件

from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.bigquery_operator import BigQueryOperator

# 定义DAG的默认参数
default_args = {
    'owner': 'your_name',
    'start_date': datetime(2022, 1, 1),
    'retries': 3,
    'retry_delay': timedelta(minutes=5)
}

# 定义DAG
dag = DAG(
    'execute_sql_daily',
    default_args=default_args,
    schedule_interval='@daily'
)

# 定义要执行的SQL语句
sql_query = """
SELECT *
FROM your_table
WHERE date = '{{ ds }}'
"""

# 定义日期范围
start_date = datetime(2022, 1, 1)
end_date = datetime(2022, 1, 31)

# 循环创建BigQueryOperator任务
for single_date in (start_date + timedelta(n) for n in range((end_date - start_date).days + 1)):
    task_id = f'execute_sql_{single_date.strftime("%Y%m%d")}'
    formatted_sql_query = sql_query.replace('{{ ds }}', single_date.strftime('%Y-%m-%d'))
    
    # 创建BigQueryOperator任务
    execute_sql_task = BigQueryOperator(
        task_id=task_id,
        sql=formatted_sql_query,
        use_legacy_sql=False,
        dag=dag
    )
    
    # 设置任务依赖关系
    if single_date != start_date:
        execute_sql_task.set_upstream(previous_task)
    
    # 更新前一个任务
    previous_task = execute_sql_task