Передайте значение из одной DAG в другую DAG в Apache Airflow

Question

У меня есть сценарий передачи имен файлов обработки между группами DAG, которые используются для загрузки моих данных. Есть ли функциональность для того же в потоке воздуха? Я надеюсь, что XCOM позволяет только передавать имена файлов между задачами в одном DAG.

Answer 1

Я смог реализовать это с помощью приведенных ниже опций в операторе.

python_callable = conditionally_trigger, params = {"condition_param": True, "message": "filename"},