Воздушный поток не обновляет импортированные функции / классы - PullRequest
0 голосов
/ 17 января 2020

У меня есть два python файла:

dag.py:

from utils import my_function

# use my function in some way
...

utils.py:

def my_function(arg1):
   # doing something
   ...

Работает нормально, но если я изменю код в my_function не обновляется в DAG, старый код все еще используется.

Единственный найденный мной способ - переименовать utils в utils_v2 для принудительного обновления, но это не идеально ...

Есть идеи, почему возникла эта проблема и как ее исправить?

Моя версия воздушного потока - 1.10.6, но проблема возникла и в более старых версиях.

...