diff --git a/worker/groups.go b/worker/groups.go
index 8b654cf99f9..f46fc3f01b3 100644
--- 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)
 			}