brki commented on issue #35994:
URL: https://github.com/apache/airflow/issues/35994#issuecomment-1836128059
I also see that behaviour on 2.7.3.
I don't know if it's related, but now whenever I test a task from the cli,
regardless of whether or not the task finishes successfully, I see this at the
end of the output:
```
sqlalchemy.exc.NoReferencedTableError: Foreign key associated with column
'dag_run_note.user_id' could not find table 'ab_user' with which to generate a
foreign key to target column 'id'
```
<details>
<summary>Click to see complete exception details</summary><p>
```
[2023-12-01T13:19:30.791+0000] {taskinstance.py:1400} INFO - Marking task as
SUCCESS. dag_id=sandbox_test, task_id=recreate_workdir,
execution_date=20231201T131930, start_date=, end_date=20231201T131930
Traceback (most recent call last):
File "/home/airflow/.local/bin/airflow", line 8, in <module>
sys.exit(main())
^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/airflow/__main__.py", line
57, in main
args.func(args)
File
"/home/airflow/.local/lib/python3.11/site-packages/airflow/cli/cli_config.py",
line 49, in command
return func(*args, **kwargs)
^^^^^^^^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/airflow/utils/cli.py", line
114, in wrapper
return f(*args, **kwargs)
^^^^^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/airflow/cli/commands/task_command.py",
line 634, in task_test
with create_session() as session:
File "/usr/local/lib/python3.11/contextlib.py", line 144, in __exit__
next(self.gen)
File
"/home/airflow/.local/lib/python3.11/site-packages/airflow/utils/session.py",
line 39, in create_session
session.commit()
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/session.py",
line 1454, in commit
self._transaction.commit(_to_root=self.future)
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/session.py",
line 832, in commit
self._prepare_impl()
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/session.py",
line 811, in _prepare_impl
self.session.flush()
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/session.py",
line 3449, in flush
self._flush(objects)
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/session.py",
line 3588, in _flush
with util.safe_reraise():
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/util/langhelpers.py",
line 70, in __exit__
compat.raise_(
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/util/compat.py",
line 211, in raise_
raise exception
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/session.py",
line 3549, in _flush
flush_context.execute()
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/unitofwork.py",
line 456, in execute
rec.execute(self)
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/unitofwork.py",
line 667, in execute
util.preloaded.orm_persistence.delete_obj(
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/persistence.py",
line 330, in delete_obj
table_to_mapper = base_mapper._sorted_tables
^^^^^^^^^^^^^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/util/langhelpers.py",
line 1184, in __get__
obj.__dict__[self.__name__] = result = self.fget(obj)
^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/mapper.py",
line 3386, in _sorted_tables
sorted_ = sql_util.sort_tables(
^^^^^^^^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/sql/ddl.py", line
1217, in sort_tables
for (t, fkcs) in sort_tables_and_constraints(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/sql/ddl.py", line
1289, in sort_tables_and_constraints
filtered = filter_fn(fkc)
^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/sql/ddl.py", line
1207, in _skip_fn
if skip_fn(fk):
^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/orm/mapper.py",
line 3369, in skip
dep = table_to_mapper.get(fk.column.table)
^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/util/langhelpers.py",
line 1113, in __get__
obj.__dict__[self.__name__] = result = self.fget(obj)
^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/sql/schema.py",
line 2532, in column
return self._resolve_column()
^^^^^^^^^^^^^^^^^^^^^^
File
"/home/airflow/.local/lib/python3.11/site-packages/sqlalchemy/sql/schema.py",
line 2543, in _resolve_column
raise exc.NoReferencedTableError(
sqlalchemy.exc.NoReferencedTableError: Foreign key associated with column
'dag_run_note.user_id' could not find table 'ab_user' with which to generate a
foreign key to target column 'id'
```
</p></details>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
