X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/a8bfbac314335eb0bff3f4ff5e856d3c327de31d..39c17737ac69d7693684fe2f95bef0ec235a28bf:/services/api/app/models/container_request.rb diff --git a/services/api/app/models/container_request.rb b/services/api/app/models/container_request.rb index 799aa430fb..dd3ff767dd 100644 --- a/services/api/app/models/container_request.rb +++ b/services/api/app/models/container_request.rb @@ -28,8 +28,8 @@ class ContainerRequest < ArvadosModel before_validation :fill_field_defaults, :if => :new_record? before_validation :validate_runtime_constraints - before_validation :set_container before_validation :set_default_preemptible_scheduling_parameter + before_validation :set_container validates :command, :container_image, :output_path, :cwd, :presence => true validates :output_ttl, numericality: { only_integer: true, greater_than_or_equal_to: 0 } validates :priority, numericality: { only_integer: true, greater_than_or_equal_to: 0, less_than_or_equal_to: 1000 } @@ -199,11 +199,11 @@ class ContainerRequest < ArvadosModel end def set_default_preemptible_scheduling_parameter + c = get_requesting_container() if self.state == Committed # If preemptible instances (eg: AWS Spot Instances) are allowed, # ask them on child containers by default. - if Rails.configuration.preemptible_instances and - !self.requesting_container_uuid.nil? and + if Rails.configuration.preemptible_instances and !c.nil? and self.scheduling_parameters['preemptible'].nil? self.scheduling_parameters['preemptible'] = true end @@ -239,6 +239,11 @@ class ContainerRequest < ArvadosModel if !Rails.configuration.preemptible_instances and scheduling_parameters['preemptible'] errors.add :scheduling_parameters, "preemptible instances are not allowed" end + if scheduling_parameters.include? 'max_run_time' and + (!scheduling_parameters['max_run_time'].is_a?(Integer) || + scheduling_parameters['max_run_time'] < 0) + errors.add :scheduling_parameters, "max_run_time must be positive integer" + end end end @@ -313,10 +318,18 @@ class ContainerRequest < ArvadosModel end def set_requesting_container_uuid - return if !current_api_client_authorization - if (c = Container.where('auth_uuid=?', current_api_client_authorization.uuid).select([:uuid, :priority]).first) + c = get_requesting_container() + if !c.nil? self.requesting_container_uuid = c.uuid self.priority = c.priority>0 ? 1 : 0 end end + + def get_requesting_container + return self.requesting_container_uuid if !self.requesting_container_uuid.nil? + return if !current_api_client_authorization + if (c = Container.where('auth_uuid=?', current_api_client_authorization.uuid).select([:uuid, :priority]).first) + return c + end + end end