Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.