diff --git a/lib/oban/stager.ex b/lib/oban/stager.ex
index 38078b7b..fcc7ca31 100644
--- a/lib/oban/stager.ex
+++ b/lib/oban/stager.ex
@@ -135,6 +135,8 @@ defmodule Oban.Stager do
 
       %{staged_count: length(staged), staged_jobs: staged}
     end)
+  rescue
+    error in [DBConnection.ConnectionError, Postgrex.Error] -> {:error, error}
   end
 
   defp stage_scheduled(state, leader?: true) do