anchor.diff:              timer2:send_interval(?LOG_INTERVAL, log);
           _ -> ok
       end,
  -    {ok, #state{nodes=dict:new()}}.
  +    {ok, #state{nodes=dict:new(),
  +                nodes_wanted=ns_node_disco:nodes_wanted()}}.
   
   handle_recovery_status_change(not_running, {running, _Bucket, _UUID}) ->
       {not_running, true};
  
positive.code:                        {commitVBucketURI, CommitURI},
                         {recoveryStatusURI, RecoveryStatusURI}]}]
      end.
  
negative.code: 
  -record(state, {
            nodes :: dict(),
            nodes_wanted :: [node()],
            tasks_hash_nodes :: undefined | dict(),
            tasks_hash :: undefined | integer(),
            tasks_version :: undefined | string()
  