Skip to content

Commit daf01c0

Browse files
second commit
1 parent 9785f9a commit daf01c0

File tree

1 file changed

+20
-5
lines changed

1 file changed

+20
-5
lines changed

worker/task.go

Lines changed: 20 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -443,16 +443,31 @@ func (qs *queryState) handleValuePostings(ctx context.Context, args funcArgs) er
443443
}
444444

445445
} else {
446-
pl, err = qs.cache.GetSingleItem(key)
446+
pl, err, _ := posting.GetSingleValueForKey(key, q.ReadTs)
447447
if err != nil {
448448
return err
449449
}
450450

451-
val, err := pl.AllValues(q.ReadTs)
452-
if err != nil {
453-
return err
451+
for _, p := range pl.Postings {
452+
vals = append(vals, types.Val{
453+
Tid: types.TypeID(p.ValType),
454+
Value: p.Value,
455+
})
456+
457+
if q.FacetParam != nil {
458+
fcs.FacetsList = append(fcs.FacetsList, &pb.Facets{Facets: facets.CopyFacets(p.Facets, q.FacetParam)})
459+
}
454460
}
455-
vals = append(vals, val...)
461+
//pl, err = qs.cache.GetSingleItem(key)
462+
//if err != nil {
463+
// return err
464+
//}
465+
466+
//val, err := pl.AllValues(q.ReadTs)
467+
//if err != nil {
468+
// return err
469+
//}
470+
//vals = append(vals, val...)
456471
}
457472

458473
uidList := new(pb.List)

0 commit comments

Comments
 (0)