ypz

#!/usr/bin/env ruby

require 'ruote'

class Alpha < ::Ruote::Participant
  def on_workitem
    n = workitem.fields["iteration"].nil? ? 1 : workitem.fields["iteration"] + 1
    workitem.set_field("iteration", n)
    workitem.set_field("completed", true) if n >= 10

ypz

#!/usr/bin/env ruby

require 'rubygems'
require 'json'
require 'ruote'
require 'ruote/storage/fs_storage'
require 'pp'

abort("Usage: ack.rb <wfid>") if ARGV[0].nil?
wfid = ARGV[0] 

ypz

#!/usr/bin/env ruby

require 'rubygems'
require 'json'
require 'ruote'
require 'ruote/storage/fs_storage'

@ruote =  Ruote::Dashboard.new(Ruote::Worker.new(Ruote::FsStorage.new("/tmp/ruote_storage")))

class Alpha < ::Ruote::Participant