vatsrahul1001 opened a new issue, #55117:
URL: https://github.com/apache/airflow/issues/55117

   ### Apache Airflow version
   
   main (development)
   
   ### If "Other Airflow 2 version" selected, which one?
   
   _No response_
   
   ### What happened?
   
   Downgrade to 2.11.0 is failing when we have data in dag_run_note table
   
   Getting below error with PostgreSQL
   ```
   
   Traceback (most recent call last):
     File "/usr/python/bin/airflow", line 10, in <module>
       sys.exit(main())
     File "/opt/airflow/airflow-core/src/airflow/__main__.py", line 55, in main
       args.func(args)
     File "/opt/airflow/airflow-core/src/airflow/cli/cli_config.py", line 49, 
in command
       return func(*args, **kwargs)
     File "/opt/airflow/airflow-core/src/airflow/utils/cli.py", line 114, in 
wrapper
       return f(*args, **kwargs)
     File 
"/opt/airflow/airflow-core/src/airflow/utils/providers_configuration_loader.py",
 line 54, in wrapped_function
       return func(*args, **kwargs)
     File "/opt/airflow/airflow-core/src/airflow/cli/commands/db_command.py", 
line 214, in downgrade
       run_db_downgrade_command(args, db.downgrade, _REVISION_HEADS_MAP)
     File "/opt/airflow/airflow-core/src/airflow/cli/commands/db_command.py", 
line 189, in run_db_downgrade_command
       command(to_revision=to_revision, from_revision=from_revision, 
show_sql_only=args.show_sql_only)
     File "/opt/airflow/airflow-core/src/airflow/utils/session.py", line 100, 
in wrapper
       return func(*args, session=session, **kwargs)
     File "/opt/airflow/airflow-core/src/airflow/utils/db.py", line 1231, in 
downgrade
       command.downgrade(config, revision=to_revision, sql=show_sql_only)
     File "/usr/python/lib/python3.10/site-packages/alembic/command.py", line 
530, in downgrade
       script.run_env()
     File "/usr/python/lib/python3.10/site-packages/alembic/script/base.py", 
line 549, in run_env
       util.load_python_file(self.dir, "env.py")
     File "/usr/python/lib/python3.10/site-packages/alembic/util/pyfiles.py", 
line 116, in load_python_file
       module = load_module_py(module_id, path)
     File "/usr/python/lib/python3.10/site-packages/alembic/util/pyfiles.py", 
line 136, in load_module_py
       spec.loader.exec_module(module)  # type: ignore
     File "<frozen importlib._bootstrap_external>", line 883, in exec_module
     File "<frozen importlib._bootstrap>", line 241, in 
_call_with_frames_removed
     File "/opt/airflow/airflow-core/src/airflow/migrations/env.py", line 138, 
in <module>
       run_migrations_online()
     File "/opt/airflow/airflow-core/src/airflow/migrations/env.py", line 132, 
in run_migrations_online
       context.run_migrations()
     File "<string>", line 8, in run_migrations
     File 
"/usr/python/lib/python3.10/site-packages/alembic/runtime/environment.py", line 
946, in run_migrations
       self.get_context().run_migrations(**kw)
     File 
"/usr/python/lib/python3.10/site-packages/alembic/runtime/migration.py", line 
627, in run_migrations
       step.migration_fn(**kw)
     File 
"/opt/airflow/airflow-core/src/airflow/migrations/versions/0035_3_0_0_update_user_id_type.py",
 line 49, in downgrade
       with op.batch_alter_table("dag_run_note") as batch_op:
     File "/usr/python/lib/python3.10/contextlib.py", line 142, in __exit__
       next(self.gen)
     File 
"/usr/python/lib/python3.10/site-packages/alembic/operations/base.py", line 
397, in batch_alter_table
       impl.flush()
     File 
"/usr/python/lib/python3.10/site-packages/alembic/operations/batch.py", line 
115, in flush
       fn(*arg, **kw)
     File "/usr/python/lib/python3.10/site-packages/alembic/ddl/postgresql.py", 
line 179, in alter_column
       self._exec(
     File "/usr/python/lib/python3.10/site-packages/alembic/ddl/impl.py", line 
246, in _exec
       return conn.execute(construct, params)
     File 
"/usr/python/lib/python3.10/site-packages/sqlalchemy/future/engine.py", line 
286, in execute
       return self._execute_20(
     File "/usr/python/lib/python3.10/site-packages/sqlalchemy/engine/base.py", 
line 1710, in _execute_20
       return meth(self, args_10style, kwargs_10style, execution_options)
     File "/usr/python/lib/python3.10/site-packages/sqlalchemy/sql/ddl.py", 
line 80, in _execute_on_connection
       return connection._execute_ddl(
     File "/usr/python/lib/python3.10/site-packages/sqlalchemy/engine/base.py", 
line 1477, in _execute_ddl
       ret = self._execute_context(
     File "/usr/python/lib/python3.10/site-packages/sqlalchemy/engine/base.py", 
line 1953, in _execute_context
       self._handle_dbapi_exception(
     File "/usr/python/lib/python3.10/site-packages/sqlalchemy/engine/base.py", 
line 2134, in _handle_dbapi_exception
       util.raise_(
     File "/usr/python/lib/python3.10/site-packages/sqlalchemy/util/compat.py", 
line 211, in raise_
       raise exception
     File "/usr/python/lib/python3.10/site-packages/sqlalchemy/engine/base.py", 
line 1910, in _execute_context
       self.dialect.do_execute(
     File 
"/usr/python/lib/python3.10/site-packages/sqlalchemy/engine/default.py", line 
736, in do_execute
       cursor.execute(statement, parameters)
   sqlalchemy.exc.DataError: (psycopg2.errors.InvalidTextRepresentation) 
invalid input syntax for type integer: "admin"
   
   [SQL: ALTER TABLE dag_run_note ALTER COLUMN user_id TYPE INTEGER USING 
user_id::integer]
   (Background on this error at: https://sqlalche.me/e/14/9h9h)
   root@50fabc84f9e9:/opt/airflow#
   ```
   
   ### What you think should happen instead?
   
   _No response_
   
   ### How to reproduce
   
   1. Make a DAG note in airflow3
   2. Downgrade to 2.11
   
   ### Operating System
   
   linux
   
   ### Versions of Apache Airflow Providers
   
   _No response_
   
   ### Deployment
   
   Official Apache Airflow Helm Chart
   
   ### Deployment details
   
   _No response_
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


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