psycopg/psycopg2
1
1
Fork 0
mirror of https://github.com/psycopg/psycopg2.git synced 2024-11-26 10:53:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix error test for invalid START_REPLICATION command.

Browse Source
This commit is contained in:
Oleksandr Shulgin 2016-01-21 15:56:27 +01:00
parent 09a4bb70a1
commit 5d33b39829
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/test_replication.py
View File

@ -126,8 +126,14 @@ class ReplicationTest(ReplicationTestCase):
self.create_replication_slot(cur, output_plugin='test_decoding') self.create_replication_slot(cur, output_plugin='test_decoding')
self.assertRaises(psycopg2.DataError, cur.start_replication, # try with invalid options
slot_name=self.slot, options=dict(invalid_param='value')) cur.start_replication(slot_name=self.slot, options={'invalid_param': 'value'})
def consume(msg):
pass
# we don't see the error from the server before we try to read the data
self.assertRaises(psycopg2.DataError, cur.consume_stream, consume)
# try with correct command
cur.start_replication(slot_name=self.slot) cur.start_replication(slot_name=self.slot)
@skip_before_postgres(9, 4) # slots require 9.4 @skip_before_postgres(9, 4) # slots require 9.4