如何在Airflow中通过XComs将参数从PythonOperator传递到HttpSensor？

def my_python_function(**context):
    # 从上下文中获取参数
    my_param = context['task_instance'].xcom_pull(task_ids='previous_task_id')

    # 执行任务逻辑
    ...

python_task = PythonOperator(
    task_id='python_task',
    python_callable=my_python_function,
    provide_context=True,
    dag=dag
)

def my_python_function(**context):
    # 推送参数到XComs
    context['task_instance'].xcom_push(key='my_param_key', value='my_param_value')

    # 执行任务逻辑
    ...

python_task = PythonOperator(
    task_id='python_task',
    python_callable=my_python_function,
    provide_context=True,
    dag=dag
)

http_sensor_task = HttpSensor(
    task_id='http_sensor_task',
    http_conn_id='my_http_connection',
    endpoint='/my_endpoint/{{ task_instance.xcom_pull(task_ids="python_task", key="my_param_key") }}',
    dag=dag
)