From 8b42256bac158662b3ccb358f322523b038e5768 Mon Sep 17 00:00:00 2001 From: Harshil Goel Date: Wed, 23 Apr 2025 18:07:52 +0530 Subject: [PATCH] fix(core): fix variables in live loader --- dgraph/cmd/live/batch.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/dgraph/cmd/live/batch.go b/dgraph/cmd/live/batch.go index 275a6ff2e3a..79cfac7d5ae 100644 --- a/dgraph/cmd/live/batch.go +++ b/dgraph/cmd/live/batch.go @@ -77,7 +77,6 @@ type loader struct { conflicts map[uint64]struct{} uidsLock sync.RWMutex - reqNum uint64 reqs chan *request zeroconn *grpc.ClientConn schema *Schema @@ -161,6 +160,7 @@ func (l *loader) infinitelyRetry(req *request) { func (l *loader) mutate(req *request) error { atomic.AddInt32(&l.inflight, 1) + defer atomic.AddInt32(&l.inflight, -1) txn := l.dc.NewTxn() req.CommitNow = true request := &api.Request{ @@ -172,8 +172,6 @@ func (l *loader) mutate(req *request) error { } func (l *loader) request(req *request) { - atomic.AddUint64(&l.reqNum, 1) - defer atomic.AddInt32(&l.inflight, -1) err := l.mutate(req) if err == nil { atomic.AddUint64(&l.nquads, uint64(len(req.Set)))