Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
def print_airflow_cfg():
with open(f"{os.getenv('AIRFLOW_HOME')}/airflow.cfg", 'r') as airflow_cfg:
file_contents = airflow_cfg.read()
print(f'\n{file_contents}')
get_airflow_cfg_operator = PythonOperator(
task_id='get_airflow_cfg_task',
python_callable=print_airflow_cfg
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment