fix: report error correctly

argoproj-labs · Sep 8, 2021 · fbae663 · fbae663
1 parent c3cb97f
commit fbae663
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/runner/sidecar/sources.go b/runner/sidecar/sources.go
@@ -46,6 +46,7 @@ func connectSources(ctx context.Context, toMain func(context.Context, []byte) er
 			for {
 				select {
 				case <-ctx.Done():
+					withLock(func() { step.Status.SourceStatuses.IncrErrors(sourceName, replica) })
 					return fmt.Errorf("could not send message: %w", ctx.Err())
 				default:
 					if uint64(backoff.Steps) < s.Retry.Steps { // this is a retry