Rework syncer code to search for data node

This makes them work with tables added with --find-copy-node.

Also, this disables consumer lag checking code as it makes
compare/repair too unreliable.  Probably it should be rewritten
and simple wait loop.

1 files changed, 6 insertions, 3 deletions

diff --git a/python/londiste/util.py b/python/londiste/util.py
index db7e72fe..0bfd5051 100644
--- a/python/londiste/util.py
+++ b/python/londiste/util.py
@@ -9,9 +9,12 @@ def handler_allows_copy(table_attrs):
     if not table_attrs:
         return True
     attrs = skytools.db_urldecode(table_attrs)
-    hstr = attrs['handler']
-    p = londiste.handler.build_handler('unused.string', hstr, None)
-    return p.needs_table()
+    if 'handler' in attrs:
+        hstr = attrs['handler']
+        p = londiste.handler.build_handler('unused.string', hstr, None)
+        return p.needs_table()
+    else:
+        return True
 
 def find_copy_source(script, queue_name, copy_table_name, node_name, node_location):
     """Find source node for table.