Add remove terminated workflows option to RedisPersistenceProvider

Author: Tolstovku

src/providers/WorkflowCore.Providers.Redis/ServiceCollectionExtensions.cs

@@ -19,12 +19,12 @@ public static WorkflowOptions UseRedisLocking(this WorkflowOptions options, stri
             return options;
         }
 
-        public static WorkflowOptions UseRedisPersistence(this WorkflowOptions options, string connectionString, string prefix, bool deleteComplete = false)
+        public static WorkflowOptions UseRedisPersistence(this WorkflowOptions options, string connectionString, string prefix,
+            bool deleteComplete = false, bool deleteTerminated = false)
         {
-            options.UsePersistence(sp => new RedisPersistenceProvider(connectionString, prefix, deleteComplete, sp.GetService<ILoggerFactory>()));
+            options.UsePersistence(sp => new RedisPersistenceProvider(connectionString, prefix, deleteComplete, deleteTerminated, sp.GetService<ILoggerFactory>()));
             return options;
         }
-
         public static WorkflowOptions UseRedisEventHub(this WorkflowOptions options, string connectionString, string channel)
         {
             options.UseEventHub(sp => new RedisLifeCycleEventHub(connectionString, channel, sp.GetService<ILoggerFactory>()));

src/providers/WorkflowCore.Providers.Redis/Services/RedisPersistenceProvider.cs

@@ -27,17 +27,19 @@ public class RedisPersistenceProvider : IPersistenceProvider
 
         private readonly JsonSerializerSettings _serializerSettings = new JsonSerializerSettings { TypeNameHandling = TypeNameHandling.All };
         private readonly bool _removeComplete;
+        private readonly bool _removeTerminated;
 
         public bool SupportsScheduledCommands => false;
 
-        public RedisPersistenceProvider(string connectionString, string prefix, bool removeComplete, ILoggerFactory logFactory)
+        public RedisPersistenceProvider(string connectionString, string prefix, bool removeComplete, bool removeTerminated, ILoggerFactory logFactory)
         {
             _connectionString = connectionString;
             _prefix = prefix;
             _logger = logFactory.CreateLogger(GetType());
             _multiplexer = ConnectionMultiplexer.Connect(_connectionString);
             _redis = _multiplexer.GetDatabase();
             _removeComplete = removeComplete;
+            _removeTerminated = removeTerminated;
         }
 
         public async Task<string> CreateNewWorkflow(WorkflowInstance workflow, CancellationToken _ = default)
@@ -67,7 +69,7 @@ public async Task PersistWorkflow(WorkflowInstance workflow, CancellationToken _
             else
             {
                 await _redis.SortedSetRemoveAsync($"{_prefix}.{WORKFLOW_SET}.{RUNNABLE_INDEX}", workflow.Id);
-                if (_removeComplete && workflow.Status == WorkflowStatus.Complete)
+                if ((_removeComplete && workflow.Status == WorkflowStatus.Complete) || (_removeTerminated && workflow.Status == WorkflowStatus.Terminated))
                     await _redis.HashDeleteAsync($"{_prefix}.{WORKFLOW_SET}", workflow.Id);
             }
         }