У меня есть сценарий для передачи имен файлов обработки между группами DAG, которые используются для загрузки моих данных. Есть ли функциональность для того же в потоке воздуха? Я надеюсь, что XCOM позволяет только передавать имена файлов между задачами в одном DAG.
Я смог реализовать это, используя следующие параметры в операторе.
python_callable = conditionally_trigger, params = {"condition_param": True, "message": "filename"},