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