Skip to content

Commit 236c02d

Browse files
committed
[backend] Batching execution traces
1 parent 1c12e3b commit 236c02d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

openbas-api/src/main/java/io/openbas/rest/helper/queue/executor/BatchExecutionTraceExecutor.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,12 @@
22

33
import io.openbas.rest.inject.form.InjectExecutionCallback;
44
import io.openbas.rest.inject.service.BatchingInjectStatusService;
5-
import jakarta.transaction.Transactional;
65
import java.util.List;
76
import lombok.RequiredArgsConstructor;
87
import org.springframework.stereotype.Component;
98

109
@Component
1110
@RequiredArgsConstructor
12-
@Transactional(Transactional.TxType.REQUIRED)
1311
public class BatchExecutionTraceExecutor {
1412

1513
private final BatchingInjectStatusService batchingInjectStatusService;

openbas-api/src/main/java/io/openbas/rest/inject/service/BatchingInjectStatusService.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import io.openbas.rest.finding.FindingService;
1212
import io.openbas.rest.inject.form.InjectExecutionCallback;
1313
import io.openbas.rest.inject.form.InjectExecutionInput;
14+
import jakarta.transaction.Transactional;
1415
import jakarta.validation.constraints.NotNull;
1516
import java.time.Instant;
1617
import java.util.*;
@@ -122,6 +123,7 @@ public boolean isAllInjectAgentsExecuted(List<SimpleExecutionTrace> traces, int
122123
return numberAgent == totalCompleteTrace;
123124
}
124125

126+
@Transactional
125127
public void handleInjectExecutionCallbackList(
126128
List<InjectExecutionCallback> injectExecutionCallbacks) {
127129

0 commit comments

Comments
 (0)