在Airflow上使用PythonOperator时，如何使用Python函数的返回值/

def my_function():
    # 执行一些计算
    result = 10 + 5
    return result

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

def my_function():
    # 执行一些计算
    result = 10 + 5
    return result

default_args = {
    'start_date': datetime(2022, 1, 1),
    'retries': 3,
    'retry_delay': timedelta(minutes=5),
}

with DAG('my_dag', default_args=default_args, schedule_interval='@daily') as dag:
    task = PythonOperator(
        task_id='my_task',
        python_callable=my_function,
        provide_context=True,
        dag=dag
    )

    result = task.execute(context={})

def my_other_function(result):
    # 使用result变量进行其他操作
    print(result)

with DAG('my_dag', default_args=default_args, schedule_interval='@daily') as dag:
    task = PythonOperator(
        task_id='my_task',
        python_callable=my_function,
        provide_context=True,
        dag=dag
    )

    result = task.execute(context={})

    other_task = PythonOperator(
        task_id='my_other_task',
        python_callable=my_other_function,
        op_kwargs={'result': result},
        dag=dag
    )