Merge pull request #81 from mhichb/try-catch-findmany

try-catch for FindManyAsync

Author: sfmskywalker

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)
                 {