Я очень плохо знаком с потоком воздуха. Мой поток воздуха работает нормально уже много дней. Мне удалось запустить несколько сложных трубопроводов. Недавно что-то случилось, и поток воздуха перестал работать. На самом деле сервер загружается на несколько пидов, и это происходит периодически.
Прилагается ошибка. Когда я запускаю Airflow, ниже повторяется и веб-сервер не запускается. Я уверен, что могу делать что-то глупое, но мне сложно разобраться в проблеме, так как я новичок в воздушном потоке. Версия Airflow 1.8.0. Буду признателен за любую помощь. Спасибо
enter Running the Gunicorn Server with:
Workers: 4 sync
Host: 0.0.0.0:8080
Timeout: 120
Logfiles: - -
=================================================================
[2018-04-30 02:41:53,282] {__init__.py:57} INFO - Using executor SequentialExecutor
[2018-04-30 02:41:53 -0500] [4461] [INFO] Starting gunicorn 19.3.0
[2018-04-30 02:41:53 -0500] [4461] [INFO] Listening at: http://0.0.0.0:8080 (4461)
[2018-04-30 02:41:53 -0500] [4461] [INFO] Using worker: sync
[2018-04-30 02:41:53 -0500] [4464] [INFO] Booting worker with pid: 4464
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
.format(x=modname), ExtDeprecationWarning
[2018-04-30 02:41:53 -0500] [4465] [INFO] Booting worker with pid: 4465
[2018-04-30 02:41:53 -0500] [4466] [INFO] Booting worker with pid: 4466
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
.format(x=modname), ExtDeprecationWarning
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
.format(x=modname), ExtDeprecationWarning
[2018-04-30 02:41:53 -0500] [4467] [INFO] Booting worker with pid: 4467
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
.format(x=modname), ExtDeprecationWarning
[2018-04-30 02:41:53,935] [4464] {models.py:167} INFO - Filling up the DagBag from /Users/sam/All-Program/App/PropertyClassification/dags
[2018-04-30 02:41:54,038] [4465] {models.py:167} INFO - Filling up the DagBag from /Users/sam/All-Program/App/PropertyClassification/dags
[2018-04-30 02:41:54,052] [4466] {models.py:167} INFO - Filling up the DagBag from /Users/sam/All-Program/App/PropertyClassification/dags
[2018-04-30 02:41:54,152] [4467] {models.py:167} INFO - Filling up the DagBag from /Users/sam/All-Program/App/PropertyClassification/dags
2018-04-30 02:41:56.080 python[4464:89245] The application with bundle ID (null) is running setugid(), which is not allowed.
[2018-04-30 02:41:56 -0500] [4480] [INFO] Booting worker with pid: 4480
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
.format(x=modname), ExtDeprecationWarning
2018-04-30 02:41:56.217 python[4465:89249] The application with bundle ID (null) is running setugid(), which is not allowed.
2018-04-30 02:41:56.221 python[4466:89250] The application with bundle ID (null) is running setugid(), which is not allowed.
[2018-04-30 02:41:56 -0500] [4481] [INFO] Booting worker with pid: 4481
[2018-04-30 02:41:56 -0500] [4482] [INFO] Booting worker with pid: 4482
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
.format(x=modname), ExtDeprecationWarning
2018-04-30 02:41:56.323 python[4467:89253] The application with bundle ID (null) is running setugid(), which is not allowed.
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
.format(x=modname), ExtDeprecationWarning
[2018-04-30 02:41:56 -0500] [4483] [INFO] Booting worker with pid: 4483
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
.format(x=modname), ExtDeprecationWarning
[2018-04-30 02:41:56,446] [4480] {models.py:167} INFO - Filling up the DagBag from /Users/sam/All-Program/App/PropertyClassification/dags
[2018-04-30 02:41:56,574] [4481] {models.py:167} INFO - Filling up the DagBag from /Users/sam/All-Program/App/PropertyClassification/dags
[2018-04-30 02:41:56,618] [4482] {models.py:167} INFO - Filling up the DagBag from /Users/sam/All-Program/App/PropertyClassification/dags
[2018-04-30 02:41:56,712] [4483] {models.py:167} INFO - Filling up the DagBag from /Users/sam/All-Program/App/PropertyClassification/dags
2018-04-30 02:41:58.580 python[4480:89485] The application with bundle ID (null) is running setugid(), which is not allowed.
[2018-04-30 02:41:58 -0500] [4498] [INFO] Booting worker with pid: 4498
/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site- packages/flask/exthook.py:71: ExtDeprecationWarning: Importing flask.ext.cache is deprecated, use flask_cache instead.
Я пытался сбросить базу данных "airflow resetdb". Я получаю ошибку ниже:
low/migrations/env.py", line 86, in <module>
run_migrations_online()
File "/Users/sam/App- Setup/anaconda/envs/anaconda35/lib/python3.5/site- packages/airflow/migrations/env.py", line 81, in run_migrations_online
context.run_migrations()
File "<string>", line 8, in run_migrations
File "/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/alembic/runtime/environment.py", line 807, in run_migrations
self.get_context().run_migrations(**kw)
File "/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/alembic/runtime/migration.py", line 321, in run_migrations
step.migration_fn(**kw)
File "/Users/sam/App-Setup/anaconda/envs/anaconda35/lib/python3.5/site-packages/airflow/migrations/versions/cc1e65623dc7_add_max_tries_column_to_task_instance.py", line 53, in upgrade
query = session.query(sa.func.count(TaskInstance.max_tries)).filter(
AttributeError: type object 'TaskInstance' has no attribute 'max_tries'