SagaEntity.cs

public class BatchSaga : IContainSagaData {
  public int TotalWork { get; set; }
  public int WorkCompleted { get; set }
  
  public void Handle(WorkCompleted message) {
    WorkCompleted++;
    
    if (WorkCompleted == TotalWork) {
      Bus.Send(new BatchDone());
      MarkAsComplete();
    }
  }
}