diff --git a/cliquet/permission/redis.py b/cliquet/permission/redis.py index ee6ecaf0..abab7911 100644 --- a/cliquet/permission/redis.py +++ b/cliquet/permission/redis.py @@ -59,7 +59,7 @@ def remove_principal(self, principal): with self._client.pipeline() as pipe: user_keys = self._client.scan_iter(match='user:*') for user_key in user_keys: - self._client.srem(user_key, principal) + pipe.srem(user_key, principal) pipe.execute() @wrap_redis_error