@@ -96,8 +96,9 @@ handle_cast({update_config_table, Config}, S) -> {noreply, S#state{nodes = NewNodes}}; handle_cast(schedule_next, #state{nodes = Nodes, workers = Workers} = S) -> - AvailableNodes = [N || #dnode{slots = X, num_running = Y, name = N} - <- gb_trees:values(Nodes), X > Y], + AvailableNodes = [N || #dnode{slots = X, num_running = Y, name = N, + blacklisted = false} + <- gb_trees:values(Nodes), X > Y], if AvailableNodes =/= [] -> case gen_server:call(scheduler, {next_task, AvailableNodes}) of {ok, {JobSchedPid, {Node, Task}}} -> master/src/disco_server.erl 5ba19d09f09690d2a55bc6817070d52ac684612c Ville Tuulos tuulos@dxfront.(none) http://github.com/tuulos/disco/commit/63aa62c1aef131c34fc3a8d8f5a9f129627628fb 63aa62c1aef131c34fc3a8d8f5a9f129627628fb 2009-10-04T17:08:37-07:00 2009-10-04T17:08:37-07:00 Blacklisted nodes should not be included in AvailableNodes f851900c118d14825b1d2d7441292c7d45cbd1fb Ville Tuulos tuulos@dxfront.(none)