anchor.diff:              lager:error("No replication group for key: ~p (~p)", [Key, Reason])
       end,
       {reply, {ok, TimeStamp}, S0#state{max_ts=TimeStamp, last_label=Label}};
  -    {noreply, S0};
   
   handle_command({propagate, Key, Value, TimeStamp}, _From, S0=#state{max_ts=MaxTS0}) ->
       MaxTS1 = max(TimeStamp, MaxTS0),
  
positive.code: handle_command({check_tables_ready}, _Sender, SD0) ->
      {reply, true, SD0};
  
  handle_command({read, Key}, From, S0) ->
      {ok, Value} = ?BACKEND_CONNECTOR:read({Key, From}),
      {reply, {ok, Value}, S0};
  
  handle_command({update, Key, Value, Clock}, _From, S0=#state{max_ts=MaxTS0, partition=Partition}) ->
      PhysicalClock = saturn_utilities:now_microsec(),
      TimeStamp = max(Clock, max(PhysicalClock, MaxTS0)),
      ok = ?BACKEND_CONNECTOR:update({Key, Value, TimeStamp}),
  
negative.code: init([Partition]) ->
      {ok, #state{partition=Partition,
                  max_ts=0,
                  last_label=none
                 }}.
  
  %% @doc The table holding the prepared transactions is shared with concurrent
  