Success().value! == Dry::Monads::Unit

class BaseStep
  include Dry::Monads[:result]

  def call(context)
    Success()
  end
end

class Step1 < BaseStep; end
class Step2 < BaseStep; end

redis = ConnectionPool.new { Redis.new }
redis_adapter = Novel::RepositoryAdapters::Redis.new(connection_pool: redis)
repository = Novel::SagaRepository.new(adapter: redis_adapter)

saga = Novel.compose(logger: Logger.new(STDOUT), repository: repository, timeouts: 5) # timeout in seconds
      .build(name: :test_saga)
      .register_step(:step1, activity: { command: Step1.new },              compensation: { command: Step1.new })
      .register_step(:step2, activity: { command: Step2.new, async: true }, compensation: { command: Step2.new })
      .build

saga.call()