Настройка воздушного потока с помощью Celery executor с сервером MS SQL в качестве бэкэнда - PullRequest
0 голосов
/ 15 февраля 2020

Я подключаю свой Airflow к серверной части MS SQL. airflow initdb работает нормально.

Однако, когда я делаю airflow resetdb , я получаю следующую ошибку.


INFO  [alembic.runtime.migration] Running upgrade 939bb1e647c8 -> 004c1210f153, increase queue name size limit

INFO  [alembic.runtime.migration] Running upgrade c8ffec048a3b -> a56c9515abdc, Remove dag_stat table

INFO  [alembic.runtime.migration] Running upgrade a56c9515abdc, 004c1210f153, 74effc47d867, b3b105409875 -> 08364691d074, Merge the four heads back together

INFO  [alembic.runtime.migration] Running upgrade 08364691d074 -> fe461863935f, increase_length_for_connection_password

INFO  [alembic.runtime.migration] Running upgrade fe461863935f -> 7939bcff74ba, Add DagTags table

WARNI [airflow.utils.log.logging_mixin.LoggingMixin] empty cryptography key - values will not be stored encrypted.

Exception ignored in: <function _ConnectionRecord.checkout.<locals>.<lambda> at 0x7f657bf272f0>
Traceback (most recent call last):

  File "/home/ops/.pyenv/versions/3.6.10/envs/airflow_env/lib/python3.6/site-packages/sqlalchemy/pool/base.py", line 503, in <lambda>

  File "/home/ops/.pyenv/versions/3.6.10/envs/airflow_env/lib/python3.6/site-packages/sqlalchemy/pool/base.py", line 710, in _finalize_fairy

  File "/home/ops/.pyenv/versions/3.6.10/envs/airflow_env/lib/python3.6/site-packages/sqlalchemy/pool/base.py", line 528, in checkin

  File "/home/ops/.pyenv/versions/3.6.10/envs/airflow_env/lib/python3.6/site-packages/sqlalchemy/pool/base.py", line 387, in _return_conn

  File "/home/ops/.pyenv/versions/3.6.10/envs/airflow_env/lib/python3.6/site-packages/sqlalchemy/pool/impl.py", line 106, in _do_return_conn

TypeError: catching classes that do not inherit from BaseException is not allowed

Может кто-нибудь пожалуйста помочь мне с этим? Я застрял!

...