Skip to content

Commit

Permalink
fixed something
Browse files Browse the repository at this point in the history
  • Loading branch information
harshil-goel committed Jan 27, 2025
1 parent adc4ad2 commit 1386cc5
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 3 deletions.
6 changes: 4 additions & 2 deletions posting/mvcc.go
Original file line number Diff line number Diff line change
Expand Up @@ -536,8 +536,10 @@ func ReadPostingList(key []byte, it *badger.Iterator) (*List, error) {
return nil, errors.Wrapf(err, "while reading posting list with key [%v]", key)
}

fmt.Println(pk)
debug.PrintStack()
if pk.Attr == "0-genre" {
fmt.Println(pk)
debug.PrintStack()
}

start := time.Now()
defer func() {
Expand Down
3 changes: 2 additions & 1 deletion worker/mutation.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,11 +94,12 @@ func runMutation(ctx context.Context, edge *pb.DirectedEdge, txn *posting.Txn) e
// just create a posting list facade in memory and use it to store the delta in Badger. Later,
// the rollup operation would consolidate all these deltas into a posting list.
isList := su.GetList()
hasIndex := (len(su.GetTokenizer()) > 0 || su.GetCount())
var getFn func(key []byte) (*posting.List, error)
switch {
case len(edge.Lang) == 0 && !isList:
getFn = txn.GetScalarList
case len(edge.Lang) > 0:
case len(edge.Lang) > 0 || hasIndex && su.GetValueType() == pb.Posting_UID:
// Any index or count index.
getFn = txn.Get
case edge.Op == pb.DirectedEdge_DEL:
Expand Down

0 comments on commit 1386cc5

Please sign in to comment.