(Complete = 'Complete'),
]
+ def self.limit_index_columns_read
+ ["components"]
+ end
+
# if all components have input, the pipeline is Ready
def components_look_ready?
if !self.components || self.components.empty?
self.where("state = 'RunningOnServer'")
end
- def cancel cascade=nil
+ 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!
return if children.empty?
- Job.where(uuid: children).each do |job|
- job.cancel cascade if job.state.in?([Job::Queued, Job::Running])
+ Job.where(uuid: children, state: [Job::Queued, Job::Running]).each do |job|
+ job.cancel(cascade: cascade, need_transaction: false)
end
end