summaryrefslogtreecommitdiff
path: root/python/londiste/setup.py
diff options
context:
space:
mode:
authorMarko Kreen2008-04-25 14:48:32 +0000
committerMarko Kreen2008-04-25 14:48:32 +0000
commit7ad93d5ca136a10c970a38837641b5789f3f8033 (patch)
tree93c4be1e4089e99c7cb735b40918f6c369b04aa3 /python/londiste/setup.py
parenta6bc0ffa2c37b9e43a5bca7b4003313ce1875ad3 (diff)
pgq_set: pause/resume/change-provider/rename-node work now
Diffstat (limited to 'python/londiste/setup.py')
-rw-r--r--python/londiste/setup.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/python/londiste/setup.py b/python/londiste/setup.py
index 7ab6093d..31394e8d 100644
--- a/python/londiste/setup.py
+++ b/python/londiste/setup.py
@@ -45,27 +45,27 @@ class LondisteSetup(pgq.setadmin.SetAdmin):
def cmd_add(self, args = []):
q = "select * from londiste.node_add_table(%s, %s)"
db = self.get_database('node_db')
- self.db_cmd_many(db, q, [self.set_name], args)
+ self.exec_cmd_many(db, q, [self.set_name], args)
def cmd_remove(self, args = []):
q = "select * from londiste.node_remove_table(%s, %s)"
db = self.get_database('node_db')
- self.db_cmd_many(db, q, [self.set_name], args)
+ self.exec_cmd_many(db, q, [self.set_name], args)
def cmd_add_seq(self, args = []):
q = "select * from londiste.node_add_seq(%s, %s)"
db = self.get_database('node_db')
- self.db_cmd_many(db, q, [self.set_name], args)
+ self.exec_cmd_many(db, q, [self.set_name], args)
def cmd_remove_seq(self, args = []):
q = "select * from londiste.node_remove_seq(%s, %s)"
db = self.get_database('node_db')
- self.db_cmd_many(db, q, [self.set_name], args)
+ self.exec_cmd_many(db, q, [self.set_name], args)
def cmd_resync(self, args = []):
q = "select * from londiste.node_resync_table(%s, %s)"
db = self.get_database('node_db')
- self.db_cmd_many(db, q, [self.set_name], args)
+ self.exec_cmd_many(db, q, [self.set_name], args)
def cmd_tables(self, args = []):
q = "select table_name, merge_state from londiste.node_get_table_list(%s)"