На одном этапе моей DAG Airflow у меня есть DockerOperator, который выполняет некоторые вычисления и создает строку. Эта строка служит входом для других задач в DAG.
Я хочу передать строку другим операторам, используя xcom_push. Тем не менее, код, работающий внутри моего DockerOperator, также выводит различную диагностическую информацию / информацию о журнале в stdout, и я полагаюсь на это в журнале Airflow. Как я могу отделить свой вывод от сообщений журнала и передать только строку вывода следующей задаче?