Subdag in Taskflow API

[Ning Shi]

Hi,

The Taskflow API allows passing values between tasks simply by using
the return value of a task function as the parameter to another task
function. Is it possible to pass value from a subdag to a task
function? Please see the pseudo code below for what I am thinking
about.

@dag(...)
def parent_dag():
    @task()
    def post_process(var):
        pass

    subdag = SubDagOperator(
        task_id="my_subdag",
        subdag=create_subdag(...)
    )

    # Is this possible?
    post_process(subdag.output)


Thanks,

Ning