我已经配置了气流，并创建了一些dag和subdag来调用几个操作符。
我的问题是，当操作符运行并完成作业时，我希望以某种python结构接收返回的结果。例如：
文件1.py

...
    ...
    sub_dag_one=SubDagOperator(subdag=subdag_accessHive(
PARENT_DAG_NAME, CHILD_DAG_NAME, default_args, STEP, macros,path,
       ),
        task_id=DELP_DAG_NAME,
        dag=dag,
    )

文件2.py

from airflow import DAG
    from airflow.operators import HiveOperator
def subdag_callHive(parent, child, args, step,
                         user_defined_macros, path
                        ):
        dag_subdag = DAG(
            dag_id='%s.%s' % (parent, child),
            default_args=args,
            schedule_interval="@daily",
            template_searchpath=path,
            user_defined_macros=user_defined_macros,
        )
        # some work...
        HiveOperator(
            task_id='some_id',
            hiveconf_jinja_translate=True,
            hql='select field1 from public.mytable limit 4;',
            trigger_rule='all_done',
            dag=dag_subdag,
        )
        return dag_subdag

函数subdag\u callhive是从另一个python脚本调用的，在该脚本中定义了主dag和所需的所有其他参数。
我只需要能够从hiveoperator（selectfrom public.mytable limit 4；*）获取结果在这种情况下是4个值。
返回的dag\u subdag是一个对象<class'airflow.models.dag'>并包含传递给调用的所有属性/数据，但不包含有关hiveoperator所做操作的信息。
这可能吗？如果是的话，如何才能实现。