fix(duckdb): 🐛 Ensure proper closure of DuckDB connection

flowcore-platform · flowcore-platform · commit 5957ac6a60b0 · 2025-03-24T23:06:52.000Z
diff --git a/src/duckdb/index.ts b/src/duckdb/index.ts
@@ -26,6 +26,7 @@ export async function initializeDuckDB(
 
 export async function closeDuckDB() {
   if (db) {
+    await connection?.close()
     await db.close()
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -26,6 +26,7 @@ export async function initializeDuckDB(`
`26`	`26`
`27`	`27`	`export async function closeDuckDB() {`
`28`	`28`	`if (db) {`
	`29`	`+ await connection?.close()`
`29`	`30`	`await db.close()`
`30`	`31`	`}`
`31`	`32`	`}`