Module: DTK::Client::TaskStatusMixin

Included in:
CommandBaseThor
Defined in:
lib/task_status.rb

Instance Method Summary collapse

Instance Method Details

#list_task_info_aux(object_type, object_id) ⇒ Object 



39
40
41
42
43
44
45
46
 
# 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 = {}) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# 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 = {}) ⇒ Object 



35
36
37
 
# 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