remove sql.end/client.end()

Author: thomasgauvin

src/content/docs/hyperdrive/tutorials/serverless-timeseries-api-with-timescale/index.mdx

@@ -203,7 +203,6 @@ export default {
 				headers: { "Content-Type": "application/json" },
 			});
 
-			ctx.waitUntil(client.end());
 			return resp;
 
 			// Create a route for querying within a time-frame
@@ -221,7 +220,6 @@ export default {
 				headers: { "Content-Type": "application/json" },
 			});
 
-			ctx.waitUntil(client.end());
 			return resp;
 		}
 	},

src/content/docs/workers/databases/third-party-integrations/neon.mdx

@@ -81,7 +81,6 @@ To connect to Neon using `@neondatabase/serverless`, follow these steps:
    		const client = new Client(env.DATABASE_URL);
    		await client.connect();
    		const { rows } = await client.query("SELECT * FROM elements");
-   		ctx.waitUntil(client.end()); // this doesn’t hold up the response
 
    		return new Response(JSON.stringify(rows));
    	},

src/content/partials/hyperdrive/use-node-postgres-to-make-query.mdx

@@ -29,7 +29,11 @@ Create a new `Client` instance and pass the Hyperdrive `connectionString`:
 import { Client } from "pg";
 
 export default {
-	async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
+	async fetch(
+		request: Request,
+		env: Env,
+		ctx: ExecutionContext,
+	): Promise<Response> {
 		// Create a new client instance for each request.
 		const client = new Client({
 			connectionString: env.HYPERDRIVE.connectionString,
@@ -43,17 +47,14 @@ export default {
 			// Perform a simple query
 			const result = await client.query("SELECT * FROM pg_tables");
 
-			// Clean up the client after the response is returned, before the Worker is killed
-			ctx.waitUntil(client.end());
-
 			return Response.json({
 				success: true,
 				result: result.rows,
 			});
 		} catch (error: any) {
 			console.error("Database error:", error.message);
 
-			new Response('Internal error occurred', { status: 500 });
+			new Response("Internal error occurred", { status: 500 });
 		}
 	},
 };