Class: Debci::Job
- Inherits:
-
ActiveRecord::Base
- Object
- ActiveRecord::Base
- Debci::Job
- Defined in:
- lib/debci/job.rb
Class Method Summary collapse
Instance Method Summary collapse
- #enqueue ⇒ Object
- #prefix ⇒ Object
- #queue ⇒ Object
-
#time ⇒ Object
Returns the amount of time since the date for this status object.
Class Method Details
Instance Method Details
#enqueue ⇒ Object
33 34 35 36 37 38 39 40 41 42 43 |
# File 'lib/debci/job.rb', line 33 def enqueue parameters = ['run-id:%s' % id] if self.trigger parameters << "trigger:#{trigger}" end Array(self.pin_packages).each do |pin| pkg, suite = pin parameters << "pin-packages:#{suite}=#{pkg}" end self.queue.publish("%s %s %s" % [package, suite, parameters.join(' ')]) end |
#prefix ⇒ Object
16 17 18 19 20 |
# File 'lib/debci/job.rb', line 16 def prefix name = self.package name =~ /^((lib)?.)/ $1 end |
#queue ⇒ Object
45 46 47 48 49 50 51 |
# File 'lib/debci/job.rb', line 45 def queue @queue ||= begin q = ENV['debci_amqp_queue'] || "debci-#{arch}-#{Debci.config.backend}" self.class.amqp_channel.queue(q, durable: true) end end |
#time ⇒ Object
Returns the amount of time since the date for this status object
23 24 25 26 27 28 29 30 31 |
# File 'lib/debci/job.rb', line 23 def time days = (Time.now - self.created_at)/86400 if days >= 1 || days <= -1 "#{days.floor} day(s) ago" else "#{Time.at(Time.now - self.created_at).gmtime.strftime('%H')} hour(s) ago" end end |