我正在尝试使用 Airflow 实现基本的 ETL 作业,但有一点:
我有3个功能。我想为每个变量定义全局变量,例如:
function a():
return a_result
function b():
use a
return b_result
function c():
use a and b
Run Code Online (Sandbox Code Playgroud)
然后在python_callable.
像往常一样定义global a_result是行不通的。任何解决方案?
global-variables airflow airflow-scheduler apache-airflow-xcom