From 65cb952727fa58489fd1ebf1a4ede7fc85b5c140 Mon Sep 17 00:00:00 2001
From: Kamil Janecek <j@necek.com>
Date: Sun, 5 Jan 2025 16:53:24 +0100
Subject: [PATCH] #515: fix naming

---
 .../java/com/github/kagkarlsson/scheduler/Scheduler.java   | 6 +++---
 .../scheduler/functional/DeleteUnresolvedTest.java         | 7 ++++---
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/Scheduler.java b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/Scheduler.java
index 7659f315..f1a5589c 100644
--- a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/Scheduler.java
+++ b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/Scheduler.java
@@ -358,11 +358,11 @@ public List<CurrentlyExecuting> getCurrentlyExecutingWithStaleHeartbeat() {
   protected void detectDeadExecutions() {
     LOG.debug("Deleting executions with unresolved tasks.");
 
-    Map<String, Instant> unresolvedTaskToNewestExecution = new HashMap<>();
+    Map<String, Instant> taskToNewestExecutionTime = new HashMap<>();
     schedulerTaskRepository.getScheduledExecutions(
         ScheduledExecutionsFilter.all(),
         execution ->
-            unresolvedTaskToNewestExecution.merge(
+            taskToNewestExecutionTime.merge(
                 execution.taskInstance.getTaskName(),
                 execution.executionTime,
                 (oldValue, newValue) -> oldValue.isAfter(newValue) ? oldValue : newValue));
@@ -371,7 +371,7 @@ protected void detectDeadExecutions() {
         .map(UnresolvedTask::getTaskName)
         .filter(
             taskName -> {
-              Instant newestExecution = unresolvedTaskToNewestExecution.get(taskName);
+              Instant newestExecution = taskToNewestExecutionTime.get(taskName);
 
               if (newestExecution == null) {
                 // probably deleted by other node
diff --git a/db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/functional/DeleteUnresolvedTest.java b/db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/functional/DeleteUnresolvedTest.java
index e148b093..0892642b 100644
--- a/db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/functional/DeleteUnresolvedTest.java
+++ b/db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/functional/DeleteUnresolvedTest.java
@@ -56,15 +56,16 @@ public void should_delete_executions_with_old_unresolved_tasknames() {
 
     scheduler.schedule(first.instance("id_f"), clock.now());
     scheduler.schedule(second.instance("id_s"), clock.now().minus(1, ChronoUnit.DAYS));
+    scheduler.schedule(second.instance("id_s_2"), clock.now().minus(2, ChronoUnit.DAYS));
     assertEquals(0, testableRegistry.getCount(StatsRegistry.SchedulerStatsEvent.UNRESOLVED_TASK));
 
     scheduler.runAnyDueExecutions();
-    assertEquals(2, testableRegistry.getCount(StatsRegistry.SchedulerStatsEvent.UNRESOLVED_TASK));
+    assertEquals(3, testableRegistry.getCount(StatsRegistry.SchedulerStatsEvent.UNRESOLVED_TASK));
 
-    assertEquals(2, DbUtils.countExecutions(postgres.getDataSource()));
+    assertEquals(3, DbUtils.countExecutions(postgres.getDataSource()));
 
     scheduler.runDeadExecutionDetection();
-    assertEquals(2, DbUtils.countExecutions(postgres.getDataSource()));
+    assertEquals(3, DbUtils.countExecutions(postgres.getDataSource()));
 
     clock.tick(Duration.ofDays(4));
     scheduler.runDeadExecutionDetection();