[proxima-direct-core] allow creation of committed transaction in caching

datadrivencz · Jan 20, 2025 · 5fab79c · 5fab79c
1 parent 9a35f5c
commit 5fab79c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/.../core/src/main/java/cz/o2/proxima/direct/core/transaction/TransactionResourceManager.java b/.../core/src/main/java/cz/o2/proxima/direct/core/transaction/TransactionResourceManager.java
@@ -830,7 +830,11 @@ public void ensureTransactionOpen(String transactionId, State state) {
   @VisibleForTesting
   @Nullable
   CachedTransaction createCachedTransaction(String transactionId, State state) {
-    Preconditions.checkArgument(state.getCommittedOutputs().isEmpty());
+    Preconditions.checkArgument(
+        state.getCommittedOutputs().isEmpty() || state.getFlags() == State.Flags.COMMITTED,
+        "Invalid state of transaction %s: %s",
+        transactionId,
+        state.getFlags());
     if (state.getInputAttributes().isEmpty()) {
       return null;
     }