anchor.diff:          keys_in_flush = KIF2,
           keys_to_expire = ToExpire2,
           flush_times = FT2
  -    }, 100))};
  +    }, ?FAST_FLUSH_DELAY))};
   handle_cast(Request, #state{} = State) ->
       ?log_bad_request(Request),
       {noreply, State}.
  
positive.code: -spec schedule_flush(state()) -> state().
  schedule_flush(State) ->
      Delay = application:get_env(cluster_worker, datastore_writer_flush_delay,
          timer:seconds(1)),
      schedule_flush(State, Delay).
  
  %%--------------------------------------------------------------------
  
negative.code:         {undefined, _} ->
              Timer = erlang:send_after(Delay, self(), flush),
              State#state{flush_timer = Timer};
          {_, ?FAST_FLUSH_DELAY} ->
              case application:get_env(?CLUSTER_WORKER_APP_NAME, tp_fast_flush, on) of
                  on ->
                      erlang:cancel_timer(OldTimer, [{async, true}, {info, false}]),
  