sync-sidecar: fix a bug that could mark sync with errors as fully suc…

…cessful
jitsucom · Aug 16, 2024 · 5b16093 · 5b16093
1 parent 9c4ae1c
commit 5b16093
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sync-sidecar/read.go b/sync-sidecar/read.go
@@ -67,7 +67,7 @@ func (s *ReadSideCar) Run() {
 			s.registerErr(fmt.Errorf("%v", r))
 			s.closeActiveStreams(false)
 		} else {
-			s.closeActiveStreams(!cancelled)
+			s.closeActiveStreams(!cancelled && !s.isErr())
 		}
 		if len(s.processedStreams) > 0 {
 			statusMap := types2.NewOrderedMap[string, any]()