auto reconnect when disconnected by some reason

kyleaa · Mar 2, 2022 · 4c65528 · 4c65528
1 parent aa035c5
commit 4c65528
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