changed hex_metadata.config
 
@@ -49,4 49,4 @@
49
49
{<<"optional">>,false},
50
50
{<<"repository">>,<<"hexpm">>},
51
51
{<<"requirement">>,<<"~> 1.0">>}]]}.
52
- {<<"version">>,<<"1.7.2">>}.
52
{<<"version">>,<<"1.7.3">>}.
changed lib/verk/node/manager.ex
 
@@ -97,14 97,13 @@ defmodule Verk.Node.Manager do
97
97
Enum.each(queues, &enqueue_inprogress(verk_node_id, &1))
98
98
end
99
99
100
- defp find_faulty_nodes(local_verk_node_id, cursor \\ 0) do
100
defp find_faulty_nodes(local_verk_node_id, cursor \\ 0, faulty_nodes \\ []) do
101
101
case Verk.Node.members(cursor, Verk.Redis) do
102
102
{:ok, verk_nodes} ->
103
- {:ok, do_find_faulty_nodes(verk_nodes, local_verk_node_id)}
103
{:ok, faulty_nodes do_find_faulty_nodes(verk_nodes, local_verk_node_id)}
104
104
105
105
{:more, verk_nodes, cursor} ->
106
- do_find_faulty_nodes(verk_nodes, local_verk_node_id)
107
- find_faulty_nodes(local_verk_node_id, cursor)
106
find_faulty_nodes(local_verk_node_id, cursor, faulty_nodes do_find_faulty_nodes(verk_nodes, local_verk_node_id))
108
107
109
108
{:error, reason} ->
110
109
{:error, reason}
changed mix.exs
 
@@ -2,7 2,7 @@ defmodule Verk.Mixfile do
2
2
use Mix.Project
3
3
4
4
@source_url "https://github.com/edgurgel/verk"
5
- @version "1.7.2"
5
@version "1.7.3"
6
6
7
7
def project do
8
8
[