iamer

** worker#step intercepted exception **

Please report issue or fix your Ruote::FsStorage impl,

or override Ruote::Worker#handle_step_error(e, msg) so that
the issue is dealt with appropriately. For example:

    class Ruote::Worker
      def handle_step_error(e, msg)
        logger.error('ruote step error: ' + e.inspect)

iamer

Ruote.process_definition 'test_leak' do
  sequence do
    set 'debug_trace' => 'True'
    set 'debug_dump' => 'True'
    set 'v:sourceprojects' => []
    set 'bla' => ['a','b','c','d','e']
    repeat :timeout => '2m', :on_timeout => 'error' do
      iterator :on_field => 'bla', :to => 'v:action' do
        sequence do
          echo '$v:action'

iamer

diff --git a/lib/ruote/dashboard.rb b/lib/ruote/dashboard.rb
index b524ca4..f9257e2 100644
--- a/lib/ruote/dashboard.rb
+++ b/lib/ruote/dashboard.rb
@@ -105,7 +105,7 @@ module Ruote
     #
     def worker
 
- @context.worker
+ @context.worker if @context.respond_to?('worker')

iamer

In one process

$engine = Ruote::Engine.new(
  Ruote::Worker.new(
    Ruote::FsStorage.new(ENV['SERVER_DATABASE'])
  )
)


In another process