feat(core): kill trigger running on worker when updated

This commit is contained in:
Ludovic DEHON
2024-04-23 17:53:43 +02:00
parent 684aba6362
commit 203df2180f
18 changed files with 411 additions and 98 deletions

View File

@@ -507,13 +507,15 @@ public class MemoryExecutor implements ExecutorInterface {
return;
}
ExecutionKilled message = either.getLeft();
if (!(either.getLeft() instanceof ExecutionKilledExecution message)) {
return;
}
if (skipExecutionService.skipExecution(message.getExecutionId())) {
log.warn("Skipping execution {}", message.getExecutionId());
return;
}
synchronized (this) {
if (log.isDebugEnabled()) {
executorService.log(log, true, message);