| 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