Triggering backfills from Airflow UI always returns 409 Conflict #57125
Description
Apache Airflow version
Other Airflow 2/3 version (please specify below)
If "Other Airflow 2/3 version" selected, which one?
3.0.6
What happened?
What you think should happen instead?
No response
How to reproduce
I'm not sure how he plans to reproduce it, but I think it might be related to the fact that I'm using a self-hosted database.
I chose Percona XtraDB Cluster as my Airflow database.
Operating System
Debian GNU/Linux 12 (bookworm)
Versions of Apache Airflow Providers
apache/airflow:3.0.6-python3.12
Deployment
Official Apache Airflow Helm Chart
Deployment details
No response
Anything else?
api-server File "/home/airflow/.local/lib/python3.12/site-packages/anyio/to_thread.py", line 56, in run_sync
api-server return await get_async_backend().run_sync_in_worker_thread(
api-server ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py", line 2476, in run_sync_in_worker_thread
api-server return await future
api-server ^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py", line 967, in run
api-server result = context.run(func, *args)
api-server ^^^^^^^^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/airflow/api_fastapi/core_api/routes/public/backfills.py", line 227, in create_backfill
api-server backfill_obj = _create_backfill(
api-server ^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/airflow/models/backfill.py", line 488, in _create_backfill
api-server _create_backfill_dag_run(
api-server File "/home/airflow/.local/lib/python3.12/site-packages/airflow/models/backfill.py", line 285, in _create_backfill_dag_run
api-server with session.begin_nested() as nested:
api-server ^^^^^^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/util.py", line 235, in __exit__
api-server with util.safe_reraise():
api-server ^^^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/util/langhelpers.py", line 70, in __exit__
api-server compat.raise_(
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/util/compat.py", line 211, in raise_
api-server raise exception
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/util.py", line 233, in __exit__
api-server self.commit()
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", line 839, in commit
api-server trans.commit()
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 2469, in commit
api-server self._do_commit()
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 2774, in _do_commit
api-server self.connection._release_savepoint_impl(self._savepoint)
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1127, in _release_savepoint_impl
api-server self.engine.dialect.do_release_savepoint(self, name)
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/default.py", line 730, in do_release_savepoint
api-server connection.execute(expression.ReleaseSavepointClause(name))
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/future/engine.py", line 286, in execute
api-server return self._execute_20(
api-server ^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1710, in _execute_20
api-server return meth(self, args_10style, kwargs_10style, execution_options)
api-server ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/sql/elements.py", line 334, in _execute_on_connection
api-server return connection._execute_clauseelement(
api-server ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1577, in _execute_clauseelement
api-server ret = self._execute_context(
api-server ^^^^^^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1953, in _execute_context
api-server self._handle_dbapi_exception(
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 2134, in _handle_dbapi_exception
api-server File "/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/default.py", line 736, in do_execute
api-server cursor.execute(statement, parameters)
api-server File "/home/airflow/.local/lib/python3.12/site-packages/MySQLdb/cursors.py", line 179, in execute
api-server res = self._query(mogrified_query)
api-server ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
api-server File "/home/airflow/.local/lib/python3.12/site-packages/MySQLdb/cursors.py", line 330, in _query
api-server db.query(q)
api-server File "/home/airflow/.local/lib/python3.12/site-packages/MySQLdb/connections.py", line 280, in query
api-server _mysql.connection.query(self, query)
api-server sqlalchemy.exc.OperationalError: (MySQLdb.OperationalError) (1305, 'SAVEPOINT sa_savepoint_1 does not exist')
api-server [SQL: RELEASE SAVEPOINT sa_savepoint_1]
api-server (Background on this error at: https://sqlalche.me/e/14/e3q8)
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct