feat: fix type

Author: meomeocoj

duckdb_engine/__init__.py

@@ -1,5 +1,6 @@
 import re
 import warnings
+from collections.abc import Hashable
 from functools import lru_cache
 from typing import (
     TYPE_CHECKING,
@@ -175,6 +176,26 @@ def fetchmany(self, size: Optional[int] = None) -> List:
         else:
             return self.__c.fetchmany(size)
 
+    @property
+    def description(self) -> Optional[List[Tuple[Any, ...]]]:
+        description = self.__c.description
+        if description is None:
+            return None
+
+        sanitized: List[Tuple[Any, ...]] = []
+        for row in description:
+            if len(row) <= 1:
+                sanitized.append(tuple(row))
+                continue
+
+            type_code = row[1]
+            if isinstance(type_code, Hashable):
+                sanitized.append(tuple(row))
+            else:
+                sanitized.append((row[0], str(type_code), *row[2:]))
+
+        return sanitized
+
 
 class DuckDBEngineWarning(Warning):
     pass
@@ -283,6 +304,7 @@ def type_descriptor(self, typeobj: Type[sqltypes.TypeEngine]) -> Any:  # type: i
         return res
 
     def connect(self, *cargs: Any, **cparams: Any) -> "Connection":
+        print("duckdb version:", duckdb_version)
         core_keys = get_core_config()
         preload_extensions = cparams.pop("preload_extensions", [])
         config = dict(cparams.get("config", {}))
@@ -409,7 +431,7 @@ def get_schema_names(self, connection: "Connection", **kw: "Any"):  # type: igno
         s = """
             SELECT database_name, schema_name AS nspname
             FROM duckdb_schemas()
-            WHERE schema_name NOT LIKE 'pg\_%' ESCAPE '\'
+            WHERE schema_name NOT LIKE 'pg\\_%' ESCAPE '\\'
             ORDER BY database_name, nspname
             """
         rs = connection.execute(text(s))

duckdb_engine/tests/test_ducklake.py

@@ -192,38 +192,21 @@ def readonly_ducklake_engine(temp_dir: Path) -> Engine:
     )
     return readonly_engine
 
-@pytest.fixture
-def postgres(temp_dir: Path) -> Engine:
+def test_postgres(temp_dir: Path) -> Engine:
     data_path = temp_dir / "data"
     data_path.mkdir()
     registry.register("duckdb", "duckdb_engine", "Dialect")
-    catalog_path = temp_dir / "test_catalog.ducklake"
 
     # First create some test data with a writable connection
-    writable_engine = create_engine(
-        f"ducklake:postgres:dbname=ducklake user=postgres password=FvTEBiSdLOlo host=15.235.225.242 port=5433",
+    ducklake_engine = create_engine(
+        f"duckdb:///ducklake:postgres:dbname=ducklake user=postgres password=FvTEBiSdLOlo host=15.235.225.242 port=5433",
     )
-    with writable_engine.connect() as conn:
-        conn.execute(
-            text("""
-            CREATE TABLE readonly_test (
-                id INTEGER,
-                name VARCHAR
-            )
-        """)
-        )
-        conn.execute(text("INSERT INTO readonly_test VALUES (1, 'existing_data')"))
+    with ducklake_engine.connect() as conn:
+        inspector = inspect(ducklake_engine)
+        schemas = inspector.get_schema_names()
+        print(f"Schemas: {schemas}")
 
-    # Return readonly engine
-    readonly_engine = create_engine(
-        f"duckdb:///ducklake:{catalog_path}",
-        connect_args={
-            "data_path": str(data_path),
-            "alias": "test_readonly",
-            "read_only": True,
-        },
-    )
-    return readonly_engine
+    return ducklake_engine
 
 
 def test_ducklake_readonly_prevents_writes(readonly_ducklake_engine: Engine) -> None: