Merge pull request #106 from aserto-dev/edge-sync-err

exit on producer|subscriber err
aserto-dev · Nov 7, 2024 · 3dd0c27 · 3dd0c27
2 parents ea860f1 + 813bf53
commit 3dd0c27
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/datasync/directory.go b/pkg/datasync/directory.go
@@ -54,7 +54,8 @@ func (s *Sync) syncDirectory(ctx context.Context, conn *grpc.ClientConn) error {
 	})
 
 	if err := g.Wait(); err != nil {
-		s.logger.Debug().Err(err).Msg(syncRun)
+		s.logger.Error().Err(err).Msg(syncRun)
+		return err
 	}
 
 	if Has(s.options.Mode, Diff) {