application.rb

config.after_initialize do
      ::RuoteEngine = Ruote::Engine.new(
        Ruote::Worker.new(
          Ruote::Redis::RedisStorage.new(::REDIS)))

      RuoteEngine.register_participant :turk_unit, TurkUnitParticipant

      RuoteEngine.register_participant :weighted_consensus, WeightedConsensusParticipant

      RuoteEngine.register_participant :printer do |workitem|
        puts workitem.fields['decisions']['default']['output'].inspect
      end
end

default_workflow.rb

Ruote.process_definition :name => 'DefaultWorkflow' do
  cursor do
    participant :unit, "step_name" => "default", "input" => "${f:task.input}"
    participant :weighted_consensus, "step_name" => "default"
    rewind :unless => '${f:decisions.default.ok}'
  end
end