From 6ad299945fc431d162f53b08a3de5dda729fcb3e Mon Sep 17 00:00:00 2001 From: Oleksandr Shulgin Date: Tue, 13 Oct 2015 18:05:33 +0200 Subject: [PATCH] Remove IDENTIFY_SYSTEM wrapper method (it can't work with async anyway). --- doc/src/extras.rst | 10 ---------- lib/extras.py | 9 +-------- 2 files changed, 1 insertion(+), 18 deletions(-) diff --git a/doc/src/extras.rst b/doc/src/extras.rst index bdf8fc1b..356e10e0 100644 --- a/doc/src/extras.rst +++ b/doc/src/extras.rst @@ -222,16 +222,6 @@ The individual messages in the replication stream are presented by .. autoclass:: ReplicationCursor - .. method:: identify_system() - - Execute ``IDENTIFY_SYSTEM`` command of the streaming replication - protocol and return the result as a dictionary. - - Example:: - - >>> cur.identify_system() - {'timeline': 1, 'systemid': '1234567890123456789', 'dbname': 'test', 'xlogpos': '0/1ABCDEF'} - .. method:: create_replication_slot(slot_name, slot_type=None, output_plugin=None) Create streaming replication slot. diff --git a/lib/extras.py b/lib/extras.py index c05536ad..913a6aae 100644 --- a/lib/extras.py +++ b/lib/extras.py @@ -506,13 +506,6 @@ class PhysicalReplicationConnection(ReplicationConnectionBase): class ReplicationCursor(_cursor): """A cursor used for communication on the replication protocol.""" - def identify_system(self): - """Get information about the cluster status.""" - - self.execute("IDENTIFY_SYSTEM") - return dict(zip([_.name for _ in self.description], - self.fetchall()[0])) - def create_replication_slot(self, slot_name, slot_type=None, output_plugin=None): """Create streaming replication slot.""" @@ -594,7 +587,7 @@ class ReplicationCursor(_cursor): command += "%s %s" % (self.connection.quote_ident(k), _A(str(v))) command += ")" - return self.start_replication_expert(command) + self.start_replication_expert(command) def send_feedback_message(self, written_lsn=0, sync_lsn=0, apply_lsn=0, reply_requested=False): return self.send_replication_feedback(written_lsn, sync_lsn, apply_lsn, reply_requested)