From 942a9a2ed6fa48cb72831732e1dce789d9f43f09 Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Tue, 27 Apr 2010 13:41:49 +0300 Subject: [PATCH] Require [londiste3] in londiste config. --- python/londiste.py | 2 +- python/londiste/playback.py | 2 +- python/londiste/setup.py | 2 +- python/londiste/syncer.py | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/python/londiste.py b/python/londiste.py index c2907d2b..a224be2f 100755 --- a/python/londiste.py +++ b/python/londiste.py @@ -56,7 +56,7 @@ cmd_handlers = ( class Londiste(skytools.DBScript): def __init__(self, args): - skytools.DBScript.__init__(self, 'londiste', args) + skytools.DBScript.__init__(self, 'londiste3', args) if len(self.args) < 2: print("need command") diff --git a/python/londiste/playback.py b/python/londiste/playback.py index e7bc1406..04e2c699 100644 --- a/python/londiste/playback.py +++ b/python/londiste/playback.py @@ -261,7 +261,7 @@ class Replicator(CascadedWorker): def __init__(self, args): """Replication init.""" - CascadedWorker.__init__(self, 'londiste', 'db', args) + CascadedWorker.__init__(self, 'londiste3', 'db', args) self.table_list = [] self.table_map = {} diff --git a/python/londiste/setup.py b/python/londiste/setup.py index c0e84e54..b7e7b966 100644 --- a/python/londiste/setup.py +++ b/python/londiste/setup.py @@ -17,7 +17,7 @@ class LondisteSetup(CascadeAdmin): provider_location = None def __init__(self, args): """Londiste setup init.""" - CascadeAdmin.__init__(self, 'londiste', 'db', args, worker_setup = True) + CascadeAdmin.__init__(self, 'londiste3', 'db', args, worker_setup = True) # compat self.queue_name = self.cf.get('pgq_queue_name', '') diff --git a/python/londiste/syncer.py b/python/londiste/syncer.py index bae1fa56..5bce2485 100644 --- a/python/londiste/syncer.py +++ b/python/londiste/syncer.py @@ -9,7 +9,7 @@ class Syncer(skytools.DBScript): def __init__(self, args): """Syncer init.""" - skytools.DBScript.__init__(self, 'londiste', args) + skytools.DBScript.__init__(self, 'londiste3', args) self.set_single_loop(1) # compat names -- 2.39.5