Jarek Potiuk created AIRFLOW-7042:
-------------------------------------
Summary: Example causes migration scripts to show errors
Key: AIRFLOW-7042
URL: https://issues.apache.org/jira/browse/AIRFLOW-7042
Project: Apache Airflow
Issue Type: Bug
Components: database
Affects Versions: 1.10.9
Reporter: Jarek Potiuk
When trying to install fresh db you get this (harmless) error by default (with
load_defaults=True).
This should be fixed as it is misleading for the users.
INFO [alembic.runtime.migration] Running upgrade 127d2bf2dfa7 -> cc1e65623dc7,
add max tries column to task instance
ERROR [airflow.models.dagbag.DagBag] Failed to import:
/usr/local/lib/python3.6/site-packages/airflow/example_dags/example_subdag_operator.py
Traceback (most recent call last):
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line
1246, in _execute_context
cursor, statement, parameters, context
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/default.py",
line 588, in do_execute
cursor.execute(statement, parameters)
psycopg2.errors.UndefinedTable: relation "slot_pool" does not exist
LINE 2: FROM slot_pool
^
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/usr/local/lib/python3.6/site-packages/airflow/models/dagbag.py", line
204, in process_file
m = imp.load_source(mod_name, filepath)
File "/usr/local/lib/python3.6/imp.py", line 172, in load_source
module = _load(spec)
File "<frozen importlib._bootstrap>", line 684, in _load
File "<frozen importlib._bootstrap>", line 665, in _load_unlocked
File "<frozen importlib._bootstrap_external>", line 678, in exec_module
File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
File
"/usr/local/lib/python3.6/site-packages/airflow/example_dags/example_subdag_operator.py",
line 47, in <module>
dag=dag,
File "/usr/local/lib/python3.6/site-packages/airflow/utils/db.py", line 74, in
wrapper
return func(*args, **kwargs)
File "/usr/local/lib/python3.6/site-packages/airflow/utils/decorators.py",
line 98, in wrapper
result = func(*args, **kwargs)
File
"/usr/local/lib/python3.6/site-packages/airflow/operators/subdag_operator.py",
line 77, in __init__
.filter(Pool.pool == self.pool)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/query.py", line
3287, in first
ret = list(self[0:1])
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/query.py", line
3065, in __getitem__
return list(res)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/query.py", line
3389, in __iter__
return self._execute_and_instances(context)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/query.py", line
3414, in _execute_and_instances
result = conn.execute(querycontext.statement, self._params)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line
982, in execute
return meth(self, multiparams, params)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/sql/elements.py", line
293, in _execute_on_connection
return connection._execute_clauseelement(self, multiparams, params)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line
1101, in _execute_clauseelement
distilled_params,
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line
1250, in _execute_context
e, statement, parameters, cursor, context
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line
1476, in _handle_dbapi_exception
util.raise_from_cause(sqlalchemy_exception, exc_info)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/compat.py", line
398, in raise_from_cause
reraise(type(exception), exception, tb=exc_tb, cause=cause)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/compat.py", line
152, in reraise
raise value.with_traceback(tb)
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line
1246, in _execute_context
cursor, statement, parameters, context
File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/default.py",
line 588, in do_execute
cursor.execute(statement, parameters)
sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedTable) relation
"slot_pool" does not exist
LINE 2: FROM slot_pool
^
[SQL: SELECT slot_pool.id AS slot_pool_id, slot_pool.pool AS slot_pool_pool,
slot_pool.slots AS slot_pool_slots, slot_pool.description AS
slot_pool_description
FROM slot_pool
WHERE slot_pool.slots = %(slots_1)s AND slot_pool.pool = %(pool_1)s
LIMIT %(param_1)s]
[parameters: \{'slots_1': 1, 'pool_1': 'default_pool', 'param_1': 1}]
(Background on this error at: http://sqlalche.me/e/f405)
INFO [alembic.runtime.migration] Running upgrade cc1e65623dc7 -> bdaa763e6c56,
Make xcom value column a large binary
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
