X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/aaa45b09de0e9437743fce53d7c0bf8165074b5e..3f8336875d5938afb6b00289e9d6c9941456b57f:/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 f84c4a310f..651f36d30f 100644
--- a/services/api/app/models/pipeline_instance.rb
+++ b/services/api/app/models/pipeline_instance.rb
@@ -100,6 +100,26 @@ class PipelineInstance < ArvadosModel
     self.where("state = 'RunningOnServer'")
   end
 
+  def cancel cascade=nil
+    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).each do |job|
+      job.cancel cascade if job.state.in?([Job::Queued, Job::Running])
+    end
+  end
+
   protected
   def bootstrap_components
     if pipeline_template and (!components or components.empty?)