Skip to content

Commit

Permalink
Apply auto-formatting rules
Browse files Browse the repository at this point in the history
  • Loading branch information
weco-bot committed Oct 19, 2020
1 parent d4ecba6 commit 55411ad
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 4 deletions.
Expand Up @@ -29,7 +29,8 @@ class ElasticRetriever[T](client: ElasticClient, index: Index)(
.flatMap {
case RequestFailure(_, _, _, error) => Future.failed(error.asException)
case RequestSuccess(_, _, _, response) if !response.found =>
warn(s"Asked to look up ID $id in index $index, got response $response")
warn(
s"Asked to look up ID $id in index $index, got response $response")
Future.failed(new RetrieverNotFoundException(id))
case RequestSuccess(_, _, _, response) =>
response.safeTo[T] match {
Expand Down
Expand Up @@ -59,6 +59,7 @@ trait WorkerServiceFixture extends LocalWorksVhs with SQS with Akka {
def getWorksSent(workSender: MemoryMessageSender): Seq[String] =
workSender.messages.map { _.body }

def getImagesSent(imageSender: MemoryMessageSender): Seq[MergedImage[DataState.Unidentified]] =
def getImagesSent(imageSender: MemoryMessageSender)
: Seq[MergedImage[DataState.Unidentified]] =
imageSender.getMessages[MergedImage[DataState.Unidentified]]
}
Expand Up @@ -181,7 +181,8 @@ class MergerWorkerServiceTest
}
}

it("if it merges two Works, it sends two onward results (one merged, one redirected)") {
it(
"if it merges two Works, it sends two onward results (one merged, one redirected)") {
val (digitisedWork, physicalWork) = sierraSourceWorkPair()

val works = List(physicalWork, digitisedWork)
Expand Down Expand Up @@ -362,6 +363,7 @@ class MergerWorkerServiceTest
def getWorksSent(senders: Senders): Seq[String] =
getWorksSent(senders.works)

def getImagesSent(senders: Senders): Seq[MergedImage[DataState.Unidentified]] =
def getImagesSent(
senders: Senders): Seq[MergedImage[DataState.Unidentified]] =
getImagesSent(senders.images)
}

0 comments on commit 55411ad

Please sign in to comment.