jmettraux

    # The context will call this method for each msg sucessfully processed
    # by the worker.
    #
    def on_msg(msg)

      puts(fancy_print(msg, @noisy)) if @noisy

      return if msg['action'] == 'noop'

      @on_msg_mutex.synchronize do

jmettraux

*.swp

jmettraux

*.swp

jmettraux

jmettraux@sanma $ date; bx rake swf:executions_and_tasks

Thu Mar  1 13:32:50 JST 2012
WFTYPE            VER START                    WFID                                  RUNID                                  STC  ODT  OAT   OT
my_workflow      0.1b 2012-03-01 04:31:24 UTC  20120301-1331-bipihosa-mopoyu         ce51e5d5-d88a-4cfe-b19f-70fc9f1c97e0     5    0    1    0
count: 1

jmettraux

require 'rexml/document'
require 'pp'
require 'rubygems'
require 'ruote'

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

class FetchData
  include Ruote::LocalParticipant

jmettraux

define 'error_handler' do
  _if "${v:x} == 'y'" do
    error "something went wrong"
    # else
    participant 'admin'
end

jmettraux

# works fine

foreach concurrence ..., task: y
end

# conflict

concurrence
  foreach concurrence ..., task: x

jmettraux

# works fine

foreach concurrence ... task: y
end

# conflict

concurrence
  foreach concurrence ... task: x

jmettraux

jmettraux@sanma ~/r/right_site (master) 円 ak "require .thread"

config/environment.rb
4:    require 'thread'
No such file or directory - public/rightscale_core_ui

Rakefile
5:    require 'thread'

vendor/plugins/activerecord-activesalesforce-adapter/lib/active_record/connection_adapters/activesalesforce_adapter.rb

jmettraux

# master.rb

#$:.unshift('~/w/ruote/lib')
#$:.unshift('~/w/ruote-redis/lib')

require 'rubygems'
require 'rufus-json/automatic'
require 'ruote'
require 'redis'