kamal.rb

require 'rubygems'
require 'ruote'

engine = Ruote::Engine.new(Ruote::Worker.new(Ruote::HashStorage.new))

pdef = Ruote.define do
  alice
  bob
end

engine.register do
  catchall # all goes in the storage_participant
end

engine.noisy = true

wfid = engine.launch(pdef)

engine.wait_for(:alice)

ps = engine.ps(wfid)

root = ps.expressions.first
root.update_tree([ "define", {}, [
  [ "alice", {}, [] ],
  [ "charly", {}, [] ],
  [ "bob", {}, [] ]
] ])
root.persist

wi = engine.storage_participant.first
engine.storage_participant.proceed(wi)

engine.wait_for(:charly)