Как вызовать вспомогательные функции из task.external_python в DAG без установленного sys.path каждый раз? ⇐ Python

[Anonymous]

У меня есть вспомогательная функция, необходимая в каждой задаче в среде инициации. Поэтому я должен добавить один и тот же код в начало каждой задачи, например: < /p>

Код: Выделить всё

@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

Есть ли способ сделать его чище и изящным?


Подробнее здесь: https://stackoverflow.com/questions/794 ... set-sys-pa