X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/2d4263c16812a906589cbc13be26535a85691bd8..7a537556b3503bf957ad3da2bf27885518a33230:/services/api/app/models/job_task.rb

diff --git a/services/api/app/models/job_task.rb b/services/api/app/models/job_task.rb
index dde1b2f9f9..7d568e952a 100644
--- a/services/api/app/models/job_task.rb
+++ b/services/api/app/models/job_task.rb
@@ -1,8 +1,36 @@
-class JobTask < OrvosModel
+class JobTask < ArvadosModel
   include AssignUuid
   include KindAndEtag
   include CommonApiTemplate
+  serialize :parameters, Hash
+  after_update :delete_created_job_tasks_if_failed
+  after_update :assign_created_job_tasks_qsequence_if_succeeded
 
-  api_accessible :superuser, :extend => :common do |t|
+  api_accessible :user, extend: :common do |t|
+    t.add :job_uuid
+    t.add :created_by_job_task_uuid
+    t.add :sequence
+    t.add :qsequence
+    t.add :parameters
+    t.add :output
+    t.add :progress
+    t.add :success
+  end
+
+  protected
+
+  def delete_created_job_tasks_if_failed
+    if self.success == false and self.success != self.success_was
+      JobTask.delete_all ['created_by_job_task_uuid = ?', self.uuid]
+    end
+  end
+
+  def assign_created_job_tasks_qsequence_if_succeeded
+    if self.success == false and self.success != self.success_was
+      # xxx qsequence should be sequential as advertised; for now at
+      # least it's non-decreasing.
+      JobTask.update_all(['qsequence = ?', (Time.now.to_f*10000000).to_i],
+                         ['created_by_job_task_uuid = ?', self.uuid])
+    end
   end
 end