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

Improvements

Browse source
This commit is contained in:
Marius Vasile Vușcan 2025-01-14 12:23:21 +02:00
parent f27563a93f
commit 7df058dd2a
No known key found for this signature in database
GPG key ID: E0EC75631D902E06
1 changed files with 1 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/modules/Elsa.Workflows.Core/Services/VariablePersistenceManager.cs
View file

@ -113,27 +113,11 @@ public class VariablePersistenceManager : IVariablePersistenceManager
/// <inheritdoc />
public async Task DeleteVariablesAsync(WorkflowExecutionContext context)
{
var cancellationToken = context.CancellationTokens.ApplicationCancellationToken;
var activityContexts = context.ActivityExecutionContexts.ToList();
foreach (var activityContext in activityContexts)
{
var variables = GetLocalVariables(activityContext).ToList();
foreach (var variable in variables)
{
var block = variable.GetBlock(activityContext.ExpressionExecutionContext);
var metadata = (VariableBlockMetadata)block.Metadata!;
var driver = _storageDriverManager.Get(metadata.StorageDriverType!);
if (driver == null)
continue;
var id = GetStateId(variable);
var storageDriverContext = new StorageDriverContext(activityContext, variable, cancellationToken);
await driver.DeleteAsync(id, storageDriverContext);
}
await DeleteVariablesAsync(activityContext);
}
}