# that are associated with this container.
if self.state_changed? and [Complete, Cancelled].include? self.state
act_as_system_user do
+
+ if self.state == Cancelled
+ retryable_requests = ContainerRequest.where("priority > 0 and state = 'Committed' and container_count < container_count_max")
+ else
+ retryable_requests = []
+ end
+
+ if retryable_requests.any?
+ c = Container.create!(command: self.command,
+ cwd: self.cwd,
+ environment: self.environment,
+ output_path: self.output_path,
+ container_image: self.container_image,
+ mounts: self.mounts,
+ runtime_constraints: self.runtime_constraints)
+ retryable_requests.each do |cr|
+ cr.container_uuid = c.uuid
+ cr.save!
+ end
+ end
+
# Notify container requests associated with this container
ContainerRequest.where(container_uuid: uuid,
:state => ContainerRequest::Committed).each do |cr|
if state_changed? and state == Committed and container_uuid.nil?
resolve
end
+ if self.container_uuid != self.container_uuid_was
+ self.container_count += 1
+ end
end
def validate_runtime_constraints