[+] update alembic

deps/test-task-2025-06-30-v1/python/online/fxreader/pr34/test_task_2025_06_30_v1/tickers/alembic/env.py

@@ -1,5 +1,9 @@
+import asyncio
+
 from logging.config import fileConfig
 
+from sqlalchemy.ext.asyncio import async_engine_from_config
+
 from sqlalchemy import engine_from_config
 from sqlalchemy import pool
 
@@ -29,62 +33,97 @@ target_metadata = Base.metadata
 # ... etc.
 
 
-def run_migrations_offline() -> None:
+# def run_migrations_offline() -> None:
+#
+#     """Run migrations in 'offline' mode.
+#
+#     This configures the context with just a URL
+#     and not an Engine, though an Engine is acceptable
+#     here as well.  By skipping the Engine creation
+#     we don't even need a DBAPI to be available.
+#
+#     Calls to context.execute() here emit the given string to the
+#     script output.
+#
+#     """
+#     # url = config.get_main_option("sqlalchemy.url")
+#     url = Settings.singleton().db_url
+#
+#     context.configure(
+#         url=url,
+#         target_metadata=target_metadata,
+#         literal_binds=True,
+#         dialect_opts={"paramstyle": "named"},
+#     )
+#
+#     with context.begin_transaction():
+#         context.run_migrations()
+#
 
-    """Run migrations in 'offline' mode.
+# def run_migrations_online() -> None:
+#     """Run migrations in 'online' mode.
+#
+#     In this scenario we need to create an Engine
+#     and associate a connection with the context.
+#
+#     """
+#
+#     url = Settings.singleton().db_url
+#
+#     connectable = engine_from_config(
+#         config.get_section(
+#             config.config_ini_section, {}
+#         ),
+#         prefix="sqlalchemy.",
+#         poolclass=pool.NullPool,
+#         url=url,
+#     )
+#
+#     with connectable.connect() as connection:
+#         context.configure(
+#             connection=connection, target_metadata=target_metadata
+#         )
+#
+#         with context.begin_transaction():
+#             context.run_migrations()
 
-    This configures the context with just a URL
-    and not an Engine, though an Engine is acceptable
-    here as well.  By skipping the Engine creation
-    we don't even need a DBAPI to be available.
 
-    Calls to context.execute() here emit the given string to the
-    script output.
 
-    """
-    # url = config.get_main_option("sqlalchemy.url")
-    url = Settings.singleton().db_url
 
-    context.configure(
-        url=url,
-        target_metadata=target_metadata,
-        literal_binds=True,
-        dialect_opts={"paramstyle": "named"},
-    )
+# if context.is_offline_mode():
+#     run_migrations_offline()
+# else:
+#     run_migrations_online()
+
+def do_run_migrations(connection):
+    context.configure(connection=connection, target_metadata=target_metadata)
 
     with context.begin_transaction():
         context.run_migrations()
 
 
-def run_migrations_online() -> None:
-    """Run migrations in 'online' mode.
-
-    In this scenario we need to create an Engine
+async def run_async_migrations():
+    """In this scenario we need to create an Engine
     and associate a connection with the context.
 
     """
 
     url = Settings.singleton().db_url
 
-    connectable = engine_from_config(
-        config.get_section(
-            config.config_ini_section, {}
-        ),
+    connectable = async_engine_from_config(
+        config.get_section(config.config_ini_section),
         prefix="sqlalchemy.",
         poolclass=pool.NullPool,
         url=url,
     )
 
-    with connectable.connect() as connection:
-        context.configure(
-            connection=connection, target_metadata=target_metadata
-        )
+    async with connectable.connect() as connection:
+        await connection.run_sync(do_run_migrations)
 
-        with context.begin_transaction():
-            context.run_migrations()
+    await connectable.dispose()
 
 
-if context.is_offline_mode():
-    run_migrations_offline()
-else:
-    run_migrations_online()
+def run_migrations_online():
+    """Run migrations in 'online' mode."""
+
+    asyncio.run(run_async_migrations())