diff --git a/components/electric/lib/electric/postgres/extension/schema_loader/epgsql.ex b/components/electric/lib/electric/postgres/extension/schema_loader/epgsql.ex
index 14bf123052..becdebd1d3 100644
--- a/components/electric/lib/electric/postgres/extension/schema_loader/epgsql.ex
+++ b/components/electric/lib/electric/postgres/extension/schema_loader/epgsql.ex
@@ -148,10 +148,8 @@ defmodule Electric.Postgres.Extension.SchemaLoader.Epgsql do
   end
 
   @impl true
-  def migration_history(pool, version) do
-    checkout!(pool, fn conn ->
-      Extension.migration_history(conn, version)
-    end)
+  def migration_history(origin, version) do
+    Client.pooled_query!(origin, Extension.migration_history_query(), [version])
   end
 
   @impl true