Break lease on iteration

eclipse-edc · Aug 28, 2023 · dc118f6 · dc118f6
1 parent 224eaf9
commit dc118f6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/.../src/main/java/org/eclipse/edc/connector/transfer/process/TransferProcessManagerImpl.java b/.../src/main/java/org/eclipse/edc/connector/transfer/process/TransferProcessManagerImpl.java
@@ -430,6 +430,7 @@ private Boolean checkCompletion(TransferProcess transferProcess) {
         var checker = statusCheckerRegistry.resolve(transferProcess.getDataDestination().getType());
         if (checker == null) {
             monitor.warning(format("No checker found for process %s. The process will not advance to the COMPLETED state.", transferProcess.getId()));
+            breakLease(transferProcess);
             return false;
         } else {
             var resources = transferProcess.getProvisionedResources();

diff --git a/.../test/java/org/eclipse/edc/connector/transfer/process/TransferProcessManagerImplTest.java b/.../test/java/org/eclipse/edc/connector/transfer/process/TransferProcessManagerImplTest.java
@@ -606,7 +606,9 @@ void started_shouldNotComplete_whenNoChecker() {
         manager.start();
 
         await().untilAsserted(() -> {
-            verify(transferProcessStore, never()).save(any());
+            var captor = ArgumentCaptor.forClass(TransferProcess.class);
+            verify(transferProcessStore).save(captor.capture());
+            assertThat(captor.getValue().getState()).isEqualTo(STARTED.code());
         });
     }