summaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authormartinko2012-12-18 14:55:10 +0000
committermartinko2012-12-18 14:55:10 +0000
commit21d3b39d371f2956a3cfa234bf73980503df4d97 (patch)
treea59c6be9f3a8f81e3b626e6526ccd803c9762400 /python
parent364ade97bc8be670dd0c506fbd723e2bf0ad5b97 (diff)
post merge clean up
Diffstat (limited to 'python')
-rw-r--r--python/a0
-rw-r--r--python/londiste/setup.py13
2 files changed, 4 insertions, 9 deletions
diff --git a/python/a b/python/a
deleted file mode 100644
index e69de29b..00000000
--- a/python/a
+++ /dev/null
diff --git a/python/londiste/setup.py b/python/londiste/setup.py
index 0df9c9db..0cc4401e 100644
--- a/python/londiste/setup.py
+++ b/python/londiste/setup.py
@@ -78,7 +78,6 @@ class LondisteSetup(CascadeAdmin):
help="max number of parallel copy processes")
p.add_option("--dest-table",
help="add: name for actual table")
-
return p
def extra_init(self, node_type, node_db, provider_db):
@@ -173,7 +172,6 @@ class LondisteSetup(CascadeAdmin):
if self.options.wait_sync:
self.wait_for_sync(dst_db)
-
def add_table(self, src_db, dst_db, tbl, create_flags, src_tbls):
# use full names
tbl = skytools.fq_name(tbl)
@@ -256,13 +254,12 @@ class LondisteSetup(CascadeAdmin):
tgargs.append('no_merge')
if self.options.expect_sync:
tgargs.append('expect_sync')
-
return tgargs
def build_handler(self, tbl, tgargs, dest_table=None):
- """Build handler and push int into tgargs"""
+ """Build handler and return handler string"""
hstr = londiste.handler.create_handler_string(
- self.options.handler, self.options.handler_arg)
+ self.options.handler, self.options.handler_arg)
p = londiste.handler.build_handler(tbl, hstr, dest_table)
p.add(tgargs)
return hstr
@@ -307,7 +304,7 @@ class LondisteSetup(CascadeAdmin):
self.exec_cmd_many(db, q, [self.set_name], args)
def cmd_change_handler(self, tbl):
- """Change handler (table_attrs) of the replicated table"""
+ """Change handler (table_attrs) of the replicated table."""
self.load_local_info()
@@ -350,7 +347,6 @@ class LondisteSetup(CascadeAdmin):
self.exec_cmd(curs, q, args)
db.commit()
-
def cmd_add_seq(self, *args):
"""Attach seqs(s) to local node."""
dst_db = self.get_database('db')
@@ -434,7 +430,7 @@ class LondisteSetup(CascadeAdmin):
self.exec_cmd_many(db, q, [self.set_name], args)
def cmd_resync(self, *args):
- """Reload data from provider node.."""
+ """Reload data from provider node."""
db = self.get_database('db')
args = self.expand_arg_list(db, 'r', True, args)
q = "select * from londiste.local_set_table_state(%s, %s, null, null)"
@@ -720,4 +716,3 @@ class LondisteSetup(CascadeAdmin):
tinfo[2] += 1
if not bak and ev.ev_type == 'D':
tinfo[3] = NO_ROLLBACK
-