From: Christopher Coté Date: Thu, 28 Jan 2021 01:40:57 +0000 (-0600) Subject: fix dialyzer error X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=7467c25673120652b3c144dad3bf3ca9a279b53f;p=cluster_kv.git fix dialyzer error --- diff --git a/lib/cluster_kv/ring.ex b/lib/cluster_kv/ring.ex index 198959e..5a8c2e0 100644 --- a/lib/cluster_kv/ring.ex +++ b/lib/cluster_kv/ring.ex @@ -588,10 +588,14 @@ defmodule ClusterKV.Ring do @spec send_sync( name :: module(), - nodes :: [node()], - key :: {String.t(), String.t()}, + nodes :: [node()] | {:error, {:invalid_ring, :no_nodes}}, + key :: binary(), value :: any() ) :: :ok + defp send_sync(_name, {:error, er}, _key, _value) do + Logger.warn("No nodes to sync with, #{inspect(er)}") + end + defp send_sync(name, nodes, key, value) do Enum.each(nodes, fn n -> send({name, n}, {:sync, key, value})