From 207ba8f7899818372c5aae60f2853982819828e8 Mon Sep 17 00:00:00 2001 From: wendy Date: Mon, 10 Jun 2024 18:14:21 +0800 Subject: [PATCH] fix condition for schema --- defog_utils/utils_db.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/defog_utils/utils_db.py b/defog_utils/utils_db.py index 9425ebb..11882d3 100644 --- a/defog_utils/utils_db.py +++ b/defog_utils/utils_db.py @@ -474,7 +474,7 @@ def parse_md(md_str: str) -> Dict[str, List[Dict[str, str]]]: # split the table_md_str into the header and the columns header, columns_str = table_md_str.split("(", 1) table_name = header.split("CREATE TABLE", 1)[1].strip() - if "." in table_name: + if "." in table_name and not table_name.startswith('"'): schema, table_name = table_name.split(".", 1) else: schema = None