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

[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?