SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Removed optional purge

Browse source
This commit is contained in:
Marius Vasile Vușcan 2025-03-12 13:58:38 +02:00
parent c2161d057a
commit 1ea83aff14
No known key found for this signature in database
GPG key ID: E0EC75631D902E06
3 changed files with 0 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/modules/Elsa.Workflows.Runtime/Features/WorkflowRuntimeFeature.cs
View file

@ -154,15 +154,6 @@ public class WorkflowRuntimeFeature(IModule module) : FeatureBase(module)
Services.Configure<WorkflowInboxCleanupOptions>(options => { options.IsEnabled = false; });
return this;
}
/// <summary>
/// Disables the purge bookmark queue recurring task.
/// </summary>
public WorkflowRuntimeFeature DisablePurgeBookmarkQueueRecurringTask()
{
Services.Configure<BookmarkQueuePurgeOptions>(options => { options.IsEnabled = false; });
return this;
}
/// <summary>
/// Register the specified workflow type.

5
src/modules/Elsa.Workflows.Runtime/Options/BookmarkQueuePurgeOptions.cs
View file

@ -14,9 +14,4 @@ public class BookmarkQueuePurgeOptions
/// The number of records to clean up per sweep.
/// </summary>
public int BatchSize { get; set; } = 1000;
/// <summary>
/// Whether the bookmark queue purge is enabled.
/// </summary>
public bool IsEnabled { get; set; } = true;
}

6
src/modules/Elsa.Workflows.Runtime/Services/DefaultBookmarkQueuePurger.cs
View file

@ -15,12 +15,6 @@ public class DefaultBookmarkQueuePurger(IBookmarkQueueStore store, ISystemClock
{
public async Task PurgeAsync(CancellationToken cancellationToken = default)
{
if (!options.Value.IsEnabled)
{
logger.LogInformation("Purging bookmark queue is disabled");
return;
}
var currentPage = 0;
var now = systemClock.UtcNow;
var thresholdDate = now - options.Value.Ttl;