Don't cache error responses

gusutabopb · Apr 10, 2019 · be7b87c · be7b87c
1 parent 67dda02
commit be7b87c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/aioinflux/client.py b/aioinflux/client.py
@@ -365,8 +365,9 @@ async def _chunked_generator(url, data):
                 data = await resp.read()
                 if use_cache and self._redis:
                     logger.debug(f'Cache MISS ({resp.status}): {q}')
-                    await self._redis.set(key, lz4.compress(data))
-                    await self._redis.expire(key, self.cache_expiry)
+                    if resp.status == 200:
+                        await self._redis.set(key, lz4.compress(data))
+                        await self._redis.expire(key, self.cache_expiry)
                 else:
                     logger.debug(f'{resp.status}: {q}')