diff --git a/node/pkg/websocketfetcher/providers/bingx/bingx.go b/node/pkg/websocketfetcher/providers/bingx/bingx.go index 7170933cf..a5a124ab6 100644 --- a/node/pkg/websocketfetcher/providers/bingx/bingx.go +++ b/node/pkg/websocketfetcher/providers/bingx/bingx.go @@ -92,7 +92,7 @@ func (f *BingxFetcher) customReadFunc(ctx context.Context, conn *websocket.Conn) var result map[string]interface{} _, data, err := conn.Read(ctx) if err != nil { - log.Error().Str("Player", "Bingx").Err(err).Msg("error in bingx.customReadFunc, failed to read from websocket") + log.Warn().Str("Player", "Bingx").Err(err).Msg("error in bingx.customReadFunc, failed to read from websocket") return nil, err } diff --git a/node/pkg/websocketfetcher/providers/coinex/coinex.go b/node/pkg/websocketfetcher/providers/coinex/coinex.go index 52694dcda..b82f4faa7 100644 --- a/node/pkg/websocketfetcher/providers/coinex/coinex.go +++ b/node/pkg/websocketfetcher/providers/coinex/coinex.go @@ -80,7 +80,7 @@ func (f *CoinexFetcher) customReadFunc(ctx context.Context, conn *websocket.Conn var result map[string]interface{} _, data, err := conn.Read(ctx) if err != nil { - log.Error().Str("Player", "coinex").Err(err).Msg("error in coinex.customReadFunc, failed to read from websocket") + log.Warn().Str("Player", "coinex").Err(err).Msg("error in coinex.customReadFunc, failed to read from websocket") return nil, err } diff --git a/node/pkg/wss/utils.go b/node/pkg/wss/utils.go index 9fe4b58f9..2f97b2d1b 100644 --- a/node/pkg/wss/utils.go +++ b/node/pkg/wss/utils.go @@ -53,7 +53,7 @@ func (ws *WebsocketHelper) Dial(ctx context.Context) error { } conn, _, err := dialFunc(ctx, ws.Endpoint, dialOption) if err != nil { - log.Error().Err(err).Str("endpoint", ws.Endpoint).Msg("error opening websocket connection") + log.Warn().Err(err).Str("endpoint", ws.Endpoint).Msg("error opening websocket connection") return err }