X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/0df5f0feeced5bff0adfb806dae2d3811257827f..d940d88f991c14785110855ba0ee79ea5f401276:/services/api/app/models/pipeline_instance.rb diff --git a/services/api/app/models/pipeline_instance.rb b/services/api/app/models/pipeline_instance.rb index c0781ef228..0b0af8b87d 100644 --- a/services/api/app/models/pipeline_instance.rb +++ b/services/api/app/models/pipeline_instance.rb @@ -9,7 +9,10 @@ class PipelineInstance < ArvadosModel serialize :components, Hash serialize :properties, Hash serialize :components_summary, Hash - belongs_to :pipeline_template, :foreign_key => :pipeline_template_uuid, :primary_key => :uuid + belongs_to :pipeline_template, + foreign_key: 'pipeline_template_uuid', + primary_key: 'uuid', + optional: true before_validation :bootstrap_components before_validation :update_state @@ -17,6 +20,8 @@ class PipelineInstance < ArvadosModel before_validation :update_timestamps_when_state_changes before_create :set_state_before_save before_save :set_state_before_save + before_create :create_disabled + before_update :update_disabled api_accessible :user, extend: :common do |t| t.add :pipeline_template_uuid @@ -109,30 +114,7 @@ class PipelineInstance < ArvadosModel end def cancel(cascade: false, need_transaction: true) - if need_transaction - ActiveRecord::Base.transaction do - cancel(cascade: cascade, need_transaction: false) - end - return - end - - if self.state.in?([RunningOnServer, RunningOnClient]) - self.state = Paused - self.save! - elsif self.state != Paused - raise InvalidStateTransitionError - end - - return if !cascade - - # cancel all child jobs - children = self.components.andand.collect{|_, c| c['job']}.compact.collect{|j| j['uuid']}.compact - - return if children.empty? - - Job.where(uuid: children, state: [Job::Queued, Job::Running]).each do |job| - job.cancel(cascade: cascade, need_transaction: false) - end + raise "No longer supported" end protected @@ -183,4 +165,12 @@ class PipelineInstance < ArvadosModel end end + + def create_disabled + raise "Disabled" + end + + def update_disabled + raise "Disabled" + end end