diff --git a/lib/nebulex_redis_adapter/redis_cluster/config_manager.ex b/lib/nebulex_redis_adapter/redis_cluster/config_manager.ex index d060f0d..0259d0e 100644 --- a/lib/nebulex_redis_adapter/redis_cluster/config_manager.ex +++ b/lib/nebulex_redis_adapter/redis_cluster/config_manager.ex @@ -285,7 +285,8 @@ defmodule NebulexRedisAdapter.RedisCluster.ConfigManager do [{start, stop, host, port} | acc] end) |> Enum.map(fn {start, stop, host, port} -> - {start, stop, maybe_override_host(host, config_endpoint, override?), port} + {maybe_convert_to_integer(start), maybe_convert_to_integer(stop), + maybe_override_host(host, config_endpoint, override?), port} end) end @@ -318,4 +319,7 @@ defmodule NebulexRedisAdapter.RedisCluster.ConfigManager do end # coveralls-ignore-stop + + defp maybe_convert_to_integer(value) when is_binary(value), do: String.to_integer(value) + defp maybe_convert_to_integer(value), do: value end