用dag体

result = KubernetesPodOperator(
    task_id=task_id,
    name=task_name,
    cmds=["pipenv", "run", "python3", "myscript.py"],
    env_vars=env_vars,
    image=image # docker image
)

字符串
在myscript.py中，结果将是整数

def myfunction():
    ''' Perform a series of operations '''
    return result

myfunction()

型
出于某种原因，我需要运行myscript.py，它将返回dag所需的结果。使用env_vars，数据将能够从dag脚本传递到myscript.py，但是如何将数据传递回dag脚本呢？PS：我知道xcom可以帮助任务之间的通信，但不确定它是否适用于这种情况