Wie rufe ich Helferfunktionen von Task.external_Python in Dag ohne festgelegte SYS.Path jedes Mal auf?
Posted: 12 Feb 2025, 06:37
Ich habe eine Helferfunktion, die in jeder Aufgabe in die Init -Umgebung ausgeführt werden muss. Daher muss ich dem Beginn jeder Aufgabe den gleichen Code hinzufügen, wie: < /p>
Gibt es eine Möglichkeit, es sauberer und anmutiger zu machen?
Code: Select all
@task.external_python(
python=v_python_path,
retries=3,
)
def init_env():
### this part have to be added for every task
import sys
sys.path.append("/opt/airflow/dags")
####
from my_module import my_function