diff --git a/internal/caches/storage_memory.go b/internal/caches/storage_memory.go index ea09ccb..345781e 100644 --- a/internal/caches/storage_memory.go +++ b/internal/caches/storage_memory.go @@ -508,7 +508,11 @@ func (this *MemoryStorage) flushItem(key string) { if !ok { return } - if !item.IsDone || item.IsExpired() { + if !item.IsDone { + remotelogs.Error("CACHE", "flush items failed: open writer failed: item has not been done") + return + } + if item.IsExpired() { return }