如何在Airflow Dag脚本中捕获Python类的返回值？

class MyClass:
    def get_value(self):
        return "Hello, World!"

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

# 导入自定义类
from my_module import MyClass

# 实例化对象
my_object = MyClass()

# 定义Dag
dag = DAG('my_dag', start_date=datetime(2022, 1, 1), schedule_interval='@daily')

def capture_return_value():
    return_value = my_object.get_value()
    print(return_value)

task = PythonOperator(
    task_id='capture_return_value_task',
    python_callable=capture_return_value,
    dag=dag
)

task