Added expiration support for Redis (#3316)

## Summary

Added expiration support for RedisMemory and RedisStorage classes. This
allows automatic cleanup of stale data in Redis if users choose to
enable expiration, improving memory management and long-term storage
efficiency.

## Type of change

- [ ] Bug fix
- [ ] New feature
- [ ] Breaking change
- [X] Improvement
- [ ] Model update
- [ ] Other:

---

## Checklist

- [ ] Code complies with style guidelines
- [ ] Ran format/validation scripts (`./scripts/format.sh` and
`./scripts/validate.sh`)
- [ ] Self-review completed
- [ ] Documentation updated (comments, docstrings)
- [ ] Examples and guides: Relevant cookbook examples have been included
or updated (if applicable)
- [ ] Tested in clean environment
- [ ] Tests added/updated (if applicable)

---

## Additional Notes

Add any important context (deployment instructions, screenshots,
security considerations, etc.)

---------

Co-authored-by: Dirk Brand <dirkbrnd@gmail.com>

Author: nhathoang0110

libs/agno/agno/memory/v2/db/redis.py

@@ -20,6 +20,7 @@ def __init__(
         port: int = 6379,
         db: int = 0,
         password: Optional[str] = None,
+        expire: Optional[int] = None,
     ):
         """
         Initialize Redis memory store.
@@ -30,8 +31,10 @@ def __init__(
             port (int): Redis port number
             db (int): Redis database number
             password (Optional[str]): Redis password if authentication is required
+            expire (Optional[int]): TTL (time to live) in seconds for Redis keys. None means no expiration.
         """
         self.prefix = prefix
+        self.expire = expire
         self.redis_client = Redis(
             host=host,
             port=port,
@@ -45,6 +48,7 @@ def __dict__(self) -> Dict[str, Any]:
         return {
             "name": "RedisMemoryDb",
             "prefix": self.prefix,
+            "expire": self.expire,
         }
 
     def _get_key(self, memory_id: str) -> str:
@@ -128,7 +132,11 @@ def upsert_memory(self, memory: MemoryRow) -> Optional[MemoryRow]:
 
             # Save to Redis
             key = self._get_key(memory.id)  # type: ignore
-            self.redis_client.set(key, json.dumps(memory_data))
+            if self.expire is not None:
+                self.redis_client.set(key, json.dumps(memory_data), ex=self.expire)
+            else:
+                self.redis_client.set(key, json.dumps(memory_data))
+
             return memory
 
         except Exception as e:

libs/agno/agno/storage/redis.py

@@ -26,6 +26,7 @@ def __init__(
         password: Optional[str] = None,
         mode: Optional[Literal["agent", "team", "workflow"]] = "agent",
         ssl: Optional[bool] = False,
+        expire: Optional[int] = None,
     ):
         """
         Initialize Redis storage for sessions.
@@ -38,9 +39,11 @@ def __init__(
             password (Optional[str]): Redis password if authentication is required
             mode (Optional[Literal["agent", "team", "workflow"]]): Storage mode
             ssl (Optional[bool]): Whether to use SSL for Redis connection
+            expire (Optional[int]): TTL (time to live) in seconds for Redis keys. None means no expiration.
         """
         super().__init__(mode)
         self.prefix = prefix
+        self.expire = expire
         self.redis_client = Redis(
             host=host,
             port=port,
@@ -267,7 +270,10 @@ def upsert(self, session: Session) -> Optional[Session]:
                 data["created_at"] = data["updated_at"]
 
             key = self._get_key(session.session_id)
-            self.redis_client.set(key, self.serialize(data))
+            if self.expire is not None:
+                self.redis_client.set(key, self.serialize(data), ex=self.expire)
+            else:
+                self.redis_client.set(key, self.serialize(data))
             return session
         except Exception as e:
             logger.error(f"Error upserting session: {e}")