AkurAI Build
Sign in with AkurAI ID
Menu

popagent

public

Latest change 972773b71dbbef4be4a0e9ae0f53057fbdf71bb4 - Fix delegated memory persistence by Ólafur Búi Ólafsson

diff --git a/dist/agent-BOdDHE12.cjs b/dist/agent-BOdDHE12.cjs
index 6c7efc0e0771d2ef0200d6e786480a82c4e78412..dda55fa1cca1519562d3300419bfa26e461b26ed 100644
--- a/dist/agent-BOdDHE12.cjs
+++ b/dist/agent-BOdDHE12.cjs
@@ -34391,7 +34391,11 @@ var Agent = class Agent extends require_base.MastraBase {
 								args: toolResult.payload.args,
 								isError: toolResult.payload.isError
 							}));
-							fullSubAgentMessages = [subAgentUserMessage, ...agentResponseMessages];
+							fullSubAgentMessages = [subAgentUserMessage, ...agentResponseMessages].map((message) => ({
+								...message,
+								threadId: message.threadId || subAgentThreadId,
+								resourceId: message.resourceId || subAgentResourceId
+							}));
 							const memory = await resolvedAgent.getMemory({ requestContext: subAgentRequestContext });
 							if (memory) try {
 								await memory.createThread({
@@ -34480,7 +34484,11 @@ var Agent = class Agent extends require_base.MastraBase {
 								args: toolResult.payload.args,
 								isError: toolResult.payload.isError
 							}));
-							fullSubAgentMessages = [subAgentUserMessage, ...streamResult.messageList.get.response.db()];
+							fullSubAgentMessages = [subAgentUserMessage, ...streamResult.messageList.get.response.db()].map((message) => ({
+								...message,
+								threadId: message.threadId || subAgentThreadId,
+								resourceId: message.resourceId || subAgentResourceId
+							}));
 							const streamMemory = await resolvedAgent.getMemory({ requestContext: subAgentRequestContext });
 							if (streamMemory) try {
 								await streamMemory.createThread({
diff --git a/dist/agent-CKAVuxKN.js b/dist/agent-CKAVuxKN.js
index 2d9462a72607f5960d236a4d9be268ea14e60c8a..78a39a43348b5113d40c95a72c0ead603b7a11f1 100644
--- a/dist/agent-CKAVuxKN.js
+++ b/dist/agent-CKAVuxKN.js
@@ -34389,7 +34389,11 @@ var Agent = class Agent extends MastraBase {
 								args: toolResult.payload.args,
 								isError: toolResult.payload.isError
 							}));
-							fullSubAgentMessages = [subAgentUserMessage, ...agentResponseMessages];
+							fullSubAgentMessages = [subAgentUserMessage, ...agentResponseMessages].map((message) => ({
+								...message,
+								threadId: message.threadId || subAgentThreadId,
+								resourceId: message.resourceId || subAgentResourceId
+							}));
 							const memory = await resolvedAgent.getMemory({ requestContext: subAgentRequestContext });
 							if (memory) try {
 								await memory.createThread({
@@ -34478,7 +34482,11 @@ var Agent = class Agent extends MastraBase {
 								args: toolResult.payload.args,
 								isError: toolResult.payload.isError
 							}));
-							fullSubAgentMessages = [subAgentUserMessage, ...streamResult.messageList.get.response.db()];
+							fullSubAgentMessages = [subAgentUserMessage, ...streamResult.messageList.get.response.db()].map((message) => ({
+								...message,
+								threadId: message.threadId || subAgentThreadId,
+								resourceId: message.resourceId || subAgentResourceId
+							}));
 							const streamMemory = await resolvedAgent.getMemory({ requestContext: subAgentRequestContext });
 							if (streamMemory) try {
 								await streamMemory.createThread({