Term signal checked on async retry fixes #230 (#242)

Signed-off-by: Sotirios Mantziaris <smantziaris@gmail.com>
mantzas · Nov 14, 2018 · 6d532c9 · 6d532c9
1 parent bce92f9
commit 6d532c9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/async/component.go b/async/component.go
@@ -80,6 +80,9 @@ func (c *Component) Run(ctx context.Context) error {
 		if err == nil {
 			return nil
 		}
+		if ctx.Err() == context.Canceled {
+			break
+		}
 		c.consumerErrorsInc()
 		if c.retries > 0 {
 			log.Errorf("failed run, retry %d/%d with %v wait: %v", i, c.retries, c.retryWait, err)