Fix incorrect type when using InvalidateCacheCommand
This commit is contained in:
parent
fcc803b2bf
commit
69b3fd485d
|
@ -175,7 +175,7 @@ class ReplicationClientHandler(object):
|
|||
def send_invalidate_cache(self, cache_func, keys):
|
||||
"""Poke the master to invalidate a cache.
|
||||
"""
|
||||
cmd = InvalidateCacheCommand(cache_func, keys)
|
||||
cmd = InvalidateCacheCommand(cache_func.__name__, keys)
|
||||
self.send_command(cmd)
|
||||
|
||||
def await_sync(self, data):
|
||||
|
|
Loading…
Reference in New Issue