“noisy” mode

When testing/debugging a workflow, the NOISY mode might come in handy. This mode prints all the messages happening locally (sorry if you have more than one workers, there’ll be one different output per worker).

To switch it on, one has to set noisy to true in the Ruote::Dashboard, like in line 8 below.

Let’s consider this small ruote test script:

            require 'pp'
            require 'rufus-json/automatic'
            require 'ruote'
            ruote = Ruote::Dashboard.new(Ruote::Worker.new(Ruote::HashStorage.new))
            ruote.noisy = ENV['NOISY'] == 'true'
            ruote.register do
              alpha Ruote::StorageParticipant
            pdef =
              Ruote.define do
                concurrence :count => 1 do
                  cursor :tag => 'C1' do
                    alpha :timeout => '10s'
                  cursor :tag => 'C2', :lose => true do
                    wait '2s' # simulating 'bravo' replying before alpha
                    jump :to => 'alpha', :ref => 'C1'
            wfid = ruote.launch(pdef)

(gist at https://gist.github.com/4332547)

Running it with:

            NOISY=true bundle exec ruby gist4332547.rb

Will output:

Roughly, each line is a “msg”, an event just processed by the local worker. Let’s look at a single line:

Which can be split into

The first block is mostly about when the msg got processed. The first number is just a counter modulo 10 for pointing at msgs more easily. The last number, right after the timestamp, is the last part of the worker instance object_id, it can be useful when debugging environments with multiple ruote workers (interleaved tests for example).

The second block is composed of the action code and a star. The star is just here to separate the code from the expression identifier (fei) that follows. This action code is a short version of the msg action [name]. See below for a list of action codes and their corresponding action names.


action codes

  • la: “launch”
  • ap: “apply”
  • re: “reply”
  • di: “dispatch”
  • dd: “dispatched”
  • en: “entered_tag”
  • le: “left_tag”
  • ca: “cancel”
  • dc: “dispatch_cancel”
  • te: “terminated”
  • ce: “ceased” (orphan terminates)
  • va: “set_variable”