diff --git a/aws-dynamodb-conduit.cabal b/aws-dynamodb-conduit.cabal
--- a/aws-dynamodb-conduit.cabal
+++ b/aws-dynamodb-conduit.cabal
@@ -2,7 +2,7 @@
 -- documentation, see http://haskell.org/cabal/users-guide/
 
 name:                aws-dynamodb-conduit
-version:             0.1.0.5
+version:             0.1.0.6
 synopsis:            Conduit-based interface for AWS DynamoDB
 -- description:         
 homepage:            https://github.com/srijs/haskell-aws-dynamodb-query
diff --git a/src/Aws/DynamoDb/Commands/Query/Conduit.hs b/src/Aws/DynamoDb/Commands/Query/Conduit.hs
--- a/src/Aws/DynamoDb/Commands/Query/Conduit.hs
+++ b/src/Aws/DynamoDb/Commands/Query/Conduit.hs
@@ -17,7 +17,7 @@
 import Control.Monad.IO.Class (liftIO)
 import Control.Monad.Trans.Class (lift)
 import Control.Monad.Trans.Parser (ParserT(..), ResultM(..), runStateParserT)
-import Control.Monad.Trans.Resource (register, runResourceT, throwM)
+import Control.Monad.Trans.Resource (register, runResourceT, throwM, transResourceT)
 import Control.Monad.Trans.State (StateT, modify)
 import Control.Monad.Trans.Writer (WriterT, tell, runWriterT)
 
@@ -61,7 +61,7 @@
     key "ConsumedCapacity" = parse  >>= lift . modify . setConsumed . Just
     key "LastKey"          = pvalue >>= lift . modify . setLastKey  . parseMaybe parseAttributeJson
     key "Items"            = parray . const $ parse >>= lift . lift . tell . maybeToSeq
-    key _                  = return ()
+    key _                  = pvalue >> return ()
     setCount    c icq = icq { incompleteCount    = c }
     setScanned  c icq = icq { incompleteScanned  = c }
     setConsumed c icq = icq { incompleteConsumed = c }
@@ -78,7 +78,8 @@
 consume p rsrc = do
   src <- lift $ do
     (src, finalize) <- unwrapResumable rsrc
-    register (runResourceT finalize)
+    finalize' <- transResourceT return finalize
+    register finalize'
     return src
   fuse src $ conduitWriterParserT p