如何在气流DAG中并行化相似但参数不同的BashOperator任务

from airflow.operators.bash_operator import BashOperator

template_task = BashOperator(
    task_id='template_task',
    bash_command='echo {{ params.message }}',
    params={'message': ''}
)

from airflow import DAG
from datetime import datetime

dag = DAG(
    'parallel_bash_tasks',
    start_date=datetime(2022, 1, 1),
    schedule_interval=None
)

tasks = [
    {'task_id': 'task1', 'params': {'message': 'Task 1 executed.'}},
    {'task_id': 'task2', 'params': {'message': 'Task 2 executed.'}},
    {'task_id': 'task3', 'params': {'message': 'Task 3 executed.'}}
]

for task in tasks:
    task_instance = template_task.copy()
    task_instance.task_id = task['task_id']
    task_instance.params = task['params']
    task_instance.dag = dag

    task_instance.set_upstream(template_task)