anchor.diff:      catch gen_server:call(scheduler, {new_job, JobName, JobCoord}).
   
   -spec do_new_task(task(), state()) -> ok | failed.
  -do_new_task(Task, S) ->
  -    NodeStats = [case gb_trees:lookup(Node, S#state.nodes) of
  +do_new_task(Task, #state{nodes = Nodes}) ->
  +    NodeStats = [case gb_trees:lookup(Node, Nodes) of
                        none -> {false, Input};
                        {value, N} -> {N#dnode.num_running, Input}
                    end || {_Url, Node} = Input <- Task#task.input],
  
positive.code: 
  -spec do_update_config_table([disco_config:host_info()], [host_name()],
                               [host_name()], state()) -> state().
  do_update_config_table(Config, Blacklist, GCBlacklist, S) ->
      lager:info("Config table updated"),
      NewNodes =
          lists:foldl(fun({Host, Slots}, NewNodes) ->
              NewNode =
                  case gb_trees:lookup(Host, S#state.nodes) of
                      none ->
                          #dnode{host = Host,
                                 node_mon = node_mon:start_link(Host),
  
negative.code: -spec update_stats(host_name(), none | {value, dnode()}, _,
                     state()) -> state().
  update_stats(_Node, none, _ReplyType, S) -> S;
  update_stats(Node, {value, #dnode{num_running = NumRunning,
                                    stats_ok = StatsOk,
                                    stats_failed = StatsFailed,
                                    stats_crashed = StatsCrashed} = N},
               ReplyType, #state{nodes = Nodes} = S) ->
      M = N#dnode{num_running = NumRunning - 1},
      M0 = case ReplyType of
               done ->
                   M#dnode{stats_ok = StatsOk + 1};
               error ->
                   M#dnode{stats_failed = StatsFailed + 1};
               fatal ->
                   M#dnode{stats_crashed = StatsCrashed + 1};
               _ ->
                   M#dnode{stats_crashed = StatsCrashed + 1}
           end,
      S#state{nodes = gb_trees:update(Node, M0, Nodes)}.
  
  -spec do_connection_status(host_name(), up | down, state()) -> state().
  do_connection_status(Node, Status, #state{nodes = Nodes} = S) ->
  