Module: Resque::Scheduler::Server::HelperMethods
- Defined in:
- lib/resque/scheduler/server.rb
Instance Method Summary collapse
- #find_job(worker) ⇒ Object
- #format_time(t) ⇒ Object
- #queue_from_class_name(class_name) ⇒ Object
- #rails_env(name) ⇒ Object
- #schedule_class(config) ⇒ Object
- #schedule_interval(config) ⇒ Object
- #schedule_interval_every(every) ⇒ Object
- #scheduled_in_this_env?(name) ⇒ Boolean
- #scheduler_template(name) ⇒ Object
- #scheduler_view(filename, options = {}, locals = {}) ⇒ Object
Instance Method Details
#find_job(worker) ⇒ Object
139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 |
# File 'lib/resque/scheduler/server.rb', line 139 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 Resque.queues.each do |queue| queued = Resque.peek(queue, 0, Resque.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) ⇒ Object
129 130 131 |
# File 'lib/resque/scheduler/server.rb', line 129 def format_time(t) t.strftime('%Y-%m-%d %H:%M:%S %z') end |
#queue_from_class_name(class_name) ⇒ Object
133 134 135 136 137 |
# File 'lib/resque/scheduler/server.rb', line 133 def queue_from_class_name(class_name) Resque.queue_from_class( Resque::Scheduler::Util.constantize(class_name) ) end |
#rails_env(name) ⇒ Object
203 204 205 |
# File 'lib/resque/scheduler/server.rb', line 203 def rails_env(name) Resque.schedule[name]['rails_env'] end |
#schedule_class(config) ⇒ Object
184 185 186 187 188 189 190 |
# File 'lib/resque/scheduler/server.rb', line 184 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) ⇒ Object
161 162 163 164 165 166 167 168 169 |
# File 'lib/resque/scheduler/server.rb', line 161 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) ⇒ Object
171 172 173 174 175 176 177 178 179 180 181 182 |
# File 'lib/resque/scheduler/server.rb', line 171 def schedule_interval_every(every) every = [*every] s = 'every: ' << every.first return s unless every.length > 1 s << ' (' = every.last.map do |key, value| "#{key.to_s.tr('_', ' ')} #{value}" end s << .join(', ') << ')' end |
#scheduled_in_this_env?(name) ⇒ Boolean
198 199 200 201 |
# File 'lib/resque/scheduler/server.rb', line 198 def scheduled_in_this_env?(name) return true if Resque.schedule[name]['rails_env'].nil? rails_env(name).split(/[\s,]+/).include?(Resque::Scheduler.env) end |
#scheduler_template(name) ⇒ Object
192 193 194 195 196 |
# File 'lib/resque/scheduler/server.rb', line 192 def scheduler_template(name) File.read( File.("../server/views/#{name}.erb", __FILE__) ) end |
#scheduler_view(filename, options = {}, locals = {}) ⇒ Object
207 208 209 210 |
# File 'lib/resque/scheduler/server.rb', line 207 def scheduler_view(filename, = {}, locals = {}) source = File.read(File.join(VIEW_PATH, "#{filename}.erb")) erb source, , locals end |