python: amendments

diff --git a/python/londiste/handlers/dispatch.py b/python/londiste/handlers/dispatch.py
index 0b02edcd463530a760b805e5175760ef18e93c67..f17d44a6f47193e2aed8f4c67c06d502bdf9466f 100644 (file)
--- a/python/londiste/handlers/dispatch.py
+++ b/python/londiste/handlers/dispatch.py
@@ -237,7 +237,7 @@ class DirectLoader(BaseLoader):
                   'D': skytools.mk_delete_sql}
         if self.data:
             curs.execute("\n".join(mk_sql[op](row, self.table, self.pkeys)
-                for op, row in self.data))
+                                   for op, row in self.data))
 
 
 class BaseBulkCollectingLoader(BaseLoader):
@@ -923,9 +923,7 @@ class Dispatcher (ShardHandler):
         sql = "select " + func + " (%s, %s, %s)"
         self.log.debug("func: %s, args: %s", func, args)
         curs.execute(sql, args)
-        res = []
-        for row in curs.fetchall():
-            res.append(row[0])
+        res = [row[0] for row in curs.fetchall()]
         if res:
             self.log.info("Dropped tables: %s", ", ".join(res))
 

diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py
index d109f74925d5e9bbd4e912df8350bc64c3dcc0c8..b7956853164d9a02e01fc15fa1864b7f9ded35f6 100644 (file)
--- a/python/pgq/consumer.py
+++ b/python/pgq/consumer.py
@@ -16,7 +16,7 @@ EV_DONE = 1
 
 
 class RetriableEvent(Event):
-    """Event which can be retryed
+    """Event which can be retried
 
     Consumer is supposed to tag them after processing.
     """
@@ -128,4 +128,3 @@ class Consumer(BaseConsumer):
         """Tag event for retry. (internal)"""
         cx.execute("select pgq.event_retry(%s, %s, %s)",
                     [batch_id, ev_id, retry_time])
-

diff --git a/python/pgq/localconsumer.py b/python/pgq/localconsumer.py
index ed791ece8aabb6ca8289ada4e3461e8b012406d3..e551536f5ee5f35f4dde829a65bcf35a9a8401c0 100644 (file)
--- a/python/pgq/localconsumer.py
+++ b/python/pgq/localconsumer.py
@@ -128,8 +128,7 @@ class LocalConsumer(BaseConsumer):
         raise Exception('process_local_event not implemented')
 
     def is_batch_done(self):
-        """Helper function to keep track of last successful batch
-        in external database.
+        """Helper function to keep track of last successful batch in external database.
         """
 
         local_tick = self.load_local_tick()
@@ -154,8 +153,7 @@ class LocalConsumer(BaseConsumer):
                         prev_tick, cur_tick, local_tick))
 
     def set_batch_done(self):
-        """Helper function to set last successful batch
-        in external database.
+        """Helper function to set last successful batch in external database.
         """
         tick_id = self.batch_info['tick_id']
         self.save_local_tick(tick_id)