View on GitHub
File Changes
            , putPoolProduction = putPoolProduction'
            , readPoolProduction = readPoolProduction'
            }
-
        = liftIO $ do
-
        atomically $ forM_ pairs $ \(pool, slot) ->
+
        = do
+
        run . atomically $ forM_ pairs $ \(pool, slot) ->
            unsafeRunExceptT $ putPoolProduction slot pool
-
        atomically' $ forM_ pairs $ \(pool, slot) ->
+
        run . atomically' $ forM_ pairs $ \(pool, slot) ->
            unsafeRunExceptT $ putPoolProduction' slot pool
-
        forM_ (uniqueEpochs pairs) $ \epoch -> do
+
        monitor $ classify (length pairs > 100) "productions > 100"
+
        monitor $ classify (length pairs > 1000) "productions > 1000"
+
        run . forM_ (uniqueEpochs pairs) $ \epoch -> do
            res' <- atomically' $ readPoolProduction' epoch
            atomically (readPoolProduction epoch) `shouldReturn` res'