Clean up whitespace.

Author: chawco

resweb/views.py

@@ -12,19 +12,19 @@ class ResWeb(pystache.View):
     def __init__(self, host):
         super(ResWeb, self).__init__()
         self.resq = host
-    
+
     def media_folder(self):
         return '/media/'
-    
+
     def close(self):
         self.resq.close()
-    
+
     def address(self):
         return '%s:%s' % (self.resq.redis.host,self.resq.redis.port)
-    
+
     def version(self):
         return str(__version__)
-    
+
     def pages(self, start, size, link_function, width=20):
         pages = []
 
@@ -49,10 +49,10 @@ def __init__(self, host, queue=None, start=0):
         self._queue = queue
         self._start = start
         super(Overview, self).__init__(host)
-    
+
     def queue(self):
         return self._queue
-    
+
     def queues(self):
         queues = []
         for q in self.resq.queues():
@@ -61,16 +61,16 @@ def queues(self):
                 'size': str(self.resq.size(q)),
             })
         return queues
-    
+
     def start(self):
         return str(self._start)
-    
+
     def end(self):
         return str(self._start + 20)
-    
+
     def size(self):
         return str(self.resq.size(self._queue))
-    
+
     def jobs(self):
         jobs = []
         for job in self.resq.peek(self._queue, self._start, self._start+20):
@@ -79,17 +79,17 @@ def jobs(self):
                 'args':','.join(job['args'])
             })
         return jobs
-    
+
     def empty_jobs(self):
         return len(self.jobs()) == 0
-    
+
     def empty(self):
         return not self._queue
-    
+
     def fail_count(self):
         #from pyres.failure import Failure
         return str(failure.count(self.resq))
-    
+
     def workers(self):
         workers = []
         for w in self.resq.working():
@@ -113,10 +113,10 @@ def workers(self):
         return workers
     def worker_size(self):
         return str(len(self.workers()))
-    
+
     def total_workers(self):
         return str(len(Wrkr.all(self.resq)))
-    
+
     def empty_workers(self):
         if len(self.workers()):
             return False
@@ -127,14 +127,14 @@ class Queues(Overview):
 
 class Working(Overview):
     template_name = 'working_full'
-    
+
 class Workers(ResWeb):
     def size(self):
         return str(len(self.all()))
-    
+
     def all(self):
         return Wrkr.all(self.resq)
-    
+
     def workers(self):
         workers = []
         for w in self.all():
@@ -167,7 +167,7 @@ def __init__(self, host, key, start=0):
         self.key = key
         self._start = start
         super(Queue, self).__init__(host)
-    
+
     def start(self):
         return str(self._start)
 
@@ -176,13 +176,13 @@ def end(self):
         if end > int(self.size()):
             end = self.size()
         return str(end)
-    
+
     def queue(self):
         return self.key
-    
+
     def size(self):
         return str(self.resq.size(self.key) or 0)
-    
+
     def jobs(self):
         jobs = []
         for job in self.resq.peek(self.key, self._start, self._start+20):
@@ -191,29 +191,29 @@ def jobs(self):
                 'args': str(job['args'])
             })
         return jobs
-    
+
     def pagination(self):
         return self.pages(self._start, int(self.size()), self.link_func)
-    
+
     def link_func(self, start):
         return '/queues/%s/?start=%s' % (self.key, start)
-    
+
 
 class Failed(ResWeb):
     def __init__(self, host, start=0):
         self._start = start
         self.host = host
         super(Failed, self).__init__(host)
-    
+
     def start(self):
         return str(self._start)
-    
+
     def end(self):
         return str(self._start + 20)
-    
+
     def size(self):
         return str(failure.count(self.resq) or 0)
-     
+
     def failed_jobs(self):
         from base64 import b64encode
         try:
@@ -230,18 +230,18 @@ def failed_jobs(self):
             item['traceback'] = job['backtrace']
             jobs.append(item)
         return jobs
-    
+
     def pagination(self):
         return self.pages(self._start, int(self.size()), self.link_func)
-    
+
     def link_func(self, start):
         return '/failed/?start=%s' % start
-        
+
 class Stats(ResWeb):
     def __init__(self, host, key_id):
         self.key_id = key_id
         super(Stats, self).__init__(host)
-    
+
     def sub_nav(self):
         sub_nav = []
         sub_nav.append({
@@ -257,7 +257,7 @@ def sub_nav(self):
             'subtab':'keys'
         })
         return sub_nav
-    
+
     def title(self):
         if self.key_id == 'resque':
             return 'Pyres'
@@ -267,7 +267,7 @@ def title(self):
             return 'Keys owned by Pyres'
         else:
             return ''
-    
+
     def stats(self):
         if self.key_id == 'resque':
             return self.resque_info()
@@ -277,7 +277,7 @@ def stats(self):
             return self.key_info()
         else:
             return []
-    
+
     def resque_info(self):
         stats = []
         for key, value in self.resq.info().items():
@@ -286,7 +286,7 @@ def resque_info(self):
                 'value': str(value)
             })
         return stats
-    
+
     def redis_info(self):
         stats = []
         for key, value in self.resq.redis.info().items():
@@ -298,16 +298,16 @@ def redis_info(self):
     def key_info(self):
         stats = []
         for key in self.resq.keys():
-            
+
             stats.append({
                 'key': str(key),
                 'type': str(self.resq.redis.type('resque:'+key)),
-                'size': str(redis_size(key, self.resq)) 
+                'size': str(redis_size(key, self.resq))
             })
         return stats
     def standard(self):
         return not self.resque_keys()
-    
+
     def resque_keys(self):
         if self.key_id == 'keys':
             return True
@@ -317,13 +317,13 @@ class Stat(ResWeb):
     def __init__(self, host, stat_id):
         self.stat_id = stat_id
         super(Stat, self).__init__(host)
-    
+
     def key(self):
         return str(self.stat_id)
-    
+
     def key_type(self):
         return str(self.resq.redis.type('resque:'+ str(self.stat_id)))
-    
+
     def items(self):
         items = []
         if self.key_type() == 'list':
@@ -343,32 +343,32 @@ def items(self):
                 'row':str(self.resq.redis.get('resque:'+self.stat_id))
             })
         return items
-    
+
     def size(self):
         return redis_size(self.stat_id,self.resq)
-    
+
 class Worker(ResWeb):
     def __init__(self, host, worker_id):
         self.worker_id = worker_id
         super(Worker, self).__init__(host)
         self._worker = Wrkr.find(worker_id, self.resq)
-    
+
     def worker(self):
         return str(self.worker_id)
-    
+
     def host(self):
         host,pid,queues = str(self.worker_id).split(':')
         return str(host)
     def pid(self):
         host,pid,queues = str(self.worker_id).split(':')
         return str(pid)
-    
+
     def state(self):
         return str(self._worker.state())
-    
+
     def started_at(self):
         return str(self._worker.started)
-    
+
     def queues(self):
         host,pid,queues = str(self.worker_id).split(':')
         qs = []
@@ -379,7 +379,7 @@ def queues(self):
         return qs
     def processed(self):
         return str(self._worker.get_processed())
-    
+
     def failed(self):
         return str(self._worker.get_failed())
     def data(self):
@@ -397,7 +397,7 @@ def runat(self):
         if self.data():
             return str(datetime.datetime.fromtimestamp(float(data['run_at'])))
         return ''
-    
+
         """
         item = {
             'state':w.state(),
@@ -442,9 +442,9 @@ def jobs(self):
             t = datetime.datetime.fromtimestamp(float(timestamp))
             item = dict(timestamp=str(timestamp))
             item['size'] = str(self.resq.delayed_timestamp_size(timestamp))
-            
+
             item['formated_time'] = str(t)
-            
+
             jobs.append(item)
         return jobs
 
@@ -459,10 +459,10 @@ def __init__(self, host, timestamp, start=0):
         self._start = start
         self._timestamp = timestamp
         super(DelayedTimestamp, self).__init__(host)
-    
+
     def formated_timestamp(self):
         return str(datetime.datetime.fromtimestamp(float(self._timestamp)))
-    
+
     def start(self):
         return str(self._start)
 
@@ -482,12 +482,12 @@ def jobs(self):
             }
             jobs.append(item)
         return jobs
-    
+
     def no_jobs(self):
         if int(self.size()) > 0:
             return False
         return True
-    
+
     def pagination(self):
         return self.pages(self._start, int(self.size()), self.link_func)