diff options
| author | Oleksandr Shulgin <oleksandr.shulgin@zalando.de> | 2015-10-23 11:31:55 +0200 |
|---|---|---|
| committer | Oleksandr Shulgin <oleksandr.shulgin@zalando.de> | 2015-10-23 11:31:55 +0200 |
| commit | e69dafbeccf4a1ff096759bd531fd771955592da (patch) | |
| tree | 498e6e9ec8103ea89dde52c0c93c6f077494c604 /lib/extras.py | |
| parent | 76c7f4a0b5f3ff69499239917fb0aec8b0da6adf (diff) | |
| download | psycopg2-e69dafbeccf4a1ff096759bd531fd771955592da.tar.gz | |
Move the `decode` parameter to `start_replication()`.
It makes more sense this way, because otherwise it must be passed to every call
of `read_message()`.
Diffstat (limited to 'lib/extras.py')
| -rw-r--r-- | lib/extras.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/extras.py b/lib/extras.py index 8e1373c..8a8d34f 100644 --- a/lib/extras.py +++ b/lib/extras.py @@ -548,7 +548,7 @@ class ReplicationCursor(_replicationCursor): self.execute(command) def start_replication(self, slot_name=None, slot_type=None, start_lsn=0, - timeline=0, options=None): + timeline=0, options=None, decode=False): """Start replication stream.""" command = "START_REPLICATION " @@ -597,7 +597,7 @@ class ReplicationCursor(_replicationCursor): command += "%s %s" % (quote_ident(k, self), _A(str(v))) command += ")" - self.start_replication_expert(command) + self.start_replication_expert(command, decode=decode) # allows replication cursors to be used in select.select() directly def fileno(self): |