diff --git a/apps/server/src/orchestration/Layers/ProviderRuntimeIngestion.ts b/apps/server/src/orchestration/Layers/ProviderRuntimeIngestion.ts index 3d1eb012ec6b3ab09dea7d076f0f009ce5fab8d4..a365da1d47a7409a47b01e8675605d6f26ad6dd5 100644 --- a/apps/server/src/orchestration/Layers/ProviderRuntimeIngestion.ts +++ b/apps/server/src/orchestration/Layers/ProviderRuntimeIngestion.ts @@ -288,7 +288,6 @@ const make = Effect.gen(function* () { threadId: input.threadId, messageId: input.messageId, ...(input.turnId ? { turnId: input.turnId } : {}), - text: "", createdAt: input.createdAt, }); yield* clearAssistantMessageState(input.messageId); diff --git a/apps/server/src/orchestration/decider.ts b/apps/server/src/orchestration/decider.ts index 98acd091ac051e131b2b5efe09ed9385b3838faf..91e7d756e9e8913d99b4f2667061d0e29e68bb6c 100644 --- a/apps/server/src/orchestration/decider.ts +++ b/apps/server/src/orchestration/decider.ts @@ -425,7 +425,7 @@ export const decideOrchestrationCommand = Effect.fn("decideOrchestrationCommand" threadId: command.threadId, messageId: command.messageId, role: "assistant", - text: command.text ?? "", + text: "", turnId: command.turnId ?? null, streaming: false, createdAt: command.createdAt, diff --git a/packages/contracts/src/orchestration.ts b/packages/contracts/src/orchestration.ts index 2148179d3fa3b0501fed2eb88d4ed527752169a9..c2f25d4e02b27fe263520642212042c3aa791b50 100644 --- a/packages/contracts/src/orchestration.ts +++ b/packages/contracts/src/orchestration.ts @@ -356,7 +356,6 @@ export const ThreadMessageAssistantCompleteCommand = Schema.Struct({ threadId: ThreadId, messageId: MessageId, turnId: Schema.optional(TurnId), - text: Schema.optional(Schema.String), createdAt: IsoDateTime, });