accept_attribute_as_json :runtime_constraints, Hash
accept_attribute_as_json :tasks_summary, Hash
skip_before_filter :find_object_by_uuid, :only => :queue
+ skip_before_filter :render_404_if_no_object, :only => :queue
def index
want_ancestor = @where[:script_version_descends_from]
super
end
+ def cancel
+ @object.update_attributes cancelled_at: Time.now
+ show
+ end
+
class LogStreamer
Q_UPDATE_INTERVAL = 12
def initialize(job, opts={})
def self._log_tail_follow_requires_parameters
{
- buffer_size: {type: 'integer', required: false}
+ buffer_size: {type: 'integer', required: false, default: 2**13}
}
end
def log_tail_follow
if client_accepts_plain_text_stream
self.response.headers['Last-Modified'] = Time.now.ctime.to_s
self.response_body = LogStreamer.new @object, {
- buffer_size: (params[:buffer_size] || 2**13)
+ buffer_size: (params[:buffer_size].to_i rescue 2**13)
}
else
render json: {