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

(cherry picked from commit a8a47af) Co-authored-by: Manish R Jain <[email protected]>
hypermodeinc · Oct 7, 2020 · a1ce240 · a1ce240
1 parent c605cb5
commit a1ce240
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/worker/groups.go b/worker/groups.go
@@ -1016,6 +1016,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)
 			}