attr_accessor :unreadable_children
def initialize proxied, label
- self.lbl = label
- self.proxied = proxied
+ @lbl = label
+ @proxied = proxied
end
def label
- self.lbl
+ @lbl
end
def uuid
state = get(:state)
if state == 'Complete'
true
- elsif state == 'Failed'
+ elsif state == 'Failed' or state == 'Cancelled'
false
else
nil
summary_txt = ''
if state_label == 'Running'
- if summary[:done]
+ done = summary[:done] || 0
+ running = summary[:running] || 0
+ failed = summary[:failed] || 0
+ todo = summary[:todo] || 0
+ total = done + running + failed + todo
+
+ if total > 0
summary_txt += "#{summary[:done]} #{'child'.pluralize(summary[:done])} done,"
- end
- if summary[:failed]
summary_txt += "#{summary[:failed]} failed,"
- end
- if summary[:running]
summary_txt += "#{summary[:running]} running,"
- end
- if summary[:todo]
summary_txt += "#{summary[:todo]} pending"
end
end
state = get(:state)
if state == 'Complete'
return 1.0
- elsif state == 'Failed' or state== 'Cancelled'
+ elsif state == 'Failed' or state == 'Cancelled'
return 0.0
end
end
end
- def parameters
- get(:script_parameters)
+ def children
+ []
end
- def repository
- get(:repository)
+ def title
+ "process"
end
- def script
- get(:script)
+ def has_unreadable_children
+ @unreadable_children
end
- def script_version
- get(:script_version)
+ def readable?
+ resource_class = ArvadosBase::resource_class_for_uuid(uuid)
+ resource_class.where(uuid: [uuid]).first rescue nil
end
- def supplied_script_version
- get(:supplied_script_version)
+ def link_to_log
+ if state_label.in? ["Complete", "Failed", "Cancelled"]
+ lc = log_collection
+ if lc
+ logCollection = Collection.find? lc
+ if logCollection
+ ApplicationController.helpers.link_to("Log", "#{uri}#Log")
+ else
+ "Log unavailable"
+ end
+ end
+ elsif state_label == "Running"
+ if readable?
+ ApplicationController.helpers.link_to("Log", "#{uri}#Log")
+ else
+ "Log unavailable"
+ end
+ end
end
- def runtime_constraints
- get(:runtime_constraints)
+ def walltime
+ if state_label != "Queued"
+ if started_at
+ ((if finished_at then finished_at else Time.now() end) - started_at)
+ end
+ end
end
- def children
- []
+ def cputime
+ if state_label != "Queued"
+ if started_at
+ (runtime_constraints.andand[:min_nodes] || 1) * ((finished_at || Time.now()) - started_at)
+ end
+ end
end
- def title
- "work unit"
+ def queuedtime
+ if state_label == "Queued"
+ Time.now - Time.parse(created_at.to_s)
+ end
end
- def has_unreadable_children
- self.unreadable_children
+ def show_child_summary
+ if state_label == "Running"
+ if child_summary
+ child_summary_str
+ end
+ end
end
- def readable?
- resource_class = ArvadosBase::resource_class_for_uuid(uuid)
- resource_class.where(uuid: [uuid]).first rescue nil
+ def is_running?
+ state_label == 'Running'
+ end
+
+ def is_paused?
+ state_label == 'Paused'
+ end
+
+ def is_finished?
+ state_label.in? ["Complete", "Failed", "Cancelled"]
+ end
+
+ def is_failed?
+ state_label == 'Failed'
+ end
+
+ def ran_for_str
+ ran_for = nil
+ if state_label
+ ran_for = "It "
+ if state_label == 'Running'
+ ran_for << "has run"
+ else
+ ran_for << "ran"
+ end
+ ran_for << " for"
+ end
+ ran_for
+ end
+
+ def started_and_active_for_str
+ active_for = nil
+
+ if started_at
+ active_for_1 = "This #{title} started at "
+ active_for_2 = "It "
+ if state_label == 'Complete'
+ active_for_2 << "completed in "
+ elsif state_label == 'Failed'
+ active_for_2 << "failed after "
+ else
+ active_for_2 << "has been active for "
+ end
+ [active_for_1, active_for_2]
+ end
+ end
+
+ def show_runtime
+ runningtime = ApplicationController.helpers.determine_wallclock_runtime(children)
+
+ walltime = 0
+ if started_at
+ walltime = if finished_at then (finished_at - started_at) else (Time.now - started_at) end
+ end
+
+ resp = '<p>'
+
+ if started_at
+ resp << "This #{title} started at "
+ resp << ApplicationController.helpers.render_localized_date(started_at)
+ resp << ". It "
+ if state_label == 'Complete'
+ resp << "completed in "
+ elsif state_label == 'Failed'
+ resp << "failed after "
+ else
+ resp << "has been active for "
+ end
+
+ if walltime > runningtime
+ resp << ApplicationController.helpers.render_time(walltime, false)
+ else
+ resp << ApplicationController.helpers.render_time(runningtime, false)
+ end
+
+ if finished_at
+ resp << " at "
+ resp << ApplicationController.helpers.render_localized_date(finished_at)
+ end
+ resp << "."
+ else
+ if state_label
+ resp << "This #{title} is "
+ resp << if state_label == 'Running' then 'active' else state_label.downcase end
+ resp << "."
+ end
+ end
+
+ if is_failed?
+ resp << " Check the Log tab for more detail about why it failed."
+ end
+ resp << "</p>"
+
+ resp << "<p>"
+ if state_label
+ resp << "It "
+ if state_label == 'Running'
+ resp << "has run"
+ else
+ resp << "ran"
+ end
+ resp << " for "
+
+ cpu_time = children.map { |c|
+ if c.started_at
+ (c.runtime_constraints.andand[:min_nodes] || 1) * ((c.finished_at || Time.now()) - c.started_at)
+ else
+ 0
+ end
+ }.reduce(:+) || 0
+
+ resp << ApplicationController.helpers.render_time(runningtime, false)
+ if (walltime - runningtime) > 0
+ resp << "("
+ resp << ApplicationController.helpers.render_time(walltime - runningtime, false)
+ resp << "queued)"
+ end
+ if cpu_time == 0
+ resp << "."
+ else
+ resp << " and used "
+ resp << ApplicationController.helpers.render_time(cpu_time, false)
+ resp << " of node allocation time ("
+ resp << (cpu_time/runningtime).round(1).to_s
+ resp << "⨯ scaling)."
+ end
+ end
+ resp << "</p>"
+
+ resp
end
protected
def get key
- if self.proxied.respond_to? key
- self.proxied.send(key)
- elsif self.proxied.is_a?(Hash)
- self.proxied[key]
+ if @proxied.respond_to? key
+ @proxied.send(key)
+ elsif @proxied.is_a?(Hash)
+ @proxied[key]
end
end
end
projects / arvados.git / blobdiff