如何在Airflow中的任务功能之外访问xcom_pull？

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.operators.bash_operator import BashOperator
from airflow.utils.dates import days_ago

dag = DAG(
    dag_id='my_dag',
    start_date=days_ago(1),
    schedule_interval=None
)

def my_task(**context):
    # 获取其他任务的数据
    data = context['task_instance'].xcom_pull(task_ids='other_task')
    # 处理数据
    processed_data = process_data(data)
    # 将处理后的数据传递给下一个任务
    context['task_instance'].xcom_push(key='processed_data', value=processed_data)

task1 = PythonOperator(
    task_id='my_task',
    python_callable=my_task,
    provide_context=True,
    dag=dag
)

task2 = BashOperator(
    task_id='other_task',
    bash_command='echo "Hello, Airflow!"',
    xcom_push=True,
    dag=dag
)