X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/5c9aedbd8e623a518f5e1a92e4064a25ddd66353..ba917d72d48615cdd0c6da87d41b6bd0f9f26666:/apps/workbench/app/models/container_work_unit.rb diff --git a/apps/workbench/app/models/container_work_unit.rb b/apps/workbench/app/models/container_work_unit.rb index b6e72dc526..84fc1f8f09 100644 --- a/apps/workbench/app/models/container_work_unit.rb +++ b/apps/workbench/app/models/container_work_unit.rb @@ -1,7 +1,7 @@ class ContainerWorkUnit < ProxyWorkUnit attr_accessor :container - def initialize proxied, label + def initialize proxied, label, parent super if @proxied.is_a?(ContainerRequest) container_uuid = get(:container_uuid) @@ -12,7 +12,7 @@ class ContainerWorkUnit < ProxyWorkUnit end def children - return self.my_children if self.my_children + return @my_children if @my_children container_uuid = nil container_uuid = if @proxied.is_a?(Container) then uuid else get(:container_uuid) end @@ -25,7 +25,7 @@ class ContainerWorkUnit < ProxyWorkUnit end end - self.my_children = items + @my_children = items end def title @@ -53,6 +53,10 @@ class ContainerWorkUnit < ProxyWorkUnit get(:container_uuid) end + def requesting_container_uuid + get(:requesting_container_uuid) + end + def priority @proxied.priority end @@ -81,8 +85,11 @@ class ContainerWorkUnit < ProxyWorkUnit def state_label ec = exit_code return "Failed" if (ec && ec != 0) + state = get_combined(:state) - return "Ready" if ((priority == 0) and (["Queued", "Locked"].include?(state))) + + return "Queued" if state == "Locked" + return "Cancelled" if ((priority == 0) and (state == "Queued")) state end @@ -99,12 +106,21 @@ class ContainerWorkUnit < ProxyWorkUnit end def log_collection - get_combined(:log) + if @proxied.is_a?(ContainerRequest) + get(:log_uuid) + else + get(:log) + end end def outputs items = [] - items << get_combined(:output) if get_combined(:output) + if @proxied.is_a?(ContainerRequest) + out = get(:output_uuid) + else + out = get(:output) + end + items << out if out items end @@ -154,6 +170,13 @@ class ContainerWorkUnit < ProxyWorkUnit protected def get_combined key - get(key, @container) || get(key, @proxied) + from_container = get(key, @container) + from_proxied = get(key, @proxied) + + if from_container.is_a? Hash or from_container.is_a? Array + if from_container.any? then from_container else from_proxied end + else + from_container || from_proxied + end end end