Merge pull request #27 from satoren/reconnect_when_disconnect_by_netw…

…ork_problem auto reconnect when disconnected by some reason
kyleaa · Mar 5, 2022 · 3f1025e · 3f1025e
2 parents 2b7b26a + 4c65528
commit 3f1025e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/lib/strategy/tags.ex b/lib/strategy/tags.ex
@@ -85,7 +85,6 @@ defmodule ClusterEC2.Strategy.Tags do
   defp load(%State{topology: topology, connect: connect, disconnect: disconnect, list_nodes: list_nodes} = state) do
     case get_nodes(state) do
       {:ok, new_nodelist} ->
-        added = MapSet.difference(new_nodelist, state.meta)
         removed = MapSet.difference(state.meta, new_nodelist)
 
         new_nodelist =
@@ -101,7 +100,7 @@ defmodule ClusterEC2.Strategy.Tags do
           end
 
         new_nodelist =
-          case Cluster.Strategy.connect_nodes(topology, connect, list_nodes, MapSet.to_list(added)) do
+          case Cluster.Strategy.connect_nodes(topology, connect, list_nodes, MapSet.to_list(new_nodelist)) do
             :ok ->
               new_nodelist