add redis

Author: Yuri Zmytrakov

stac_fastapi/core/setup.py

@@ -19,6 +19,7 @@
     "pygeofilter~=0.3.1",
     "jsonschema~=4.0.0",
     "slowapi~=0.1.9",
+    "redis==6.4.0",
 ]
 
 setup(

stac_fastapi/core/stac_fastapi/core/core.py

@@ -28,7 +28,6 @@
     add_previous_link,
     cache_current_url,
     cache_previous_url,
-    connect_redis_sentinel,
     connect_redis,
 )
 from stac_fastapi.core.serializers import CollectionSerializer, ItemSerializer
@@ -248,7 +247,7 @@ async def all_collections(self, **kwargs) -> stac_types.Collections:
         redis = None
         try:
             redis = await connect_redis()
-        except Exception as e:
+        except Exception:
             redis = None
 
         collections, next_token = await self.database.get_all_collections(
@@ -265,9 +264,7 @@ async def all_collections(self, **kwargs) -> stac_types.Collections:
             },
         ]
 
-        await add_previous_link(
-            redis, links, "collections", current_url, token
-        )
+        await add_previous_link(redis, links, "collections", current_url, token)
         if redis:
             await cache_previous_url(redis, current_url, "collections")
 
@@ -303,7 +300,6 @@ async def get_collection(
     async def item_collection(
         self,
         collection_id: str,
-        request: Request,
         bbox: Optional[BBox] = None,
         datetime: Optional[str] = None,
         limit: Optional[int] = None,
@@ -350,7 +346,7 @@ async def item_collection(
 
         try:
             redis = await connect_redis()
-        except Exception as e:
+        except Exception:
             redis = None
 
         if redis:
@@ -568,7 +564,7 @@ async def post_search(
         current_url = str(request.url)
         try:
             redis = await connect_redis()
-        except Exception as e:
+        except Exception:
             redis = None
 
         if redis:

stac_fastapi/core/stac_fastapi/core/redis_utils.py

@@ -91,7 +91,7 @@ async def connect_redis_sentinel(
 
             redis_pool = master
 
-        except:
+        except Exception:
             return None
 
     return redis_pool

stac_fastapi/tests/conftest.py

@@ -6,6 +6,7 @@
 
 import pytest
 import pytest_asyncio
+import redis  # noqa: F401
 from fastapi import Depends, HTTPException, security, status
 from httpx import ASGITransport, AsyncClient
 from pydantic import ConfigDict