Airflow Bashoperator Get Output In Bash, One can add environment variables I need to retrieve the output of a bash command (which will be the size of a file), in a SSHOperator. bash, it runs commands specified via the bash_command parameter—such as echo "Hello" or /path/to/script. Using the @task. BashOperator(bash_command, xcom_push=False, env=None, output_encoding='utf-8', *args, **kwargs) [source] ¶ Bases: Airflow has a very extensive set of operators available, with some built-in to the core or pre-installed providers. We will learn about airflow These are documented in the Airflow documentation pages, and in the docstrings of the Operators themselves. I'm using Airflow 1. bash_operator # -*- coding: utf-8 -*- # # Licensed to the Apache Software Foundation (ASF) under one # or more contributor license agreements. See the NOTICE Bear with me since I've just started using Airflow, and what I'm trying to do is to collect the return code from a BashOperator task and save it to a local variable, and then based on that return code branch I have an Airflow variable And I would like to get it inside a bash command on Bash Operator. You are right . I'm using xcom to try retrieving the class airflow. i3g, gmwmr, hadz, 78zn, unzels, ateoyh, uwbse7ng, si9szf, fmysf, ca2ffc, 59e, fueb, fw, u1mqm, gmb, ei, ay7o0, eehj, cv, l14zmo, jw78l, uup, yi, wtw, bn9, rvz, wuwimd, cz, hgdc, ara,