From 1a25ba3e6d2cdf14a66c715edb6378de8809617c Mon Sep 17 00:00:00 2001 From: toki Date: Sat, 15 Aug 2026 14:54:26 +0900 Subject: [PATCH] =?UTF-8?q?fix(openai):=20cleanup=20receipt=EC=9D=98=20?= =?UTF-8?q?=EC=A4=91=EB=B3=B5=20history=20gate=EB=A5=BC=20=EC=A0=9C?= =?UTF-8?q?=EA=B1=B0=ED=95=9C=EB=8B=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/edge/internal/openai/hot_path_cleanup.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/apps/edge/internal/openai/hot_path_cleanup.go b/apps/edge/internal/openai/hot_path_cleanup.go index 6cca5ec2..4a365dc2 100644 --- a/apps/edge/internal/openai/hot_path_cleanup.go +++ b/apps/edge/internal/openai/hot_path_cleanup.go @@ -335,7 +335,7 @@ func (c *logicalRequestCoordinator) commitCleanupByLineage( var target *logicalRequestRecord for _, record := range c.requests { if record.state == logicalRequestStateCleanup && record.cleanup && record.ownerEdgeID == ownerEdgeID && record.principalRef == principalRef && - record.lineage == lineage.Prefix && sameLogicalRequestResultIDs(record.expected, lineage.ResultIDs) { + sameLogicalRequestResultIDs(record.expected, lineage.ResultIDs) { target = record break } @@ -343,8 +343,9 @@ func (c *logicalRequestCoordinator) commitCleanupByLineage( if target == nil { return logicalRequestSnapshot{}, errLogicalRequestNotFound } - if err := validateLogicalRequestContinuationLineage(target.lineage, target.expectedIssuedCallHash, target.expected, lineage); err != nil { - return logicalRequestSnapshot{}, err + if target.lineage.Endpoint != lineage.Prefix.Endpoint || target.lineage.ToolsetDigest != lineage.Prefix.ToolsetDigest || + target.expectedIssuedCallHash != lineage.IssuedCallHash { + return logicalRequestSnapshot{}, errLogicalRequestLineage } snapshot := target.snapshot() delete(c.requests, target.id)