如何在气流中传递SSHOperator中的动态参数？

from airflow import DAG
from airflow.models import XCom
from airflow.operators.python_operator import PythonOperator

def generate_dynamic_param(**context):
    dynamic_param = "your_dynamic_param"
    context['ti'].xcom_push(key='dynamic_param', value=dynamic_param)

with DAG('your_dag', ...) as dag:
    task_generate_dynamic_param = PythonOperator(
        task_id='generate_dynamic_param',
        python_callable=generate_dynamic_param,
        provide_context=True
    )

from airflow import DAG
from airflow.operators.ssh_operator import SSHOperator

with DAG('your_dag', ...) as dag:
    task_execute_ssh = SSHOperator(
        task_id='execute_ssh',
        command='your_command {{ ti.xcom_pull(key="dynamic_param") }}',
        ssh_conn_id='your_ssh_conn_id'
    )