Skip to content

Commit

Permalink
Minor edits
Browse files Browse the repository at this point in the history
  • Loading branch information
Rainer Simon committed Dec 21, 2017
1 parent 0474756 commit afc97a8
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions app/harvesting/HasBatchImport.scala
Original file line number Diff line number Diff line change
Expand Up @@ -19,22 +19,22 @@ trait HasBatchImport[T] {
}
}
} flatMap { failedRecords =>
Logger.info("Imported " + (records.size - failedRecords.size) + " records")
Logger.info(s"Imported ${records.size - failedRecords.size} records")
if (failedRecords.size > 0 && retries > 0) {
Logger.warn(failedRecords.size + " gazetteer records failed to import - retrying")
Logger.warn(s"${failedRecords.size} gazetteer records failed to import - retrying")

// Start first retry immediately and then increases wait time for each subsequent retry
val backoff = (MAX_RETRIES - retries) * BACKOFF_MS
if (backoff > 0) {
Logger.info("Waiting... " + backoff + "ms")
Logger.info(s"Waiting... ${backoff}ms")
Thread.sleep(backoff)
}

Logger.debug("Retrying now.")
importRecords(failedRecords, retries - 1)
} else {
if (failedRecords.size > 0) {
Logger.error(failedRecords.size + " gazetteer records failed without recovery")
Logger.error(s"${failedRecords.size} gazetteer records failed without recovery")
failedRecords.foreach(record => Logger.error(record.toString))
} else {
Logger.info("No failed imports")
Expand Down

0 comments on commit afc97a8

Please sign in to comment.