kagkarlsson#515: apply spottless, add .gitattributes

.gitattributes

@@ -0,0 +1 @@
+* text eol=lf

db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/Scheduler.java

@@ -359,31 +359,29 @@ protected void detectDeadExecutions() {
     LOG.debug("Deleting executions with unresolved tasks.");
 
     Map<String, Instant> unresolvedTaskToNewestExecution = new HashMap<>();
-    schedulerTaskRepository
-      .getScheduledExecutions(
+    schedulerTaskRepository.getScheduledExecutions(
         ScheduledExecutionsFilter.all(),
-        execution ->  unresolvedTaskToNewestExecution.merge(
-          execution.taskInstance.getTaskName(),
-          execution.executionTime,
-          (oldValue, newValue) -> oldValue.isAfter(newValue) ? oldValue : newValue
-        ));
-
-    taskResolver
-        .getUnresolved()
-        .stream()
+        execution ->
+            unresolvedTaskToNewestExecution.merge(
+                execution.taskInstance.getTaskName(),
+                execution.executionTime,
+                (oldValue, newValue) -> oldValue.isAfter(newValue) ? oldValue : newValue));
+
+    taskResolver.getUnresolved().stream()
         .map(UnresolvedTask::getTaskName)
-        .filter(taskName -> {
-          Instant newestExecution = unresolvedTaskToNewestExecution.get(taskName);
+        .filter(
+            taskName -> {
+              Instant newestExecution = unresolvedTaskToNewestExecution.get(taskName);
 
-          if (newestExecution == null) {
-            // probably deleted by other node
-            return true;
-          }
+              if (newestExecution == null) {
+                // probably deleted by other node
+                return true;
+              }
 
-          Duration age = Duration.between(newestExecution, clock.now());
+              Duration age = Duration.between(newestExecution, clock.now());
 
-          return age.compareTo(deleteUnresolvedAfter) >= 0;
-        })
+              return age.compareTo(deleteUnresolvedAfter) >= 0;
+            })
         .forEach(
             taskName -> {
               LOG.warn(

db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/TaskResolver.java

@@ -17,7 +17,6 @@
 
 import com.github.kagkarlsson.scheduler.stats.StatsRegistry;
 import com.github.kagkarlsson.scheduler.task.Task;
-import java.time.Duration;
 import java.time.Instant;
 import java.util.ArrayList;
 import java.util.Arrays;

db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/DeadExecutionsTest.java

@@ -118,7 +118,6 @@ public void scheduler_should_detect_dead_execution_that_never_updated_heartbeat(
     assertThat(nonCompletingExecutionHandler.timesExecuted.get(), is(2));
   }
 
-
   public static class NonCompletingTask<T> extends OneTimeTask<T> {
     private final VoidExecutionHandler<T> handler;