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")
def __init__(self, args):
"""Replication init."""
- CascadedWorker.__init__(self, 'londiste', 'db', args)
+ CascadedWorker.__init__(self, 'londiste3', 'db', args)
self.table_list = []
self.table_map = {}
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', '')
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