Apply suggestions from code review

Signed-off-by: Yashash H L <[email protected]> Co-authored-by: Vigith Maurice <[email protected]>
numaproj · Sep 26, 2024 · dd9d84d · dd9d84d
1 parent ab1c9b4
commit dd9d84d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/sinker/service.go b/pkg/sinker/service.go
@@ -96,8 +96,10 @@ func (fs *Service) SinkFn(stream sinkpb.Sink_SinkFnServer) error {
 		// Wait for the goroutines to finish
 		if err := g.Wait(); err != nil {
 			if errors.Is(err, io.EOF) {
+				log.Printf("Stopping the SinkFn")
 				return nil
 			}
+			log.Printf("Stopping the SinkFn with err, %s", err)
 			return err
 		}
 	}