如何通过模板将列表传递给airflow？

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime

def process_list(list_variable):
    for item in list_variable:
        # 执行需要对列表中的每个元素进行的操作
        print(item)

def define_dag():
    default_args = {
        'start_date': datetime(2022, 1, 1)
    }

    dag = DAG(
        'example_dag',
        schedule_interval='@daily',
        default_args=default_args
    )

    # 列表模板变量定义
    list_template = ['item1', 'item2', 'item3']

    # 任务定义
    task = PythonOperator(
        task_id='process_list_task',
        python_callable=process_list,
        op_kwargs={'list_variable': list_template},
        templates_dict={'list_variable': list_template},
        dag=dag
    )

    return dag

# 实例化DAG
dag = define_dag()