apps/workbench/app/controllers/jobs_controller.rb

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