ephraimbuddy commented on issue #34830: URL: https://github.com/apache/airflow/issues/34830#issuecomment-1757758249
> #34072 and #34136 work as expected. > > I also tested a few other PRs: > > * Works as expected: [Add missing audit logs for default flask action: add, edit and delete #34090](https://github.com/apache/airflow/pull/34090) > * Does not work for me: [Fix unfound ab_user table in the CLI session #34120](https://github.com/apache/airflow/pull/34120) (details below) > > Details on #34120 issue (cc @hussein-awala) > Tested both > > * locally with Breeze (Posgres 11, Python 3.8, git rev `c8b25cb3ee` aka `2.7.2rc1` tag) and > * on a test environment (MySQL 5.7, Python 3.9, PyPi package 2.7.2rc1). > > In both cases, for different DAGs, I get the error below. #34656 seems to have broken this for me. > > ``` > [2023-10-11T02:22:36.229+0000] {cli_action_loggers.py:85} DEBUG - Calling callbacks: [] > Traceback (most recent call last): > File "/opt/.pyenv/versions/3.9.8/envs/airflow/bin/airflow", line 8, in <module> > sys.exit(main()) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/airflow/__main__.py", line 60, in main > args.func(args) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/airflow/cli/cli_config.py", line 49, in command > return func(*args, **kwargs) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/airflow/utils/cli.py", line 113, in wrapper > return f(*args, **kwargs) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/airflow/cli/commands/task_command.py", line 634, in task_test > session.delete(ti.dag_run) > File "/opt/.pyenv/versions/3.9.8/lib/python3.9/contextlib.py", line 126, in __exit__ > next(self.gen) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/airflow/utils/session.py", line 37, in create_session > session.commit() > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/session.py", line 1454, in commit > self._transaction.commit(_to_root=self.future) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/session.py", line 832, in commit > self._prepare_impl() > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/session.py", line 811, in _prepare_impl > self.session.flush() > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/session.py", line 3449, in flush > self._flush(objects) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/session.py", line 3589, in _flush > transaction.rollback(_capture_exception=True) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line 70, in __exit__ > compat.raise_( > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/util/compat.py", line 211, in raise_ > raise exception > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/session.py", line 3549, in _flush > flush_context.execute() > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/unitofwork.py", line 456, in execute > rec.execute(self) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/unitofwork.py", line 667, in execute > util.preloaded.orm_persistence.delete_obj( > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/persistence.py", line 330, in delete_obj > table_to_mapper = base_mapper._sorted_tables > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line 1184, in __get__ > obj.__dict__[self.__name__] = result = self.fget(obj) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/mapper.py", line 3386, in _sorted_tables > sorted_ = sql_util.sort_tables( > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/sql/ddl.py", line 1217, in sort_tables > for (t, fkcs) in sort_tables_and_constraints( > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/sql/ddl.py", line 1289, in sort_tables_and_constraints > filtered = filter_fn(fkc) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/sql/ddl.py", line 1207, in _skip_fn > if skip_fn(fk): > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/orm/mapper.py", line 3369, in skip > dep = table_to_mapper.get(fk.column.table) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/util/langhelpers.py", line 1113, in __get__ > obj.__dict__[self.__name__] = result = self.fget(obj) > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/site-packages/sqlalchemy/sql/schema.py", line 2532, in column > return self._resolve_column() > File "/opt/.pyenv/versions/3.9.8/envs/airflow/lib/python3.9/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' > [2023-10-11T02:22:36.234+0000] {settings.py:353} DEBUG - Disposing DB connection pool (PID 5345) > ``` I don't think the failing one should be considered a blocker since no new issue was introduced. cc @dstandish @hussein-awala -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
