From 7df058dd2a009919cba1d60d104df7fd134031e4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Marius=20Vasile=20Vu=C8=99can?= Date: Tue, 14 Jan 2025 12:23:21 +0200 Subject: [PATCH] Improvements --- .../Services/VariablePersistenceManager.cs | 18 +----------------- 1 file changed, 1 insertion(+), 17 deletions(-) diff --git a/src/modules/Elsa.Workflows.Core/Services/VariablePersistenceManager.cs b/src/modules/Elsa.Workflows.Core/Services/VariablePersistenceManager.cs index 6d608a00f..61469bec6 100644 --- a/src/modules/Elsa.Workflows.Core/Services/VariablePersistenceManager.cs +++ b/src/modules/Elsa.Workflows.Core/Services/VariablePersistenceManager.cs @@ -113,27 +113,11 @@ public class VariablePersistenceManager : IVariablePersistenceManager /// 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); } }