Programmiererforum

@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

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