Resume repair after error

Author: Radovan Zvoncek

src/main/java/com/spotify/reaper/service/RepairRunner.java

@@ -157,6 +157,9 @@ public void run() {
         case PAUSED:
           context.repairManager.scheduleRetry(this);
           break;
+        case ERROR:
+          resumeAfterError();
+          break;
       }
     } catch (RuntimeException e) {
       LOG.error("RepairRun FAILURE");
@@ -193,6 +196,20 @@ private void start() {
     startNextSegment();
   }
 
+  /**
+   * Resumes execution of a repair run. Does the same as {@code start()}, except setting start time.
+   */
+  private void resumeAfterError() {
+    LOG.info("Repairs for repair run #{} resuming after error", repairRunId);
+    synchronized (this) {
+      RepairRun repairRun = context.storage.getRepairRun(repairRunId).get();
+      context.storage.updateRepairRun(repairRun.with()
+          .runState(RepairRun.RunState.RUNNING)
+          .build(repairRun.getId()));
+    }
+    startNextSegment();
+  }
+
   /**
    * Concludes the repair run.
    */