diff --git a/library/Potoki/Hasql/Consume.hs b/library/Potoki/Hasql/Consume.hs
--- a/library/Potoki/Hasql/Consume.hs
+++ b/library/Potoki/Hasql/Consume.hs
@@ -13,6 +13,13 @@
 import           Potoki.Hasql.Error.Types  
 
 
+executeBatchQueryConcurrently :: E.Query (Vector params) () -> Int -> Int -> B.Settings -> Consume params (Either Error ())
+executeBatchQueryConcurrently query batchSize amountOfConnections settings =
+  transform batchTransform (right' O.concat)
+  where
+    batchTransform =
+      F.concurrently amountOfConnections (F.consume (executeBatchQuery query batchSize settings))
+
 executeBatchQuery :: E.Query (Vector params) () -> Int -> B.Settings -> Consume params (Either Error ())
 executeBatchQuery query batchSize settings =
   transform
diff --git a/potoki-hasql.cabal b/potoki-hasql.cabal
--- a/potoki-hasql.cabal
+++ b/potoki-hasql.cabal
@@ -1,7 +1,7 @@
 name:
   potoki-hasql
 version:
-  1.2
+  1.3
 synopsis:
   Integration of "potoki" and "hasql".
 description:
@@ -58,3 +58,5 @@
     bytestring >= 0.10.8.2 && < 0.11,
     vector >= 0.12.0.1 && < 0.13,
     profunctors >= 5.2.2 && < 5.3
+  ghc-options:
+    -Wall