From 21e86105c26b9e0b6c3db1fc864d75a67176fbd1 Mon Sep 17 00:00:00 2001
From: Guen Prawiroatmodjo <guen@motherduck.com>
Date: Tue, 19 Nov 2024 10:14:38 -0800
Subject: [PATCH] use MOTHERDUCK_SCHEME

---
 src/bytewax/duckdb/__init__.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/bytewax/duckdb/__init__.py b/src/bytewax/duckdb/__init__.py
index b01d1cb..ab137fe 100644
--- 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"