Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
tchiotludo committed Jun 27, 2023
1 parent 6f40205 commit 8d0fccc
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,8 +42,7 @@ public void run() {
Trigger trigger = watchingTrigger.get(execution.getId());
triggerQueue.emit(trigger.resetExecution());
triggerState.save(trigger.resetExecution());
}
else if (this.watchingTrigger.containsKey(execution.getId())) {
} else if (this.watchingTrigger.containsKey(execution.getId())) {
Trigger trigger = watchingTrigger.get(execution.getId());
triggerState.save(Trigger.of(execution, trigger.getDate()));
}
Expand Down
3 changes: 1 addition & 2 deletions jdbc/src/main/java/io/kestra/jdbc/runner/JdbcScheduler.java
Original file line number Diff line number Diff line change
Expand Up @@ -61,8 +61,7 @@ public void run() {
triggerRepository
.findByExecution(execution)
.ifPresent(trigger -> triggerRepository.save(trigger.resetExecution()));
}
else {
} else {
// update execution state on each state change so the scheduler knows the execution is running
triggerRepository
.findByExecution(execution)
Expand Down

0 comments on commit 8d0fccc

Please sign in to comment.