From 509b2dd36d0bb73a7754a86cecf84a8e00c76314 Mon Sep 17 00:00:00 2001 From: Vinod Paidimarry Date: Sat, 23 Mar 2024 13:18:15 +0530 Subject: [PATCH] bugfix: Dynamo Memory - messageAttributeName (#2011) * bugfix: Dynamo Memory - messageAttributeName * bugfix: Dynamo Memory - messageAttributeName --- packages/components/nodes/memory/DynamoDb/DynamoDb.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/components/nodes/memory/DynamoDb/DynamoDb.ts b/packages/components/nodes/memory/DynamoDb/DynamoDb.ts index 24fa3750f..778357090 100644 --- a/packages/components/nodes/memory/DynamoDb/DynamoDb.ts +++ b/packages/components/nodes/memory/DynamoDb/DynamoDb.ts @@ -81,11 +81,11 @@ class DynamoDb_Memory implements INode { } async init(nodeData: INodeData, _: string, options: ICommonObject): Promise { - return initalizeDynamoDB(nodeData, options) + return initializeDynamoDB(nodeData, options) } } -const initalizeDynamoDB = async (nodeData: INodeData, options: ICommonObject): Promise => { +const initializeDynamoDB = async (nodeData: INodeData, options: ICommonObject): Promise => { const tableName = nodeData.inputs?.tableName as string const partitionKey = nodeData.inputs?.partitionKey as string const region = nodeData.inputs?.region as string @@ -224,8 +224,8 @@ class BufferMemoryExtended extends FlowiseMemory implements MemoryMethods { const dynamoKey = overrideSessionId ? this.overrideDynamoKey(overrideSessionId) : this.dynamoKey const tableName = this.tableName - const messageAttributeName = this.messageAttributeName + const messageAttributeName = this.messageAttributeName ? this.messageAttributeName : 'messages' const params: GetItemCommandInput = { TableName: tableName, Key: dynamoKey