airflow- все статьи тега

Как получить значение из Airflow XCom pushed через SSHExecuteOperator

У меня есть следующая DAG с двумя задачами SSHExecuteOperator. Первая задача выполняет хранимую процедуру, которая возвращает параметр. Вторая задача нуждается в этом параметре в качестве входных данных. Не могли бы вы объяснить, как извлечь значение из XCom, нажатого в task1, чтобы использовать его в task2? from airflow import DAG from datetime import datetime, timedelta from airflow.contrib.hooks.ssh_hook import SSHHook from airflow.contrib.operators.ssh_execute_operator import SSHExecuteOpe ...