amoskueez commented on issue #59184:
URL: https://github.com/apache/airflow/issues/59184#issuecomment-3889032663

   we are working on 3.1.7 
   still broken 
   
   ```
   2026-02-12T06:59:31.617883Z [error    ] Exception on /login/ [GET]     
[airflow.providers.fab.www.app] loc=app.py:1744
   Traceback (most recent call last):
     File "/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", 
line 2529, in wsgi_app
       response = self.full_dispatch_request()
                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File "/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", 
line 1825, in full_dispatch_request
       rv = self.handle_user_exception(e)
            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File "/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", 
line 1821, in full_dispatch_request
       rv = self.preprocess_request()
            ^^^^^^^^^^^^^^^^^^^^^^^^^
     File "/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", 
line 2313, in preprocess_request
       rv = self.ensure_sync(before_func)()
            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/www/security_manager.py",
 line 57, in before_request
       g.user = get_auth_manager().get_user()
                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/auth_manager/fab_auth_manager.py",
 line 280, in get_user
       if current_user.is_anonymous and getattr(g, "user", None) is not None 
and not g.user.is_anonymous:
          ^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/werkzeug/local.py", line 
316, in __get__
       obj = instance._get_current_object()
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/werkzeug/local.py", line 
520, in _get_current_object
       return get_name(local())  # type: ignore
                       ^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/utils.py", line 
25, in <lambda>
       current_user = LocalProxy(lambda: _get_user())
                                         ^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/utils.py", line 
370, in _get_user
       current_app.login_manager._load_user()
     File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/login_manager.py",
 line 364, in _load_user
       user = self._user_callback(user_id)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/auth_manager/security_manager/override.py",
 line 1396, in load_user
       user = self.get_user_by_id(int(pk))
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/auth_manager/security_manager/override.py",
 line 1402, in get_user_by_id
       return self.session.get(self.user_model, pk)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 3680, in get
       return self._get_impl(
              ^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 3859, in _get_impl
       return db_load_fn(
              ^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/loading.py", 
line 695, in load_on_pk_identity
       session.execute(
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 2351, in execute
       return self._execute_internal(
              ^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 2249, in _execute_internal
       result: Result[Any] = compile_state_cls.orm_execute_statement(
                             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/context.py", 
line 306, in orm_execute_statement
       result = conn.execute(
                ^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1419, in execute
       return meth(
              ^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/sql/elements.py", 
line 527, in _execute_on_connection
       return connection._execute_clauseelement(
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1641, in _execute_clauseelement
       ret = self._execute_context(
             ^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1813, in _execute_context
       conn = self._revalidate_connection()
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 673, in _revalidate_connection
       self._invalid_transaction()
     File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 663, in _invalid_transaction
       raise exc.PendingRollbackError(
   sqlalchemy.exc.PendingRollbackError: Can't reconnect until invalid 
transaction is rolled back.  Please rollback() fully before proceeding 
(Background on this error at: https://sqlalche.me/e/20/8s2b)
   INFO:     10.244.12.26:34150 - "GET 
/auth/login/?next=https://airflow.stage-data.cloud.kueez.net/ HTTP/1.1" 500 
Internal Server Error
   ERROR:    Exception in ASGI application
     + Exception Group Traceback (most recent call last):
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/uvicorn/protocols/http/httptools_impl.py",
 line 409, in run_asgi
     |     result = await app(  # type: ignore[func-returns-value]
     |              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/fastapi/applications.py", 
line 1082, in __call__
     |     await super().__call__(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/applications.py", 
line 113, in __call__
     |     await self.middleware_stack(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/errors.py",
 line 186, in __call__
     |     raise exc
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/errors.py",
 line 164, in __call__
     |     await self.app(scope, receive, _send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/gzip.py",
 line 29, in __call__
     |     await responder(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/gzip.py",
 line 130, in __call__
     |     await super().__call__(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/gzip.py",
 line 46, in __call__
     |     await self.app(scope, receive, self.send_with_compression)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/cors.py",
 line 85, in __call__
     |     await self.app(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/base.py",
 line 189, in __call__
     |     raise app_exc
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/base.py",
 line 144, in coro
     |     await self.app(scope, receive_or_disconnect, send_no_error)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/exceptions.py",
 line 63, in __call__
     |     await wrap_app_handling_exceptions(self.app, conn)(scope, receive, 
send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/_exception_handler.py",
 line 53, in wrapped_app
     |     raise exc
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/_exception_handler.py",
 line 42, in wrapped_app
     |     await app(scope, receive, sender)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/routing.py", line 
716, in __call__
     |     await self.middleware_stack(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/routing.py", line 
736, in app
     |     await route.handle(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/routing.py", line 
462, in handle
     |     await self.app(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/fastapi/applications.py", 
line 1082, in __call__
     |     await super().__call__(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/applications.py", 
line 113, in __call__
     |     await self.middleware_stack(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/errors.py",
 line 186, in __call__
     |     raise exc
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/errors.py",
 line 164, in __call__
     |     await self.app(scope, receive, _send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/exceptions.py",
 line 63, in __call__
     |     await wrap_app_handling_exceptions(self.app, conn)(scope, receive, 
send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/_exception_handler.py",
 line 53, in wrapped_app
     |     raise exc
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/_exception_handler.py",
 line 42, in wrapped_app
     |     await app(scope, receive, sender)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/routing.py", line 
716, in __call__
     |     await self.middleware_stack(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/routing.py", line 
736, in app
     |     await route.handle(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/routing.py", line 
462, in handle
     |     await self.app(scope, receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/wsgi.py",
 line 81, in __call__
     |     await responder(receive, send)
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/wsgi.py",
 line 106, in __call__
     |     async with anyio.create_task_group() as task_group:
     |                ^^^^^^^^^^^^^^^^^^^^^^^^^
     |   File 
"/home/airflow/.local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py",
 line 783, in __aexit__
     |     raise BaseExceptionGroup(
     | ExceptionGroup: unhandled errors in a TaskGroup (1 sub-exception)
     +-+---------------- 1 ----------------
       | Traceback (most recent call last):
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", line 2529, in 
wsgi_app
       |     response = self.full_dispatch_request()
       |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", line 1825, in 
full_dispatch_request
       |     rv = self.handle_user_exception(e)
       |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", line 1821, in 
full_dispatch_request
       |     rv = self.preprocess_request()
       |          ^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", line 2313, in 
preprocess_request
       |     rv = self.ensure_sync(before_func)()
       |          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/www/security_manager.py",
 line 57, in before_request
       |     g.user = get_auth_manager().get_user()
       |              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/auth_manager/fab_auth_manager.py",
 line 280, in get_user
       |     if current_user.is_anonymous and getattr(g, "user", None) is not 
None and not g.user.is_anonymous:
       |        ^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/werkzeug/local.py", line 
316, in __get__
       |     obj = instance._get_current_object()
       |           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/werkzeug/local.py", line 
520, in _get_current_object
       |     return get_name(local())  # type: ignore
       |                     ^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/utils.py", line 
25, in <lambda>
       |     current_user = LocalProxy(lambda: _get_user())
       |                                       ^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/utils.py", line 
370, in _get_user
       |     current_app.login_manager._load_user()
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/login_manager.py",
 line 364, in _load_user
       |     user = self._user_callback(user_id)
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/auth_manager/security_manager/override.py",
 line 1396, in load_user
       |     user = self.get_user_by_id(int(pk))
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/auth_manager/security_manager/override.py",
 line 1402, in get_user_by_id
       |     return self.session.get(self.user_model, pk)
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 3680, in get
       |     return self._get_impl(
       |            ^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 3859, in _get_impl
       |     return db_load_fn(
       |            ^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/loading.py", 
line 695, in load_on_pk_identity
       |     session.execute(
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 2351, in execute
       |     return self._execute_internal(
       |            ^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 2249, in _execute_internal
       |     result: Result[Any] = compile_state_cls.orm_execute_statement(
       |                           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/context.py", 
line 306, in orm_execute_statement
       |     result = conn.execute(
       |              ^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1419, in execute
       |     return meth(
       |            ^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/sql/elements.py", 
line 527, in _execute_on_connection
       |     return connection._execute_clauseelement(
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1641, in _execute_clauseelement
       |     ret = self._execute_context(
       |           ^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1813, in _execute_context
       |     conn = self._revalidate_connection()
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 673, in _revalidate_connection
       |     self._invalid_transaction()
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 663, in _invalid_transaction
       |     raise exc.PendingRollbackError(
       | sqlalchemy.exc.PendingRollbackError: Can't reconnect until invalid 
transaction is rolled back.  Please rollback() fully before proceeding 
(Background on this error at: https://sqlalche.me/e/20/8s2b)
       |
       | During handling of the above exception, another exception occurred:
       |
       | Traceback (most recent call last):
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/wsgi.py",
 line 109, in __call__
       |     await anyio.to_thread.run_sync(self.wsgi, environ, 
self.start_response)
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/anyio/to_thread.py", line 
61, in run_sync
       |     return await get_async_backend().run_sync_in_worker_thread(
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py",
 line 2525, in run_sync_in_worker_thread
       |     return await future
       |            ^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/anyio/_backends/_asyncio.py",
 line 986, in run
       |     result = context.run(func, *args)
       |              ^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/starlette/middleware/wsgi.py",
 line 147, in wsgi
       |     for chunk in self.app(environ, start_response):
       |                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", line 2552, in 
__call__
       |     return self.wsgi_app(environ, start_response)
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/werkzeug/middleware/proxy_fix.py",
 line 187, in __call__
       |     return self.app(environ, start_response)
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", line 2532, in 
wsgi_app
       |     response = self.handle_exception(e)
       |                ^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", line 1727, in 
handle_exception
       |     server_error = self.ensure_sync(handler)(server_error)
       |                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/www/views.py",
 line 75, in show_traceback
       |     return render_template("airflow/traceback.html"), 500
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/templating.py", line 
147, in render_template
       |     return _render(app, template, context)
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/templating.py", line 
128, in _render
       |     app.update_template_context(context)
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask/app.py", line 997, in 
update_template_context
       |     context.update(func())
       |                    ^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/utils.py", line 
405, in _user_context_processor
       |     return dict(current_user=_get_user())
       |                              ^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/utils.py", line 
370, in _get_user
       |     current_app.login_manager._load_user()
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/flask_login/login_manager.py",
 line 364, in _load_user
       |     user = self._user_callback(user_id)
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/auth_manager/security_manager/override.py",
 line 1396, in load_user
       |     user = self.get_user_by_id(int(pk))
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/airflow/providers/fab/auth_manager/security_manager/override.py",
 line 1402, in get_user_by_id
       |     return self.session.get(self.user_model, pk)
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 3680, in get
       |     return self._get_impl(
       |            ^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 3859, in _get_impl
       |     return db_load_fn(
       |            ^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/loading.py", 
line 695, in load_on_pk_identity
       |     session.execute(
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 2351, in execute
       |     return self._execute_internal(
       |            ^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", 
line 2249, in _execute_internal
       |     result: Result[Any] = compile_state_cls.orm_execute_statement(
       |                           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/orm/context.py", 
line 306, in orm_execute_statement
       |     result = conn.execute(
       |              ^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1419, in execute
       |     return meth(
       |            ^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/sql/elements.py", 
line 527, in _execute_on_connection
       |     return connection._execute_clauseelement(
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1641, in _execute_clauseelement
       |     ret = self._execute_context(
       |           ^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 1813, in _execute_context
       |     conn = self._revalidate_connection()
       |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 673, in _revalidate_connection
       |     self._invalid_transaction()
       |   File 
"/home/airflow/.local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", 
line 663, in _invalid_transaction
       |     raise exc.PendingRollbackError(
       | sqlalchemy.exc.PendingRollbackError: Can't reconnect until invalid 
transaction is rolled back.  Please rollback() fully before proceeding 
(Background on this error at: https://sqlalche.me/e/20/8s2b)
       +------------------------------------`


-- 
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]

Reply via email to