Skip to content

Commit

Permalink
fix(jdbc): exectorstate is clean to early that lead to duplicate exec…
Browse files Browse the repository at this point in the history
…ution
  • Loading branch information
tchiotludo committed Aug 31, 2022
1 parent 7a8ac61 commit 2671e5f
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions jdbc/src/main/java/io/kestra/jdbc/runner/JdbcExecutor.java
Original file line number Diff line number Diff line change
Expand Up @@ -286,10 +286,6 @@ private void executionQueue(Execution message) {

if (result != null) {
this.toExecution(result);

if (executorService.canBePurged(result)) {
executorStateStorage.delete(result.getExecution());
}
}
}

Expand Down Expand Up @@ -376,6 +372,7 @@ private void toExecution(Executor executor) {
// delete if ended
if (executorService.canBePurged(executor)) {
// TODO
// executorStateStorage.delete(executor.getExecution());
}
}

Expand Down

0 comments on commit 2671e5f

Please sign in to comment.