diff --git a/src/modules/retention/Elsa.Retention/Jobs/CleanupJob.cs b/src/modules/retention/Elsa.Retention/Jobs/CleanupJob.cs
index 69196363..b045cc41 100644
--- a/src/modules/retention/Elsa.Retention/Jobs/CleanupJob.cs
+++ b/src/modules/retention/Elsa.Retention/Jobs/CleanupJob.cs
@@ -40,7 +40,16 @@ public async Task ExecuteAsync(CancellationToken cancellationToken = default)
 
             while (true)
             {
-                var page = await workflowInstanceStore.FindManyAsync(filter, pageArgs, cancellationToken);
+                Page<WorkflowInstance> page;
+                try
+                {
+                    page = await workflowInstanceStore.FindManyAsync(filter, pageArgs, cancellationToken);
+                }
+                catch (Exception ex)
+                {
+                    _logger.LogError(ex, "Exception in FindManyAsync during CleanupJob. Policy: {Policy}. Cleanup aborted for this policy.", policy.Name);
+                    break;
+                }
 
                 if (page.Items.Count == 0)
                 {