fix(@langchain/community) create index aurora dsql (langchain-ai#8892)

Co-authored-by: Jorge Lanzarotti <abarjorg@amazon.com>

Author: christian-bromann

.changeset/kind-tickle-bear.md

@@ -0,0 +1,5 @@
+---
+"@langchain/community": patch
+---
+
+create index aurora dsql

examples/package.json

@@ -24,7 +24,7 @@
   "author": "LangChain",
   "license": "MIT",
   "dependencies": {
-    "@aws-sdk/dsql-signer": "^3.738.0",
+    "@aws-sdk/dsql-signer": "^3.844.0",
     "@azure/identity": "^4.2.1",
     "@browserbasehq/stagehand": "^1.3.0",
     "@clickhouse/client": "^0.2.5",

libs/langchain-community/package.json

@@ -58,7 +58,7 @@
     "@aws-sdk/client-sagemaker-runtime": "^3.749.0",
     "@aws-sdk/client-sfn": "^3.749.0",
     "@aws-sdk/credential-provider-node": "^3.749.0",
-    "@aws-sdk/dsql-signer": "^3.738.0",
+    "@aws-sdk/dsql-signer": "^3.844.0",
     "@aws-sdk/types": "^3.734.0",
     "@azure/search-documents": "^12.0.0",
     "@azure/storage-blob": "^12.15.0",

libs/langchain-community/src/stores/message/aurora_dsql.ts

@@ -114,7 +114,7 @@ export class AuroraDsqlChatMessageHistory extends BaseListChatMessageHistory {
 
     const query = `
     CREATE TABLE IF NOT EXISTS ${this.tableName} (
-      id UUID PRIMARY KEY DEFAULT gen_random_uuid(), 
+      id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
       created_at timestamp default current_timestamp,
       session_id VARCHAR(255) NOT NULL,
       message TEXT NOT NULL
@@ -138,7 +138,7 @@ export class AuroraDsqlChatMessageHistory extends BaseListChatMessageHistory {
   }
 
   private async createIndex() {
-    const query = `CREATE INDEX IF NOT EXISTS idx_on_session_id on ${this.tableName} (session_id);`;
+    const query = `CREATE INDEX ASYNC IF NOT EXISTS idx_on_session_id on ${this.tableName} (session_id);`;
     await this.pool.query(query);
   }
 

libs/langchain-community/src/stores/tests/aurora_dsql.int.test.ts

@@ -15,7 +15,7 @@ async function getAdminAuthToken() {
     credentials: {
       accessKeyId: process.env.AWS_ACCESS_KEY_ID!,
       secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY!,
-      // sessionToken: process.env.AWS_SESSION_TOKEN!
+      // sessionToken: process.env.AWS_SESSION_TOKEN!,
     },
   });
   return await signer.getDbConnectAdminAuthToken();