diff options
| -rw-r--r-- | python/londiste/handlers/dispatch.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/python/londiste/handlers/dispatch.py b/python/londiste/handlers/dispatch.py index c584d3ff..5d08f225 100644 --- 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) |