diff --git a/pkg/log/client.go b/pkg/log/client.go
index 0348019aba656d9e0ebf746ccf2fdd45e4e153d5..c7c4466b6e367962fcc3e8ea13e05205140580e4 100644
--- a/pkg/log/client.go
+++ b/pkg/log/client.go
@@ -26,7 +26,7 @@ func NewClient(conn *grpc.ClientConn) *Client {
 func (c *Client) Log(ctx context.Context, entries <-chan *Entry) error {
 	stream, err := c.client.Log(ctx)
 	if err != nil {
-
+		return err
 	}
 
 	for e := range entries {