On Wed, Jun 29, 2011 at 3:50 PM, John Mettraux <[email protected]> wrote: > > On Wed, Jun 29, 2011 at 03:26:32PM -0700, Ian Smith-Heisters wrote: >> >> yes, that's pretty much what we've been doing, and what we'll continue >> doing in our tests. It does mean the tests can't use multiple workers >> because the observer doesn't work cross-process without the >> aforementioned global event queue. This is somewhat problematic >> because it introduces differences between the test and production >> environments. > > Hello, > > Maybe it's time for a polling wait_for, a bit less "fast" than the current > reacting one, but that is OK with multiple workers. > > ---8<--- > def polling_wait_for(wfid, timeout=nil) > start = Time.now > loop do > sleep 0.350 > ps = @engine.ps(wfid) > break if ps.nil? # process terminated > break if ps.errors.size > 0 # process ran into an error > break if timeout and ((Time.now - start) > timeout) > end > end > --->8---
Thanks. This is working pretty well for us in initial tests. I gussied it up into this: https://gist.github.com/1070538 Cheers, Ian > > > Best regards, > > -- > John Mettraux - http://jmettraux.wordpress.com > > -- > 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 > -- 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
