Hello,
I am using ruote, ruote-amqp and python and was trying to write a
simple generic "tracer" participant that records the time elapsed
between each participant in a process. My plan is to use this data
later to graph the performance of the process.
I have reached here after many trials, during which I managed to throw
ruote into endless chain reactions. So far I have this much :
"""
Ruote.process_definition :name => 'import' do
sequence do
sequence :forget => true, :tag => 'trace' do
listen :to => !/tracer/, :wfid => 'current'
tracer
_redo :ref => 'trace'
end
sequence do
iterator :on_field => 'packages', :to_field => 'package'
do
sequence do
getlog
updaterep
end
end
end
undo :ref => 'trace'
end
end
"""
My reasoning so far is fire a tagged forgotten subprocess that listens
to anything in the current process except the tracer participant. When
triggered it calls tracer and rewinds.
The main process does its things and then cancels the tagged forgotten
subprocess.
As it stands the main process works, but tracer never gets triggered.
Any help appreciated, thanks!
--
you received this message because you are subscribed to the "ruote users" group.
to post : send email to [email protected]
to unsubscribe : send email to [email protected]
more options : http://groups.google.com/group/openwferu-users?hl=en
