handlers.dispatch: skip pk-only table update earlier

diff --git a/python/londiste/handlers/dispatch.py b/python/londiste/handlers/dispatch.py
index c584d3ff1d78c68c95f905d7c9aacc393fe6d275..5d08f2255e09d95ee16e8aa2d6fa01777ee5eca2 100644 (file)
--- a/python/londiste/handlers/dispatch.py
+++ b/python/londiste/handlers/dispatch.py
@@ -252,6 +252,10 @@ class BaseBulkCollectingLoader(BaseLoader):
             # when no edge defined for old -> new op, keep old
             _op = self.OP_GRAPH[_op].get(op, _op)
             self.pkey_ev_map[pk_data] = (_op, row)
+
+            # skip update to pk-only table
+            if len(pk_data) == len(row) and _op == 'U':
+                del self.pkey_ev_map[pk_data]
         except KeyError:
             raise Exception('unknown event type: %s' % op)