From 7ebb2d87bf10873830acbf409693b2b0cc38d992 Mon Sep 17 00:00:00 2001 From: Felipe Lessa Date: Tue, 4 Sep 2012 00:27:18 -0300 Subject: [PATCH] Throw PersistMarshalError instead of using fail. --- src/Database/Esqueleto/Internal/Sql.hs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Database/Esqueleto/Internal/Sql.hs b/src/Database/Esqueleto/Internal/Sql.hs index acdd68a..337f94f 100644 --- a/src/Database/Esqueleto/Internal/Sql.hs +++ b/src/Database/Esqueleto/Internal/Sql.hs @@ -9,8 +9,8 @@ module Database.Esqueleto.Internal.Sql import Control.Applicative (Applicative(..), (<$>)) import Control.Arrow (first) +import Control.Exception (throwIO) import Control.Monad (ap) -import Control.Monad.IO.Class (MonadIO) import Control.Monad.Logger (MonadLogger) import Data.List (intersperse) import Data.Monoid (Monoid(..), (<>)) @@ -168,7 +168,7 @@ selectSource query = src mrow <- C.await case process <$> mrow of Just (Right r) -> C.yield r >> massage - Just (Left err) -> fail (T.unpack err) + Just (Left err) -> liftIO $ throwIO $ PersistMarshalError err Nothing -> return () process = sqlSelectProcessRow