Don't error if we get a REPLICATE command without a connection

It's probably just a race.
pull/7187/head
Erik Johnston 2020-04-06 14:41:10 +01:00
parent 8a6a6802c0
commit ad2a80a742
1 changed files with 0 additions and 3 deletions

View File

@ -118,9 +118,6 @@ class ReplicationCommandHandler:
if not self._is_master:
return
if not self._connections:
raise Exception("Not connected")
for stream_name, stream in self._streams.items():
current_token = stream.current_token()
self.send_command(PositionCommand(stream_name, current_token))