anchor.diff:      erlang:monitor(process, MapperPid),
       {no_output, State#state{mapper_data=MapperData1}};
   
  -handle_event({mapexec_reply, VNode, BKey, Reply, Executor}, #state{fsms=FSMs, mapper_data=MapperData, qterm=QTerm,
  +handle_event({mapexec_reply, VNode, BKey, Reply, Executor}, #state{fsms=FSMs, mapper_data=MapperData,
                                                                      pending=Pending}=State) ->
       case dict:is_key(Executor, FSMs) of
           false ->
  
positive.code:             end;
          false -> throw(bad_mapper_props_no_id)
      end.
  
negative.code:         true ->
              case Reply of
                  [{not_found, _, _}] ->
                      handle_not_found_reply(VNode, BKey, Executor, State);
                  [{error, notfound}] ->
                      handle_not_found_reply(VNode, BKey, Executor, State);
                  _ ->
                      Pending1 = Pending ++ Reply,
                      FSMs1 = update_counter(Executor, FSMs),
  