apps/workbench/app/views/pipeline_instances/_show_components_running.html.erb

   1 <%# Summary %>
   2
   3 <% if @object.state == 'Paused' %>
   4   <p>
   5     This pipeline is paused.  Jobs that are
   6     already running will continue to run, but no new jobs will be submitted.
   7   </p>
   8 <% end %>
   9
  10 <p>
  11   <% if @object.started_at %>
  12     Started at <span data-utc-date="<%= @object.started_at %>"><%= @object.started_at %></span>.
  13   <% end %>
  14
  15   <% if @object.state == 'Complete' %>
  16     Completed in
  17   <% elsif @object.state == 'Failed' %>
  18     Failed after
  19   <% else %>
  20     Has been active for
  21   <% end %>
  22
  23   <% walltime = if @object.started_at
  24         if @object.finished_at
  25           @object.finished_at - @object.started_at
  26         else
  27           Time.now - @object.started_at
  28         end
  29       else
  30         0
  31       end
  32       %>
  33
  34   <%= runtime(walltime, true) %><% if @object.finished_at %> at <span data-utc-date="<%= @object.finished_at %>"><%= @object.finished_at %></span><% end %>.
  35
  36   <% if @object.state == 'Failed' %>
  37     Check the Log tab for more detail about why this pipeline failed.
  38   <% end %>
  39 </p>
  40
  41 <p>
  42     <% tasks = JobTask.filter([['job_uuid', 'in', render_pipeline_jobs.map { |j| j[:job].andand[:uuid] }]]).results %>
  43     <% runningtime = determine_wallclock_runtime(render_pipeline_jobs.map {|j| j[:job]}) %>
  44
  45     <% if @object.state.start_with? 'Running' %>
  46       Has run
  47       <% else %>
  48       Ran
  49     <% end %>
  50     for
  51     <%= runtime(runningtime, true) %> (<%= runtime(walltime - runningtime, true) %> queued)<% if tasks.size == 0 %>.<% else %>
  52       and used
  53       <% cputime = tasks.map { |task|
  54            puts "started at #{task.started_at}"
  55                   if task.started_at
  56                     (if task.finished_at then task.finished_at else Time.now() end) - task.started_at
  57                   else
  58                     0
  59                   end
  60                 }.reduce(:+) %>
  61     <%= runtime(cputime, true) %>
  62     of CPU time (<%= (cputime/runningtime).round(1) %>&Cross; scaling).
  63     <% end %>
  64 </p>
  65
  66 <%# Components %>
  67
  68 <% render_pipeline_jobs.each_index do |i| %>
  69   <% pj = render_pipeline_jobs[i] %>
  70   <% current_job = pj[:job] if pj[:job] != {} %>
  71   <div class="panel panel-default">
  72     <div class="panel-heading">
  73       <div class="container-fluid">
  74         <div class="row">
  75           <div class="col-md-3">
  76             <h4 class="panel-title">
  77               <a data-toggle="collapse" href="#collapse<%= i %>">
  78                 <%= pj[:name] %> <span class="caret"></span>
  79               </a>
  80             </h4>
  81           </div>
  82
  83           <% puts current_job.inspect %>
  84
  85           <% if current_job %>
  86             <div class="col-md-1">
  87               <%= render(partial: 'job_status_label', locals: { j: current_job }) %>
  88             </div>
  89
  90             <div class="col-md-3">
  91               <% if current_job[:started_at] %>
  92                 <% walltime = ((if current_job.finished_at then current_job.finished_at else Time.now() end) - current_job.started_at) %>
  93                 <% cputime = tasks.map { |task|
  94                      if task.started_at and task.job_uuid == current_job.uuid
  95                        (if task.finished_at then task.finished_at else Time.now() end) - task.started_at
  96                      else
  97                        0
  98                      end
  99                    }.reduce(:+) %>
 100                 <%= runtime(walltime, false) %> / <%= runtime(cputime, false) %> (<%= (cputime/walltime).round(1) %>&Cross;)
 101               <% end %>
 102             </div>
 103
 104             <% if Job::state(current_job).in? ["Completed", "Failed", "Canceled"] %>
 105               <div class="col-md-3">
 106                 <% if pj[:output_uuid] %>
 107                   <%= link_to_if_arvados_object pj[:output_uuid] %>
 108                 <% elsif current_job.andand[:output] %>
 109                   <%= link_to_if_arvados_object current_job[:output], link_text: "Output of #{pj[:name]}" %>
 110                 <% else %>
 111                   No output.
 112                 <% end %>
 113               </div>
 114             <% elsif Job::state(current_job) == "Running" %>
 115               <div class="col-md-3 pipeline-instance-spacing">
 116                 <%= pj[:progress_bar] %>
 117               </div>
 118               <div class="col-md-1 pipeline-instance-spacing">
 119                 <%= form_tag "/jobs/#{current_job.uuid}/cancel", style: "display:inline; padding-left: 1em" do |f| %>
 120                 <%= hidden_field_tag :return_to, url_for(@object) %>
 121                 <%= button_tag "Cancel", {class: 'btn btn-xs btn-danger', id: "cancel-job-button"} %>
 122             </div>
 123             <% end %>
 124           <% elsif Job::state(current_job) == "Queued" %>
 125             <div class="col-md-5">
 126               <% queuetime = Time.now - current_job[:created_at] %>
 127               Queued for <%= runtime(queuetime, true) %>.
 128               <% begin %>
 129               <% if current_job.queue_position == 0 %>
 130                 This job is next in the queue to run.
 131               <% elsif current_job.queue_position == 1 %>
 132                 There is 1 job in the queue ahead of this one.
 133               <% else  %>
 134                 There are <%= current_job.queue_position %> jobs in the queue ahead of this one.
 135               <% end %>
 136               <% rescue %>
 137           <% end %>
 138             </div>
 139           <% end %>
 140         <% else %>
 141           <div class="col-md-3 col-md-offset-3">
 142             <span class="label label-default">Not ready</span>
 143           </div>
 144 <% end %>
 145 </div>
 146 </div>
 147 </div>
 148
 149 <div id="collapse<%= i %>" class="panel-collapse collapse">
 150   <div class="panel-body">
 151     <div class="container">
 152         <% current_component = (if current_job then current_job else pj end) %>
 153         <div class="row">
 154           <div class="col-md-6">
 155             <table>
 156               <% [:script, :repository, :script_version, :supplied_script_version, :nondeterministic].each do |k| %>
 157                 <tr>
 158                   <td style="padding-right: 1em">
 159                     <%= k.to_s %>:
 160                   </td>
 161                   <td>
 162                     <%= current_component[k] %>
 163                   </td>
 164                 </tr>
 165               <% end %>
 166               <% if current_component[:runtime_constraints].andand[:docker_image] and current_component[:docker_image_locator] %>
 167                 <tr>
 168                   <td style="padding-right: 1em">
 169                     docker_image:
 170                   </td>
 171                   <td>
 172                     <%= current_component[:runtime_constraints][:docker_image] %>
 173                   </td>
 174                 </tr>
 175                 <tr>
 176                   <td style="padding-right: 1em">
 177                     docker_image_locator:
 178                   </td>
 179                   <td>
 180                     <%= link_to_if_arvados_object current_component[:docker_image_locator] %>
 181                   </td>
 182                 </tr>
 183               <% else %>
 184                 <tr>
 185                   <td style="padding-right: 1em">
 186                     docker_image:
 187                   </td>
 188                   <td>
 189                     Not run in Docker
 190                   </td>
 191                 </tr>
 192               <% end %>
 193             </table>
 194           </div>
 195           <div class="col-md-5">
 196             <table>
 197               <% [:uuid, :modified_by_user_uuid, :priority, :created_at, :started_at, :finished_at].each do |k| %>
 198                 <tr>
 199                   <td style="padding-right: 1em">
 200                     <%= k.to_s %>:
 201                   </td>
 202                   <td>
 203                     <% if k.to_s.end_with? 'uuid' %>
 204                       <%= link_to_if_arvados_object current_component[k], friendly_name: true %>
 205                     <% elsif k.to_s.end_with? '_at' %>
 206                       <span data-utc-date="<%= current_component[k] %>"><%= current_component[k] %></span>
 207                     <% else %>
 208                       <%= current_component[k] %>
 209                     <% end %>
 210                   </td>
 211                 </tr>
 212               <% end %>
 213             </table>
 214           </div>
 215         </div>
 216         <div class="row">
 217           <div class="col-md-6">
 218             <p>script_parameters:</p>
 219             <pre><%= JSON.pretty_generate(current_component[:script_parameters]) rescue nil %></pre>
 220           </div>
 221           <% if current_component[:tasks_summary] %>
 222           <div class="col-md-3">
 223             <table>
 224               <% [:done, :running, :failed, :todo].each do |d| %>
 225               <tr>
 226                 <td style="padding-right: 1em"><%= 'tasks:' if d == :done %></td>
 227                 <td style="padding-right: 1em"><%= d.to_s %></td>
 228                 <td><%= current_component[:tasks_summary][d] %></td>
 229               </tr>
 230               <% end %>
 231             </table>
 232           </div>
 233           <% end %>
 234         </div>
 235     </div>
 236   </div>
 237 </div>
 238 </div>
 239 <% end %>