anchor.diff:      {noreply, schedule_flush(check_inactivate(State#state{
           cached_keys_to_flush = NewKeys,
           flush_ref = undefined
  -    }))};
  +    }), 0)};
   handle_cast(Request, #state{} = State) ->
       ?log_bad_request(Request),
       {noreply, State}.
  
positive.code: %% @end
  %%--------------------------------------------------------------------
  -spec schedule_flush(state()) -> state().
  schedule_flush(State = #state{flush_ref = undefined}) ->
      Delay = application:get_env(cluster_worker, datastore_writer_flush_delay,
          timer:seconds(1)),
      erlang:send_after(Delay, self(), flush),
      State#state{flush_ref = make_ref()};
  schedule_flush(State = #state{}) ->
      State.
  
  %%--------------------------------------------------------------------
  
negative.code:         cached_keys_to_flush = NewKeys,
          flush_ref = undefined,
          requests_ref = undefined
      }), 0)};
  handle_cast({flushed, _Ref, NotFlushed}, State = #state{
      cached_keys_to_flush = CachedKeys,
      master_pid = Pid
  