anchor.diff:                   CatalogDone == true andalso
                    DeferredTables == false of
                       true ->
  -                        io:format("fold_catalog_process: streaming complete (~p of ~p)~n",
  -                            [(FinishedStreamProcessCount+1), StreamProcessCount]),
  +                        %% io:format("fold_catalog_process: streaming complete (~p of ~p)~n",
  +                        %%     [(FinishedStreamProcessCount+1), StreamProcessCount]),
                           FoldResultPid ! {fold_result, done};
                       false ->
                           fold_catalog_process(CatRef, FoldResultPid, Fun0, Acc, CatalogDone,
                               StreamProcessCount, FinishedStreamProcessCount+1, false)
                   end;
  -        Msg ->
  -            io:format("fold_catalog_process: unknown message: ~p~n", [Msg]),
  +        _Msg ->
  +            %% io:format("fold_catalog_process: unknown message: ~p~n", [_Msg]),
               fold_catalog_process(CatRef, FoldResultPid, Fun0, Acc, CatalogDone,
                   StreamProcessCount, FinishedStreamProcessCount, DeferredTables)
           after ?FOLD_TIMEOUT ->
               case FinishedStreamProcessCount >= (StreamProcessCount) of
                   true -> ok;
                   false ->
  -                    io:format("fold_catalog_process: timed out (~p of ~p), proceeding to {fold_result, done}~n",
  -                        [FinishedStreamProcessCount, StreamProcessCount])
  +                    %%TODO: How should we handle cleanup here?
  +                    %% io:format("fold_catalog_process: timed out (~p of ~p), proceeding to {fold_result, done}~n",
  +                    %%     [FinishedStreamProcessCount, StreamProcessCount])
  +                    ok
               end,
               FoldResultPid ! {fold_result, done}
       end.
  
positive.code: receive_fold_results(Acc, Count) ->
      receive
          {fold_result, done} ->
              io:format("receive_fold_results: fold complete [~p objects].~n",
                  [Count]),
              Acc;
          {fold_result, _Obj} ->
              receive_fold_results(Acc, Count+1)
  
negative.code: fold(Folder, Acc, State) ->
  %% spawn a process to kick off the catalog listing
  %%   for the this partition, e.g.,
      %% io:format("fold(~p, ~p, ~p)~n", [State, Folder, Acc]),
      %% io:format("fold/sync...~n"),
      sync(),
      %% io:format("fold/sync complete.~n"),
      Partition = integer_to_list(State#state.partition),
      {ok, Conn} = raptor_conn_pool:checkout(),
      Me = self(),
  