Page 1 of 1

Wie rufe ich Helferfunktionen von Task.external_Python in Dag ohne festgelegte SYS.Path jedes Mal auf?

Posted: 12 Feb 2025, 06:37
by Guest
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>

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
Gibt es eine Möglichkeit, es sauberer und anmutiger zu machen?