Fix replication after switch to simplejson

Turns out that simplejson serialises namedtuple's as dictionaries rather
than tuples by default.
This commit is contained in:
Erik Johnston 2018-03-19 16:06:02 +00:00
parent 3f961e638a
commit 610accbb7f

View file

@ -107,7 +107,7 @@ class RdataCommand(Command):
return " ".join(( return " ".join((
self.stream_name, self.stream_name,
str(self.token) if self.token is not None else "batch", str(self.token) if self.token is not None else "batch",
json.dumps(self.row), json.dumps(self.row, namedtuple_as_object=False),
)) ))
@ -301,7 +301,9 @@ class InvalidateCacheCommand(Command):
return cls(cache_func, json.loads(keys_json)) return cls(cache_func, json.loads(keys_json))
def to_line(self): def to_line(self):
return " ".join((self.cache_func, json.dumps(self.keys))) return " ".join((
self.cache_func, json.dumps(self.keys, namedtuple_as_object=False)
))
class UserIpCommand(Command): class UserIpCommand(Command):