private def pollRunningReindexes()

in app/com/gu/floodgate/reindex/BulkJobActor.scala [253:259]

• 7 lines of code
• 4 McCabe index (conditional complexity)

  private def pollRunningReindexes(id: String, environment: String): Unit = {
    runningJobService.getRunningJob(id, environment) match {
      case Left(RunningJobNotFound(_)) => self ! ReindexNext
      case Left(error: CustomError)    => logger.warn(s"Job present in table, but failed to read: ${error.message}")
      case Right(job)                  => context.system.scheduler.scheduleOnce(PollInterval, self, Polling(id, environment))
    }
  }