Fix progress bars on pipeline_instances#show
[arvados.git] / apps / workbench / app / helpers / pipeline_instances_helper.rb
index f314c658cedd5c8ecc3ea3ada0d364292af8f52c..348004620e6747f3466fb33d6e1a5a089477af09 100644 (file)
@@ -1,4 +1,31 @@
 module PipelineInstancesHelper
+  def pipeline_summary object=nil
+    object ||= @object
+    ret = {todo:0, running:0, queued:0, done:0, failed:0, total:0}
+    object.components.values.each do |c|
+      ret[:total] += 1
+      case
+      when !c[:job]
+        ret[:todo] += 1
+      when c[:job][:success]
+        ret[:done] += 1
+      when c[:job][:failed]
+        ret[:failed] += 1
+      when c[:job][:finished_at]
+        ret[:running] += 1      # XXX finished but !success and !failed??
+      when c[:job][:started_at]
+        ret[:running] += 1
+      else
+        ret[:queued] += 1
+      end
+    end
+    ret.merge! Hash[ret.collect do |k,v|
+                      [('percent_' + k.to_s).to_sym,
+                       ret[:total]<1 ? 0 : (100.0*v/ret[:total]).floor]
+                    end]
+    ret
+  end
+
   def pipeline_jobs object=nil
     object ||= @object
     if object.components[:steps].is_a? Array
@@ -16,9 +43,9 @@ module PipelineInstancesHelper
 
   def render_pipeline_job pj
     if pj[:percent_done]
-      pj[:progress_bar] = raw("<div class=\"progress\" style=\"width:100px\"><div class=\"bar bar-success\" style=\"width:#{pj[:percent_done]}%\"></div><div class=\"bar\" style=\"width:#{pj[:percent_running]}%\"></div></div>")
+      pj[:progress_bar] = raw("<div class=\"progress\" style=\"width:100px\"><span class=\"progress-bar progress-bar-success\" style=\"width:#{pj[:percent_done]}%\"></span><span class=\"progress-bar\" style=\"width:#{pj[:percent_running]}%\"></span></div>")
     elsif pj[:progress]
-      raw("<div class=\"progress\" style=\"width:100px\"><div class=\"bar\" style=\"width:#{pj[:progress]*100}%\"></div></div>")
+      raw("<div class=\"progress\" style=\"width:100px\"><span class=\"progress-bar\" style=\"width:#{pj[:progress]*100}%\"></span></div>")
     end
     pj[:output_link] = link_to_if_arvados_object pj[:output]
     pj[:job_link] = link_to_if_arvados_object pj[:job][:uuid]
@@ -61,23 +88,24 @@ module PipelineInstancesHelper
           pj[:progress] = 0.0
         end
       end
-      if pj[:job]
-        if pj[:job][:success]
-          pj[:result] = 'complete'
-          pj[:complete] = true
-          pj[:progress] = 1.0
-        elsif pj[:job][:finished_at]
-          pj[:result] = 'failed'
-          pj[:failed] = true
-        elsif pj[:job][:started_at]
-          pj[:result] = 'running'
-        else
-          pj[:result] = 'queued'
-        end
+      if pj[:job][:success]
+        pj[:result] = 'complete'
+        pj[:complete] = true
+        pj[:progress] = 1.0
+      elsif pj[:job][:finished_at]
+        pj[:result] = 'failed'
+        pj[:failed] = true
+      elsif pj[:job][:started_at]
+        pj[:result] = 'running'
+      elsif pj[:job][:uuid]
+        pj[:result] = 'queued'
+      else
+        pj[:result] = 'none'
       end
       pj[:job_id] = pj[:job][:uuid]
-      pj[:script] = pj[:job][:script]
-      pj[:script_version] = pj[:job][:script_version]
+      pj[:script] = pj[:job][:script] || c[:script]
+      pj[:script_parameters] = pj[:job][:script_parameters] || c[:script_parameters]
+      pj[:script_version] = pj[:job][:script_version] || c[:script_version]
       pj[:output] = pj[:job][:output]
       pj[:finished_at] = (Time.parse(pj[:job][:finished_at]) rescue nil)
       ret << pj