diff --git a/worker/groups.go b/worker/groups.go
index 6c84fa03973..4b10724001a 100644
--- 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)
 			}