use MOTHERDUCK_SCHEME

bytewax · Nov 19, 2024 · 21e8610 · 21e8610
1 parent 0279f63
commit 21e8610
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/bytewax/duckdb/__init__.py b/src/bytewax/duckdb/__init__.py
@@ -119,7 +119,7 @@ def __init__(
         config = dict(parse_qsl(parsed_db_path.query))
 
         if parsed_db_path.scheme == MOTHERDUCK_SCHEME:
-            path = f"md:{parsed_db_path.path}"
+            path = f"{MOTHERDUCK_SCHEME}:{parsed_db_path.path}"
             if "custom_user_agent" not in config:
                 config["custom_user_agent"] = "bytewax"