diff --git a/mongo/mongo.go b/mongo/mongo.go index f1f9eb9..cc1f8bc 100644 --- a/mongo/mongo.go +++ b/mongo/mongo.go @@ -232,6 +232,11 @@ func cleanRedis(ctx context.Context, tenantId interface{}, collection string) (e return } } + oneKey := fmt.Sprintf(consts.One, tenantId, collection) + _, err = redis.RedisClient.Del(ctx, oneKey) + if err != nil { + return + } return }