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
|
[
|