From 19b555c34dc42b93f5958277f1111687a343ffe3 Mon Sep 17 00:00:00 2001 From: toki Date: Sat, 15 Aug 2026 16:18:57 +0900 Subject: [PATCH] =?UTF-8?q?fix(openai):=20hybrid=20=EA=B3=BC=EA=B1=B0=20re?= =?UTF-8?q?ceipt=20=EC=9E=AC=EA=B2=80=EC=A6=9D=EC=9D=84=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_light.go | 17 +---------------- 1 file changed, 1 insertion(+), 16 deletions(-) diff --git a/apps/edge/internal/openai/hot_path_light.go b/apps/edge/internal/openai/hot_path_light.go index 7c63117e..d510ca56 100644 --- a/apps/edge/internal/openai/hot_path_light.go +++ b/apps/edge/internal/openai/hot_path_light.go @@ -800,19 +800,13 @@ func (s *hotPathLightStore) matchRecordLocked(ownerEdgeID, principalRef, protoco var candidates []*hotPathLightRecord for _, record := range s.records { pendingRelated := record.pending != nil && (record.pendingHash == lineage.IssuedCallHash || hotPathPendingIDsIntersect(record, lineage.ResultIDs) || record.lineage == lineage.Prefix) - _, consumedHash := record.consumedHashes[lineage.IssuedCallHash] - if pendingRelated || consumedHash || hotPathConsumedIDsIntersect(record, lineage.ResultIDs) { + if pendingRelated { candidates = append(candidates, record) } } if len(candidates) == 0 { return nil, false, nil } - for _, record := range candidates { - if _, replay := record.consumedHashes[lineage.IssuedCallHash]; replay { - return nil, true, fmt.Errorf("light tool frontier replay rejected") - } - } for _, record := range candidates { if record.phase != hotPathPhaseCleanupPending || record.pendingKind != hotPathPendingCleanup || !hotPathPendingIDsIntersect(record, lineage.ResultIDs) { continue @@ -869,15 +863,6 @@ func hotPathPendingIDsIntersect(record *hotPathLightRecord, ids []string) bool { return false } -func hotPathConsumedIDsIntersect(record *hotPathLightRecord, ids []string) bool { - for _, id := range ids { - if _, ok := record.consumedIDs[id]; ok { - return true - } - } - return false -} - func (s *hotPathLightStore) commitLocal(requestID, ownerEdgeID string, output normalizedStageOutput, correlation hotPathStageCorrelation, coordinator *logicalRequestCoordinator) (hotPathLightDisposition, error) { if s == nil || coordinator == nil { return hotPathLightDisposition{}, fmt.Errorf("light flow is unavailable")