uuid = get(:uuid)
items = []
- # Job tasks - for now do not include job tasks
- # tasks = JobTask.filter([['job_uuid', '=', uuid]]).results
- # tasks.each do |t|
- # items << t.work_unit("task #{items.size}")
- # end
-
# Jobs components
components = get(:components)
uuids = components.andand.collect {|_, v| v}
get(:output)
end
+ def child_summary
+ get(:tasks_summary)
+ end
+
def can_cancel?
true
end
"/jobs/#{uuid}"
end
- def child_summary
- get(:tasks_summary)
- end
-
def title
"job"
end
def created_at
t = get(:created_at)
- if t.andand.class == String
- Time.parse t
- else
- t
- end
+ t = Time.parse(t) if (t.andand.class == String)
+ t
end
def started_at
t = get(:started_at)
- if t.andand.class == String
- Time.parse t
- else
- t
- end
+ t = Time.parse(t) if (t.andand.class == String)
+ t
end
def finished_at
t = get(:finished_at)
- if t.andand.class == String
- Time.parse t
- else
- t
- end
+ t = Time.parse(t) if (t.andand.class == String)
+ t
end
def state_label
self.unreadable_children
end
+ def readable?
+ resource_class = ArvadosBase::resource_class_for_uuid(uuid)
+ resource_class.where(uuid: [uuid]).first rescue nil
+ end
+
protected
def get key
class WorkUnit
- # This is just an abstract class that documents the WorkUnit interface; a
- # class can implement the interface without being a subclass of WorkUnit.
+ # This is an abstract class that documents the WorkUnit interface
def label
# returns the label that was assigned when creating the work unit
end
def success?
- # returnis true if the work unit finished successfully,
+ # returns true if the work unit finished successfully,
# false if it has a permanent failure,
# and nil if the final state is not determined.
end
- def progress
+ def progress
# returns a number between 0 and 1
end
# returns uuid or pdh of output data, if any
end
+ def child_summary
+ # summary status of any children of this work unit
+ end
+
def can_cancel?
- # returns if this work unit is cancelable
+ # returns true if this work unit can be canceled
end
- def uri
- # returns the uri for this work unit
+ def readable?
+ # is the proxied object readable by current user?
end
- def child_summary
- # summary status of any children of this work unit
+ def uri
+ # returns the uri for this work unit
end
def title
<table>
<% [:uuid, :modified_by_user_uuid, :created_at, :started_at, :finished_at, :output, :priority].each do |k| %>
<% val = current_obj.send(k) if current_obj.respond_to?(k) %>
- <% unless val.nil? %>
+ <% if val %>
<tr>
<td style="padding-right: 1em">
<%= k.to_s %>:
%>
<% [:script, :repository, :script_version, :supplied_script_version, :nondeterministic].each do |k| %>
<% val = current_obj.send(k) if current_obj.respond_to?(k) %>
- <% unless val.nil? %>
+ <% if val %>
<tr>
<td style="padding-right: 1em">
<%= k.to_s %>:
<% if wu.state_label == 'Running' %>
- <div class="progress" style="margin-bottom: 0px">
- <span class="progress-bar progress-bar-<%= wu.state_bootstrap_class %>" style="width: <%= wu.progress*100 %>%;"></span>
- </div>
+ <% if @object.uuid == wu.uuid and wu.progress == 0.0 %>
+ <span class="label label-<%= wu.state_bootstrap_class %>"> Active </span>
+ <% else%>
+ <div class="progress" style="margin-bottom: 0px">
+ <span class="progress-bar progress-bar-<%= wu.state_bootstrap_class %>" style="width: <%= wu.progress*100 %>%;">
+ </span>
+ </div>
+ <% end %>
<% else %>
- <span class="label label-<%= wu.state_bootstrap_class %>"><%= wu.state_label%></span>
+ <span class="label label-<%= wu.state_bootstrap_class %>"><%= wu.state_label %></span>
<% end %>
<% if current_obj.log_collection %>
<% logCollection = Collection.find? current_obj.log_collection %>
<% if logCollection %>
- <%= link_to "Log", job_path(current_obj.uuid, anchor: "Log") %>
+ <%= link_to "Log", "#{current_obj.uri}#Log" %>
<% else %>
Log unavailable
<% end %>
<% end %>
<% elsif current_obj.state_label == "Running" %>
- <% job = Job.find? current_obj.uuid %>
- <% if job %>
- <%= link_to "Log", job_path(current_obj.uuid, anchor: "Log") %>
+ <% if current_obj.readable? %>
+ <%= link_to "Log", "#{current_obj.uri}#Log" %>
<% else %>
Log unavailable
<% end %>
<%# column offset 8 %>
<div class="col-md-3">
<span class="task-summary-status">
- <%= current_obj.child_summary[:done] %> <%= "task".pluralize(current_obj.child_summary[:done]) %> done,
- <%= current_obj.child_summary[:failed] %> failed,
- <%= current_obj.child_summary[:running] %> running,
- <%= current_obj.child_summary[:todo] %> pending
+ <% if current_obj.child_summary[:done] %>
+ <%= current_obj.child_summary[:done] %> <%= "child".pluralize(current_obj.child_summary[:done]) %> done,
+ <% end %>
+ <% if current_obj.child_summary[:failed] %>
+ <%= current_obj.child_summary[:failed] %> failed,
+ <% end %>
+ <% if current_obj.child_summary[:running] %>
+ <%= current_obj.child_summary[:running] %> running,
+ <% end %>
+ <% if current_obj.child_summary[:todo] %>
+ <%= current_obj.child_summary[:todo] %> pending
+ <% end %>
</span>
</div>
<% end %>
</div>
<% end %>
- <% if current_obj.state_label.in? ["Queued", "Running"] and @object.work_unit.can_cancel? and @object.editable? %>
+ <% if current_obj.state_label.in? ["Queued", "Running"] and current_obj.can_cancel? and @object.editable? %>
<%# column offset 11 %>
<div class="col-md-1 pipeline-instance-spacing">
<%= form_tag "#{current_obj.uri}/cancel", remote: true, style: "display:inline; padding-left: 1em" do |f| %>
<%= hidden_field_tag :return_to, url_for(@object) %>
- <%= button_tag "Cancel", {class: 'btn btn-xs btn-danger', id: "cancel-job-button"} %>
+ <%= button_tag "Cancel", {class: 'btn btn-xs btn-danger', id: "cancel-child-button"} %>
<% end %>
</div>
<% end %>
<div class="col-md-1">
<%= form_tag "#{wu.uri}/cancel", remote: true, style: "display:inline; padding-left: 1em" do |f| %>
<%= hidden_field_tag :return_to, url_for(@object) %>
- <%= button_tag "Cancel", {class: 'btn btn-xs btn-danger', id: "cancel-job-button"} %>
+ <%= button_tag "Cancel", {class: 'btn btn-xs btn-danger', id: "cancel-obj-button"} %>
<% end %>
</div>
<% end %>
<% if wu.state_label == 'Paused' %>
<p>
This <%= wu.title %> is paused. Children that are
- already running will continue to run, but no new work units will be submitted.
+ already running will continue to run, but no new work will be submitted.
</p>
<% end %>
end %><% if wu.finished_at %> at <%= render_localized_date(wu.finished_at) %><% end %>.
<% else %>
<% if wu.state_label %> This <%= wu.title %> is <%= if wu.state_label == 'Running' then 'active' else wu.state_label.downcase end %>. <% end %>
- <% walltime = 0%>
+ <% walltime = 0 %>
<% end %>
<% if wu.state_label == 'Failed' %>
locals: {error_name: "Unreadable components", backtrace: nil, wu: wu}) %>
<% else %>
<% @descendent_count = 0 if !@descendent_count %>
- <% wu.children.each_with_index do |c, i| %>
+ <% wu.children.each do |c| %>
<% @descendent_count += 1 %>
<%= render(partial: 'work_unit/show_child', locals: {current_obj: c, i: @descendent_count, expanded: false}) %>
<% end %>
projects / arvados.git / commitdiff