Break out if g.Ctx is done

manishrjain · manishrjain · commit a8a47af407ce · 2020-10-05T07:48:33.000-07:00
diff --git a/worker/groups.go b/worker/groups.go
@@ -1023,6 +1023,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)
 			}

Original file line number	Diff line number	Diff line change
`@@ -1023,6 +1023,9 @@ func (g *groupi) processOracleDeltaStream() {`
`1023`	`1023`	`if err == nil {`
`1024`	`1024`	`break`
`1025`	`1025`	`}`
	`1026`	`+ if g.Ctx().Err() != nil {`
	`1027`	`+ break`
	`1028`	`+ }`
`1026`	`1029`	`glog.Errorf("While proposing delta with MaxAssigned: %d and num txns: %d."+`
`1027`	`1030`	`" Error=%v. Retrying...\n", delta.MaxAssigned, len(delta.Txns), err)`
`1028`	`1031`	`}`