apps/workbench/app/controllers/jobs_controller.rb

   1 class JobsController < ApplicationController
   2   if Rails.configuration.anonymous_user_token
   3     skip_around_filter :require_thread_api_token, only: :show
   4   end
   5
   6   include JobsHelper
   7
   8   def generate_provenance(jobs)
   9     return if params['tab_pane'] != "Provenance"
  10
  11     nodes = {}
  12     collections = []
  13     hashes = []
  14     jobs.each do |j|
  15       nodes[j[:uuid]] = j
  16       hashes << j[:output]
  17       ProvenanceHelper::find_collections(j[:script_parameters]) do |hash, uuid|
  18         collections << uuid if uuid
  19         hashes << hash if hash
  20       end
  21       nodes[j[:script_version]] = {:uuid => j[:script_version]}
  22     end
  23
  24     Collection.where(uuid: collections).each do |c|
  25       nodes[c[:portable_data_hash]] = c
  26     end
  27
  28     Collection.where(portable_data_hash: hashes).each do |c|
  29       nodes[c[:portable_data_hash]] = c
  30     end
  31
  32     @svg = ProvenanceHelper::create_provenance_graph nodes, "provenance_svg", {
  33       :request => request,
  34       :all_script_parameters => true,
  35       :script_version_nodes => true}
  36   end
  37
  38   def index
  39     @svg = ""
  40     if params[:uuid]
  41       @objects = Job.where(uuid: params[:uuid])
  42       generate_provenance(@objects)
  43       render_index
  44     else
  45       @limit = 20
  46       super
  47     end
  48   end
  49
  50   def cancel
  51     @object.cancel
  52     if params[:return_to]
  53       redirect_to params[:return_to]
  54     else
  55       redirect_to @object
  56     end
  57   end
  58
  59   def show
  60     generate_provenance([@object])
  61     super
  62   end
  63
  64   def logs
  65     @logs = Log.select(%w(event_type object_uuid event_at properties))
  66                .order('event_at DESC')
  67                .filter([["event_type",  "=", "stderr"],
  68                         ["object_uuid", "in", [@object.uuid]]])
  69                .limit(500)
  70                .results
  71                .to_a
  72                .map{ |e| e.serializable_hash.merge({ 'prepend' => true }) }
  73     respond_to do |format|
  74       format.json { render json: @logs }
  75     end
  76   end
  77
  78   def index_pane_list
  79     if params[:uuid]
  80       %w(Recent Provenance)
  81     else
  82       %w(Recent)
  83     end
  84   end
  85
  86   def show_pane_list
  87     panes = %w(Status Log Details Provenance Advanced)
  88     panes.delete 'Log' if !current_user
  89     panes
  90   end
  91 end