X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/a6439c7ddc3407193889386051f06df2a1e74ea9..525c942524426cb3ddc48ea63c18c4f300d47cb3:/services/api/app/models/job.rb diff --git a/services/api/app/models/job.rb b/services/api/app/models/job.rb index a23989309a..51fb7c2783 100644 --- a/services/api/app/models/job.rb +++ b/services/api/app/models/job.rb @@ -1,5 +1,5 @@ class Job < ArvadosModel - include AssignUuid + include HasUuid include KindAndEtag include CommonApiTemplate serialize :script_parameters, Hash @@ -35,10 +35,9 @@ class Job < ArvadosModel t.add :runtime_constraints t.add :tasks_summary t.add :dependencies - t.add :log_stream_href - t.add :log_buffer t.add :nondeterministic t.add :repository + t.add :supplied_script_version end def assert_finished @@ -47,12 +46,6 @@ class Job < ArvadosModel running: false) end - def log_stream_href - unless self.finished_at - "#{current_api_base}/#{self.class.to_s.pluralize.underscore}/#{self.uuid}/log_tail_follow" - end - end - def self.queue self.where('started_at is ? and is_locked_by_uuid is ? and cancelled_at is ? and success is ?', nil, nil, nil, nil). @@ -88,6 +81,7 @@ class Job < ArvadosModel if new_record? or script_version_changed? sha1 = Commit.find_commit_range(current_user, self.repository, nil, self.script_version, nil)[0] rescue nil if sha1 + self.supplied_script_version = self.script_version if self.supplied_script_version.nil? or self.supplied_script_version.empty? self.script_version = sha1 else raise ArgumentError.new("Specified script_version does not resolve to a commit") @@ -187,15 +181,4 @@ class Job < ArvadosModel end end end - - def log_buffer - begin - @@redis ||= Redis.new(:timeout => 0) - if @@redis.exists uuid - @@redis.getrange(uuid, 0 - 2**10, -1) - end - rescue Redis::CannotConnectError - return '(not available)' - end - end end