From 42aee8d3f13e0a210f2cf2d62cfaaf3174a98003 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Fri, 6 Jul 2012 14:23:32 +0300 Subject: [PATCH] londiste replay: skip provider checks if copy_node is used Because the table does not need to exist on current provider then. Perhaps it would be safer to go and check this new node, but copy can wait for good state on its own too. --- python/londiste/playback.py | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) diff --git a/python/londiste/playback.py b/python/londiste/playback.py index 6742f02d..328286d6 100644 --- a/python/londiste/playback.py +++ b/python/londiste/playback.py @@ -473,13 +473,18 @@ class Replicator(CascadedWorker): pmap = self.get_state_map(src_db.cursor()) src_db.commit() for t in self.get_tables_in_state(TABLE_MISSING): - if t.name not in pmap: - self.log.warning("Table %s not available on provider" % t.name) - continue - pt = pmap[t.name] - if pt.state != TABLE_OK: # or pt.custom_snapshot: # FIXME: does snapsnot matter? - self.log.info("Table %s not OK on provider, waiting" % t.name) - continue + if 'copy_node' in t.table_attrs: + # should we go and check this node? + pass + else: + # regular provider is used + if t.name not in pmap: + self.log.warning("Table %s not available on provider" % t.name) + continue + pt = pmap[t.name] + if pt.state != TABLE_OK: # or pt.custom_snapshot: # FIXME: does snapsnot matter? + self.log.info("Table %s not OK on provider, waiting" % t.name) + continue # dont allow more copies than configured if npossible == 0: -- 2.39.5