From 96ae5006fcfdcf84a7e1fa7e30557af93f35e60c Mon Sep 17 00:00:00 2001 From: aries_ckt <916701291@qq.com> Date: Wed, 18 Oct 2023 00:06:23 +0800 Subject: [PATCH] fix:meta_data mysql ddl bug --- pilot/base_modules/meta_data/meta_data.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pilot/base_modules/meta_data/meta_data.py b/pilot/base_modules/meta_data/meta_data.py index e5551da82..11cd29e38 100644 --- a/pilot/base_modules/meta_data/meta_data.py +++ b/pilot/base_modules/meta_data/meta_data.py @@ -7,7 +7,7 @@ import fnmatch from datetime import datetime from typing import Optional, Type, TypeVar -from sqlalchemy import create_engine, DateTime, String, func, MetaData +from sqlalchemy import create_engine, DateTime, String, func, MetaData, DDL from sqlalchemy.exc import OperationalError from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.orm import Mapped @@ -47,7 +47,7 @@ if CFG.LOCAL_DB_TYPE == "mysql": try: # try to connect with engine_temp.connect() as conn: - conn.execute(f"CREATE DATABASE IF NOT EXISTS {db_name}") + conn.execute(DDL(f"CREATE DATABASE IF NOT EXISTS {db_name}")) print(f"Already connect '{db_name}'") except OperationalError as e: