white noise

diff --git a/python/pgq/cascade/admin.py b/python/pgq/cascade/admin.py
index 8006477464080699567ac7f589ccb0cd10e85efd..9e789fb1a9b76cd0bcd5296dc03aedfe8c198825 100644 (file)
--- a/python/pgq/cascade/admin.py
+++ b/python/pgq/cascade/admin.py
@@ -1310,7 +1310,6 @@ class CascadeAdmin(skytools.AdminScript):
             time.sleep(1)
         raise Exception('process canceled')
 
-
     def pause_consumer(self, node, consumer):
         """Shortcut for pausing by name."""
         self.set_paused(node, consumer, True)
@@ -1394,4 +1393,3 @@ class CascadeAdmin(skytools.AdminScript):
 if __name__ == '__main__':
     script = CascadeAdmin('setadm', 'node_db', sys.argv[1:], worker_setup = False)
     script.start()
-

diff --git a/python/skytools/adminscript.py b/python/skytools/adminscript.py
index 1fc420e58a6126b8de3bd311aaef134fb0ec67f0..7ec16e754c22807b42f11f0cafd1b788a3959b07 100644 (file)
--- a/python/skytools/adminscript.py
+++ b/python/skytools/adminscript.py
@@ -56,7 +56,7 @@ class AdminScript(skytools.DBScript):
         fn(*cmdargs)
 
     def fetch_list(self, db, sql, args, keycol = None):
-        """Fetch a resultset from db, optionally turnin it info value list."""
+        """Fetch a resultset from db, optionally turning it into value list."""
         curs = db.cursor()
         curs.execute(sql, args)
         rows = curs.fetchall()
@@ -107,7 +107,6 @@ class AdminScript(skytools.DBScript):
         print('\n')
         return 1
 
-
     def exec_stmt(self, db, sql, args):
         """Run regular non-query SQL on db."""
         self.log.debug("exec_stmt: %s" % skytools.quote_statement(sql, args))
@@ -123,5 +122,3 @@ class AdminScript(skytools.DBScript):
         res = curs.fetchall()
         db.commit()
         return res
-
-

diff --git a/python/skytools/skylog.py b/python/skytools/skylog.py
index bf76940c93fa6e2b336f44cfca8d4a7186b59639..11940ec16f9180ec4e92c204a755a3f5d529c55a 100644 (file)
--- a/python/skytools/skylog.py
+++ b/python/skytools/skylog.py
@@ -211,7 +211,7 @@ class LogDBHandler(logging.handlers.SocketHandler):
             self.stat_cache[k] = agg
 
     def flush_stats(self, service):
-        """Send awuired stats to logdb."""
+        """Send acquired stats to logdb."""
         res = []
         for k, v in self.stat_cache.items():
             res.append("%s: %s" % (k, str(v)))