diff options
| author | Marko Kreen | 2008-04-25 14:48:32 +0000 |
|---|---|---|
| committer | Marko Kreen | 2008-04-25 14:48:32 +0000 |
| commit | 7ad93d5ca136a10c970a38837641b5789f3f8033 (patch) | |
| tree | 93c4be1e4089e99c7cb735b40918f6c369b04aa3 /python/londiste/setup.py | |
| parent | a6bc0ffa2c37b9e43a5bca7b4003313ce1875ad3 (diff) | |
pgq_set: pause/resume/change-provider/rename-node work now
Diffstat (limited to 'python/londiste/setup.py')
| -rw-r--r-- | python/londiste/setup.py | 10 |
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)" |
