fix(compaction): skip tail persistence on error
This commit is contained in:
parent
44062b7976
commit
e0501ac50b
1 changed files with 2 additions and 1 deletions
|
|
@ -512,6 +512,8 @@ export const layer: Layer.Layer<
|
|||
return "stop"
|
||||
}
|
||||
|
||||
if (processor.message.error) return "stop"
|
||||
|
||||
if (tail) {
|
||||
const tailMessage = yield* session.updateMessage({
|
||||
id: MessageID.ascending(),
|
||||
|
|
@ -623,7 +625,6 @@ export const layer: Layer.Layer<
|
|||
}
|
||||
}
|
||||
|
||||
if (processor.message.error) return "stop"
|
||||
if (result === "continue") {
|
||||
const summaryMessage = (yield* session.messages({ sessionID: input.sessionID })).find(
|
||||
(item) => item.info.id === msg.id,
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue