Skip to content

Commit

Permalink
Fix use of Transactors
Browse files Browse the repository at this point in the history
  • Loading branch information
Simon Dumas committed Apr 17, 2024
1 parent 728a16c commit af51024
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions ship/src/main/scala/ch/epfl/bluebrain/nexus/ship/Main.scala
Original file line number Diff line number Diff line change
Expand Up @@ -61,12 +61,7 @@ object Main
InitShip(r).use { case (config, eventsStream, xas) =>
for {
start <- clock.realTimeInstant
reportOrError <- Transactors
.init(config.database)
.use { xas =>
RunShip(eventsStream, config.input, xas)
}
.attempt
reportOrError <- RunShip(eventsStream, config.input, xas).attempt
end <- clock.realTimeInstant
_ <- ShipSummaryStore.save(xas, start, end, r, reportOrError)
_ <- IO.fromEither(reportOrError)
Expand Down

0 comments on commit af51024

Please sign in to comment.