Я запускаю поток воздуха в virtualenv как пользователь_A с LocalExecutor .Когда я использую run_as_user в качестве User_B (я добавил, я получил следующее сообщение:
[2019-01-31 21: 00: 40,323] {base_task_runner.py:118} INFO - Выполняется: ['bash', '-c', 'sudo -E -H -u запуск потока hdfs ci_order_renew ci_import_ci_hive 2019-01-30T01: 05: 00 + 08: 00 --job_id 990 --raw -sd DAGS_FOLDER / ci_order_renew.py --cfg_path /tmp / tmp_im7r2fe ']
[2019-01-31 21: 00: 40,759] {base_task_runner.py:101} INFO - задание 990: подзадача ci_import_ci_hive [2019-01-31 21: 00: 40,758] { init .py: 51} ИНФОРМАЦИЯ - Использование executor SequentialExecutor
Кажется, что run_as_user берет другой файл cfg, чем AIRFLOW_HOME / airflow.cfg. После Google немного. Я нашелчто-то связанное с этим.
https://github.com/apache/airflow/pull/4050/commits/c3dc3b4f8610d852f99cdae9a5614025de279c46
Есть ли способ избежать этой проблемы? Спасибо.