module ResqueAdmin::Scheduler::Server::HelperMethods
Public Instance Methods
find_job(worker)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 154 def find_job(worker) worker = worker.downcase results = working_jobs_for_worker(worker) dels = delayed_jobs_for_worker(worker) results += dels.select do |j| j['class'].downcase.include?(worker) && j.merge!('where_at' => 'delayed') end ResqueAdmin.queues.each do |queue| queued = ResqueAdmin.peek(queue, 0, ResqueAdmin.size(queue)) queued = [queued] unless queued.is_a?(Array) results += queued.select do |j| j['class'].downcase.include?(worker) && j.merge!('queue' => queue, 'where_at' => 'queued') end end results end
format_time(t)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 140 def format_time(t) t.strftime(::ResqueAdmin::Scheduler::Server::TIMESTAMP_FORMAT) end
queue_from_class_name(class_name)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 148 def queue_from_class_name(class_name) ResqueAdmin.queue_from_class( ResqueAdmin::Scheduler::Util.constantize(class_name) ) end
rails_env(name)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 218 def rails_env(name) ResqueAdmin.schedule[name]['rails_env'] || ResqueAdmin.schedule[name]['env'] end
schedule_class(config)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 199 def schedule_class(config) if config['class'].nil? && !config['custom_job_class'].nil? config['custom_job_class'] else config['class'] end end
schedule_interval(config)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 176 def schedule_interval(config) if config['every'] schedule_interval_every(config['every']) elsif config['cron'] 'cron: ' + config['cron'].to_s else 'Not currently scheduled' end end
schedule_interval_every(every)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 186 def schedule_interval_every(every) every = [*every] s = 'every: ' << every.first return s unless every.length > 1 s << ' (' meta = every.last.map do |key, value| "#{key.to_s.tr('_', ' ')} #{value}" end s << meta.join(', ') << ')' end
scheduled_in_this_env?(name)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 213 def scheduled_in_this_env?(name) return true if rails_env(name).nil? rails_env(name).split(/[\s,]+/).include?(ResqueAdmin::Scheduler.env) end
scheduler_template(name)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 207 def scheduler_template(name) File.read( File.expand_path("../server/views/#{name}.erb", __FILE__) ) end
scheduler_view(filename, options = {}, locals = {})
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 222 def scheduler_view(filename, options = {}, locals = {}) source = File.read(File.join(VIEW_PATH, "#{filename}.erb")) erb source, options, locals end
show_job_arguments(args)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 144 def show_job_arguments(args) Array(args).map(&:inspect).join("\n") end
Private Instance Methods
delayed_jobs_for_worker(_worker)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 246 def delayed_jobs_for_worker(_worker) [].tap do |dels| schedule_size = ResqueAdmin.delayed_queue_schedule_size ResqueAdmin.delayed_queue_peek(0, schedule_size).each do |d| ResqueAdmin.delayed_timestamp_peek( d, 0, ResqueAdmin.delayed_timestamp_size(d) ).each do |j| dels << j.merge!('timestamp' => d) end end end end
working_jobs_for_worker(worker)
click to toggle source
# File lib/resque_admin/scheduler/server.rb, line 229 def working_jobs_for_worker(worker) [].tap do |results| working = [*ResqueAdmin.working] work = working.select do |w| w.job && w.job['payload'] && w.job['payload']['class'].downcase.include?(worker) end work.each do |w| results += [ w.job['payload'].merge( 'queue' => w.job['queue'], 'where_at' => 'working' ) ] end end end