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
     /// <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);
         }
     }