module DTK::Client::TaskStatusMixin

Public Instance Methods

list_task_info_aux(object_type, object_id) click to toggle source
# File lib/task_status.rb, line 39
def list_task_info_aux(object_type, object_id)
  response = TaskStatus.new(self, object_id, object_type).post_call(:form => :list)
  unless response.ok?
    DtkError.raise_error(response)
  end
  response.override_command_class("list_task")
  puts response.render_data
end
task_status_aux(mode, object_id, object_type, opts = {}) click to toggle source
# File lib/task_status.rb, line 20
def task_status_aux(mode, object_id, object_type, opts = {})
  case mode
    when :refresh
      TaskStatus::RefreshMode.new(self, mode, object_id, object_type).task_status(opts)
    when :snapshot 
      TaskStatus::SnapshotMode.new(self, mode, object_id, object_type).task_status(opts)
    when :stream  
      assembly_or_workspace_id = object_id
      task_status_stream(assembly_or_workspace_id)
    else
      legal_modes = [:refresh, :snapshot, :stream]
      raise DtkError::Usage.new("Illegal mode '#{mode}'; legal modes are: #{legal_modes.join(', ')}")
  end
end
task_status_stream(assembly_or_workspace_id, opts = {}) click to toggle source
# File lib/task_status.rb, line 35
def task_status_stream(assembly_or_workspace_id, opts = {})
  TaskStatus::StreamMode.new(self, :stream, assembly_or_workspace_id, :assembly).get_and_render(opts)
end