style: fix black/isort formatting

2026-07-22 13:49:26 +08:00
parent d24caefbca
commit f2dd0862b7
1 changed files with 4 additions and 4 deletions
@@ -77,10 +77,10 @@ def _create_worker_database(worker_id: str) -> str:
        cur = conn.cursor()

        # 先尝试删除（防止残留）
-        cur.execute(f"DROP DATABASE IF EXISTS \"{worker_db}\" WITH (FORCE)")
+        cur.execute(f'DROP DATABASE IF EXISTS "{worker_db}" WITH (FORCE)')

        # 创建新数据库
-        cur.execute(f"CREATE DATABASE \"{worker_db}\"")
+        cur.execute(f'CREATE DATABASE "{worker_db}"')
        cur.close()
        conn.close()
        print(f"[xdist {worker_id}] ✅ 创建数据库: {worker_db}")
@@ -107,8 +107,8 @@ def _create_worker_database(worker_id: str) -> str:
        if str(ROOT) not in sys.path:
            sys.path.insert(0, str(ROOT))

-        from alembic.config import Config as AlembicConfig
        from alembic import command as alembic_command
+        from alembic.config import Config as AlembicConfig

        alembic_cfg = AlembicConfig(str(ROOT / "alembic.ini"))
        alembic_cfg.set_main_option("sqlalchemy.url", new_url)
@@ -153,7 +153,7 @@ def _cleanup_worker_database(worker_id: str):
            f"SELECT pg_terminate_backend(pid) FROM pg_stat_activity "
            f"WHERE datname = '{_WORKER_DB_NAME}' AND pid <> pg_backend_pid()"
        )
-        cur.execute(f"DROP DATABASE IF EXISTS \"{_WORKER_DB_NAME}\" WITH (FORCE)")
+        cur.execute(f'DROP DATABASE IF EXISTS "{_WORKER_DB_NAME}" WITH (FORCE)')
        cur.close()
        conn.close()
        print(f"[xdist {worker_id}] 🧹 已清理数据库: {_WORKER_DB_NAME}")