Commit 9dd5a721 authored by Julien Muchembled's avatar Julien Muchembled

storate: fix AttributeError when cancelling replication

parent 4fcd8ddc
......@@ -82,7 +82,7 @@ class Replicator(object):
def getCurrentConnection(self):
node = self.current_node
if node is not None and node.isConnected():
if node is not None and node.isConnected(True):
return node.getConnection()
# XXX: We can't replicate unfinished transactions but do we need such
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment