получить значения sql в потоке воздуха

#python-3.x #airflow Вопрос: необходимо получить значение sql - файлов и почты соответственно.вот мой код воздушного потока audit_phase = BashOperator( task_id='audit_phase', bash_command='python3 /path to db_connection.py /path to sql lowercase.sql' ) dag=dag,…