anchor.diff:                        write_set=WriteSet,
                         active_txs_per_key=ActiveTxsPerKey}=State) ->
       TxId = Txn#transaction.txn_id,
  -    LogRecord = #log_record{tx_id=TxId, op_type=update, op_payload={Key, Type, Op}},
  -    Result = floppy_rep_vnode:append(Key, Type, LogRecord),
  -    case Result of
  -        {ok, _} ->
  -            true = ets:insert(ActiveTxsPerKey, {Key, Type, TxId}),
  -            true = ets:insert(WriteSet, {TxId, {Key, Type, Op}}),
  -            {ok, _Pid} = clocksi_updateitem_fsm:start_link(
  +    %%LogRecord = #log_record{tx_id=TxId, op_type=update, op_payload={Key, Type, Op}},
  +    %%Result = floppy_rep_vnode:append(Key, Type, LogRecord),
  +    %%case Result of
  +    %%    {ok, _} ->
  +    true = ets:insert(ActiveTxsPerKey, {Key, Type, TxId}),
  +    true = ets:insert(WriteSet, {TxId, {Key, Type, Op}}),
  +    {ok, _Pid} = clocksi_updateitem_fsm:start_link(
                       Sender,
                       Txn#transaction.vec_snapshot_time,
                       Partition),
  -            {noreply, State};
  -        {error, timeout} ->
  -            {reply, {error, timeout}, State}
  -    end;
  +    {noreply, State};
  +    %%    {error, timeout} ->
  +    %%        {reply, {error, timeout}, State}
  +    %%end;
   
   handle_command({prepare, Transaction}, _Sender,
                  State = #state{partition=_Partition,
  
positive.code:         false ->
              check_keylog(TxId, T, CommittedTx)
      end.
  
negative.code:                                       Transaction#transaction.vec_snapshot_time}},
      Updates = ets:lookup(WriteSet, TxId),
      [{_, {Key, Type, {_Op, _Actor}}} | _Rest] = Updates,
  
      %%Update materializer and write to materializer
  
      case floppy_rep_vnode:append(Key, Type, LogRecord) of
          {ok, _} ->
              true = ets:insert(CommittedTx, {TxId, TxCommitTime}),
              SnapshotTime = Transaction#transaction.vec_snapshot_time,
              case update_materializer(Updates, TxId, SnapshotTime, TxCommitTime) of 
                  ok ->
                      _Return = clocksi_downstream_generator_vnode:trigger(
                                  Key, {TxId,
                                  [],
                                  SnapshotTime,
                                  TxCommitTime}),
                      clean_and_notify(TxId, Key, State),
                      {reply, committed, State};
                  error ->
                      {reply, {error, materializer_failure}, State}
              end;
          {error, timeout} ->
              {reply, {error, timeout}, State}
      end;
  