observe.rb

class RuoteObserver
  def initialize(context, options={})
  end

  def on_msg(msg)
    case msg['action']
    when 'launch'
      msg['launched_at'] = Time.now
    when 'terminated'
      Project.logger.debug "{#{msg['wfid']}} [#{msg['workitem']['wf_name']}] took %.2fs" % (Time.now - msg['launched_at'])
    end
  end
end