Break out if g.Ctx is done (#6675)

(cherry picked from commit a8a47af) Co-authored-by: Manish R Jain <manish@dgraph.io>
dgraph-io · Oct 7, 2020 · b52a1bf · b52a1bf
1 parent b84251f
commit b52a1bf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/worker/groups.go b/worker/groups.go
@@ -1024,6 +1024,9 @@ func (g *groupi) processOracleDeltaStream() {
 				if err == nil {
 					break
 				}
+				if g.Ctx().Err() != nil {
+					break
+				}
 				glog.Errorf("While proposing delta with MaxAssigned: %d and num txns: %d."+
 					" Error=%v. Retrying...\n", delta.MaxAssigned, len(delta.Txns), err)
 			}