anchor.diff:           handoff/2,
            validate_arg/1]).
   -export([chashfun/1, reduce_compat/1]).
  +%% Special export for riak_pipe_fitting
  +-export([no_input_run_reduce_once/0]).
   
   -include_lib("riak_pipe/include/riak_pipe.hrl").
   -include_lib("riak_pipe/include/riak_pipe_log.hrl").
  
positive.code:          {ok, state()}.
  init(Partition, FittingDetails) ->
      DelayMax = calc_delay_max(FittingDetails),
      {ok, #state{acc=[], delay=0, delay_max = DelayMax,
                  p=Partition, fd=FittingDetails}}.
  
  %% @doc Process looks up the previous result for the `Key', and then
  
negative.code:     reduce_compat({qfun, erlang:make_fun(Module, Function, 2)});
  reduce_compat({qfun, Fun}) ->
      Fun.
  
  no_input_run_reduce_once() ->
      true.
  
  stored_js_source(Bucket, Key) ->
      {ok, C} = riak:local_client(),
  