module Proxy::Dynflow::Helpers

Public Instance Methods

cancel_task(task_id) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 13
def cancel_task(task_id)
  execution_plan = world.persistence.load_execution_plan(task_id)
  cancel_events = execution_plan.cancel
  { :task_id => task_id, :canceled_steps_count => cancel_events.size }
end
task_status(task_id) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 19
def task_status(task_id)
  ep = world.persistence.load_execution_plan(task_id)
  ep.to_hash.merge(:actions => ep.actions.map(&:to_hash))
rescue KeyError => e
  status 404
  {}
end
tasks_count(state) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 27
def tasks_count(state)
  state ||= 'all'
  filter = state != 'all' ? { :filters => { :state => [state] } } : {}
  tasks = world.persistence.find_execution_plans(filter)
  { :count => tasks.count, :state => state }
end
trigger_task(*args) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 8
def trigger_task(*args)
  triggered = world.trigger(*args)
  { :task_id => triggered.id }
end
world() click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 4
def world
  Proxy::Dynflow.world
end