diff options
author | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-04-19 01:01:59 +0100 |
---|---|---|
committer | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-04-19 01:01:59 +0100 |
commit | 248e653c9e2ec2dfc0b1eac9561981b34a637f9d (patch) | |
tree | 9496cf5abeca9775b481c7118c706f84d37b01e3 /tests | |
parent | 4b4d2796b7efdd0846e972fd7a300ca4e7b11ccd (diff) | |
download | psycopg2-248e653c9e2ec2dfc0b1eac9561981b34a637f9d.tar.gz |
Fixed args parsing in ReplicationCursor.consume_stream()
Close #547.
Diffstat (limited to 'tests')
-rwxr-xr-x | tests/test_replication.py | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/tests/test_replication.py b/tests/test_replication.py index 0aed578..182bff2 100755 --- a/tests/test_replication.py +++ b/tests/test_replication.py @@ -159,6 +159,29 @@ class ReplicationTest(ReplicationTestCase): # try with correct command cur.start_replication(slot_name=self.slot) + @skip_before_postgres(9, 4) # slots require 9.4 + @skip_repl_if_green + def test_keepalive(self): + conn = self.repl_connect(connection_factory=LogicalReplicationConnection) + if conn is None: + return + + cur = conn.cursor() + + self.create_replication_slot(cur, output_plugin='test_decoding') + + self.make_replication_events() + + cur.start_replication(self.slot) + + def consume(msg): + raise StopReplication() + + self.assertRaises(StopReplication, + cur.consume_stream, consume, keepalive_interval=2) + + conn.close() + @skip_before_postgres(9, 4) # slots require 9.4 @skip_repl_if_green def test_stop_replication(self): |