如何在Elsa Workflows中为已执行活动实现撤销(Undo)功能？

我正在实现一批和SignalReceived活动功能类似的自定义活动，这类活动执行后会进入挂起状态，需要在代码其他位置手动恢复。现在需要实现撤销已执行的这类活动，让用户可以重新录入对应的数据。

我尝试通过以下代码实现该功能：

// 找到要撤销活动对应的工作流实例
var instance = await workflowInstanceStore.FindByIdAsync(workflowInstanceId, cancellationToken);

// 手动设置要回退到的活动，并清空当前阻塞活动
instance.CurrentActivity = new ScheduledActivity(activityId);
instance.BlockingActivities.Clear();

// 获取现有输入并保存修改后的工作流实例
var input = await GetWorkflowInputAsync(instance, cancellationToken);
await workflowStorageService.SaveAsync(input, instance, cancellationToken);

// 重新执行工作流实例，指向要回退到的活动
await workflowInstanceExecutor.ExecuteAsync(instance, activityId, cancellationToken: cancellationToken);

但该方案存在两个问题：

• 手动修改工作流实例的活动后，通过workflowStorageService保存的更改没有被保留，活动执行日志也未更新；
• 调用workflowInstanceExecutor.ExecuteAsync重新执行时，目标活动虽然会重新执行，但会立即恢复并直接跳转到下一个活动，无法像正常执行那样保持挂起状态。

是否有更优的解决方案？理想情况下我希望在活动实现外部执行撤销流程，目前无法访问ActivityExecutionContext对象（除非有其他注入方式）。

优化解决方案 #

1. 确保工作流实例状态正确持久化

直接修改CurrentActivity和BlockingActivities可能绕过了工作流引擎的状态跟踪机制，导致保存失效。可以尝试：

• 重置实例的Status为Idle或待执行状态；
• 清除实例ExecutionHistory中对应活动之后的执行记录，保证状态回退的一致性；
• 调用存储服务时，强制触发全量持久化（部分存储服务有增量更新逻辑，手动修改的字段未被标记为脏数据）。

2. 强制活动重新执行后进入挂起状态

重新执行时活动直接跳转，是因为引擎认为该活动已执行过，跳过了挂起逻辑。可以通过以下方式处理：

• 在重新执行前，给目标活动添加强制挂起标记（比如在工作流输入中新增ForceSuspend参数）；
• 若无法修改活动内部逻辑，可在执行前重置活动的ExecutionStatus为NotStarted，让引擎判定这是首次执行，触发原生挂起逻辑。

3. 利用工作流内置回退机制（若支持）

如果使用的工作流引擎支持补偿/回退模式，直接创建回退命令而非手动修改实例状态：

• 构造指定目标活动ID的RollbackActivityCommand；
• 通过引擎命令调度器执行该命令，由引擎内部处理状态重置、日志更新和重新挂起逻辑，避免手动操作带来的不一致。

内容的提问来源于stack exchange，提问作者pyrox18