Skip to content

Commit 149456d

Browse files
committed
.
1 parent 566fa27 commit 149456d

2 files changed

Lines changed: 4 additions & 5 deletions

File tree

core/nhcore.cabal

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -203,6 +203,10 @@ library
203203
test-suite nhcore-test
204204
import: common_cfg
205205
default-language: GHC2021
206+
ghc-options:
207+
-rtsopts
208+
-with-rtsopts=-N
209+
206210
other-modules:
207211
Service.EventStore.InMemorySpec
208212
Service.EventStore.Postgres.Internal.SubscriptionStoreSpec

core/service/Service/EventStore/Postgres/Internal.hs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,6 @@ defaultOps ::
8282
Ops eventType
8383
defaultOps = do
8484
let acquire cfg = do
85-
print [fmt|acquiring connection|]
8685
toConnectionSettings cfg
8786
|> toConnectionPoolSettings
8887
|> HasqlPool.acquire
@@ -107,7 +106,6 @@ defaultOps = do
107106
subscriptionStore |> Notifications.connectTo connection
108107

109108
let release connection = do
110-
print [fmt|releasing connection|]
111109
case connection of
112110
Sessions.MockConnection ->
113111
pass
@@ -122,7 +120,6 @@ withConnection ::
122120
Config -> (Sessions.Connection -> Task PostgresStoreError result) -> Ops eventType -> Task PostgresStoreError result
123121
withConnection cfg callback ops = do
124122
connection <- ops.acquire cfg |> Task.mapError ConnectionAcquisitionError
125-
print [fmt|running callback|]
126123
result <- callback connection |> Task.asResult
127124
ops.release connection |> Task.mapError ConnectionReleaseError
128125
case result of
@@ -135,12 +132,10 @@ withConnectionAndError ::
135132
Config -> (Sessions.Connection -> Task Error result) -> Ops eventType -> Task Error result
136133
withConnectionAndError cfg callback ops = do
137134
connection <- ops.acquire cfg |> Task.mapError (ConnectionAcquisitionError .> toText .> StorageFailure)
138-
print [fmt|running callback|]
139135
result <- callback connection |> Task.asResult
140136
ops.release connection |> Task.mapError (ConnectionReleaseError .> toText .> StorageFailure)
141137
case result of
142138
Ok res -> do
143-
print [fmt|res: #{toText res}|]
144139
Task.yield res
145140
Err err ->
146141
Task.throw err

0 commit comments

Comments
 (0)