toki/iop
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(openai): hybrid 과거 receipt 재검증을 제거한다

Browse source
This commit is contained in:
toki 2026-08-15 16:18:57 +09:00
parent 178539590f
commit 19b555c34d
1 changed files with 1 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
apps/edge/internal/openai/hot_path_light.go
View file

@ -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")