Update current version to 7.13.5.Final

Refactor of persistence layer that give more flexibility for
implementors to implement a different transactional policy without
duplicating already existing code.

Signed-off-by: fjtirado <ftirados@redhat.com>

Author: fjtirado

.github/project.yml

@@ -1,3 +1,3 @@
 release:
-  current-version: 7.13.4.Final
+  current-version: 7.13.5.Final
   next-version: 8.0.0-SNAPSHOT

impl/persistence/api/src/main/java/io/serverlessworkflow/impl/persistence/DefaultPersistenceInstanceHandlers.java

@@ -17,7 +17,6 @@
 
 import static io.serverlessworkflow.impl.WorkflowUtils.safeClose;
 
-import java.time.Duration;
 import java.util.Optional;
 import java.util.concurrent.ExecutorService;
 
@@ -27,7 +26,6 @@ public static class Builder {
 
     private final PersistenceInstanceStore store;
     private ExecutorService executorService;
-    private Duration closeTimeout;
 
     private Builder(PersistenceInstanceStore store) {
       this.store = store;
@@ -38,17 +36,9 @@ public Builder withExecutorService(ExecutorService executorService) {
       return this;
     }
 
-    public Builder withCloseTimeout(Duration closeTimeout) {
-      this.closeTimeout = closeTimeout;
-      return this;
-    }
-
     public PersistenceInstanceHandlers build() {
       return new DefaultPersistenceInstanceHandlers(
-          new DefaultPersistenceInstanceWriter(
-              store,
-              Optional.ofNullable(executorService),
-              closeTimeout == null ? Duration.ofSeconds(1) : closeTimeout),
+          new DefaultPersistenceInstanceWriter(store, Optional.ofNullable(executorService)),
           new DefaultPersistenceInstanceReader(store),
           store);
     }

impl/persistence/api/src/main/java/io/serverlessworkflow/impl/persistence/DefaultPersistenceInstanceWriter.java

@@ -17,7 +17,6 @@
 
 import io.serverlessworkflow.impl.WorkflowContextData;
 import io.serverlessworkflow.impl.WorkflowDefinitionData;
-import java.time.Duration;
 import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
@@ -32,18 +31,14 @@ public class DefaultPersistenceInstanceWriter extends AbstractPersistenceInstanc
   private final PersistenceInstanceStore store;
   private final Map<String, CompletableFuture<Void>> futuresMap = new ConcurrentHashMap<>();
   private final Optional<ExecutorService> executorService;
-  private final Duration closeTimeout;
 
   private static final Logger logger =
       LoggerFactory.getLogger(DefaultPersistenceInstanceWriter.class);
 
   protected DefaultPersistenceInstanceWriter(
-      PersistenceInstanceStore store,
-      Optional<ExecutorService> executorService,
-      Duration closeTimeout) {
+      PersistenceInstanceStore store, Optional<ExecutorService> executorService) {
     this.store = store;
     this.executorService = executorService;
-    this.closeTimeout = closeTimeout;
   }
 
   @Override
@@ -76,7 +71,7 @@ private void executeTransaction(
       try {
         transaction.rollback(definition);
       } catch (Exception rollEx) {
-        logger.warn("Exception during rollback. Ignoring it", ex);
+        logger.warn("Exception during rollback. Ignoring it", rollEx);
       }
       throw ex;
     }

impl/test/src/test/java/io/serverlessworkflow/impl/test/MvStorePersistenceTest.java

@@ -32,7 +32,9 @@
 import java.time.Duration;
 import java.util.Collection;
 import java.util.Map;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Stream;
 import org.junit.jupiter.api.Test;
 
@@ -41,10 +43,10 @@ public class MvStorePersistenceTest {
   @Test
   void testSimpleRun() throws Exception {
     final String dbName = "db-samples/simple.db";
+    ExecutorService service =Executors.newSingleThreadExecutor();
     try (PersistenceInstanceHandlers handlers =
             DefaultPersistenceInstanceHandlers.builder(new MVStorePersistenceStore(dbName))
-                .withExecutorService(Executors.newSingleThreadExecutor())
-                .withCloseTimeout(Duration.ofMillis(100))
+                .withExecutorService(service)
                 .build();
         WorkflowApplication application =
             PersistenceApplicationBuilder.builder(WorkflowApplication.builder(), handlers.writer())
@@ -54,7 +56,8 @@ void testSimpleRun() throws Exception {
               readWorkflowFromClasspath("workflows-samples/simple-expression.yaml"));
       assertNoInstance(handlers, definition);
       definition.instance(Map.of()).start().join();
-      handlers.writer().close();
+      service.shutdown();
+      service.awaitTermination(100, TimeUnit.MILLISECONDS);
       assertNoInstance(handlers, definition);
     } finally {
       Files.delete(Path.of(dbName));