anchor.diff:                                   O=riakc_obj:new(<<"bucket">>, K),
                                    ?MODULE:put(Pid,riakc_obj:update_value(O, V, "application/json"))
                            end,
  -                 [Store(KV) || KV <- [{<<"foo">>, <<"2">>}, 
  -                                      {<<"bar">>, <<"3">>}, 
  +                 [Store(KV) || KV <- [{<<"foo">>, <<"2">>},
  +                                      {<<"bar">>, <<"3">>},
                                         {<<"baz">>, <<"4">>}]],
   
                    ?assertEqual({ok, [{1, [9]}]},
  -                              ?MODULE:mapred(Pid, 
  +                              ?MODULE:mapred(Pid,
                                                [{<<"bucket">>, <<"foo">>},
                                                 {<<"bucket">>, <<"bar">>},
                                                 {<<"bucket">>, <<"baz">>}],
  
positive.code:               {'query', Query},
                {'timeout', Timeout}],
      send_mapred_req(Pid, MapRed, ClientPid).
      
  %% @spec mapred_bucket(Pid :: pid(),
  %%                     Query :: [riak_kv_mapred_query:mapred_queryterm()],
  %%                     ClientPid :: pid(),
  %%                     TimeoutMillisecs :: integer() | 'infinity') ->
  %%       {ok, {ReqId :: term(), MR_FSM_PID :: pid()}} |
  %%       {error, Err :: term()}
  %% @doc Perform a map/reduce job against a bucket with a timeout 
  %%      across the cluster.
  %%      See the map/reduce documentation for explanation of behavior.
  mapred_bucket(Pid, Bucket, Query) ->
  
negative.code:                                {n_val,2}],
                                lists:sort(Props))
               end)},
  
       {"allow_mult should allow dupes",
        ?_test(begin
                   reset_riak(),
                   {ok, Pid1} = start_link(?TEST_IP, ?TEST_PORT),
  