(self, **kwargs)
| 43 | return ":".join(key_parts) |
| 44 | |
| 45 | async def get(self, **kwargs) -> Optional[ModelEntity]: |
| 46 | if not self.redis_conn: |
| 47 | return None |
| 48 | key = self.__key(self.redis_key_postfix, **kwargs) |
| 49 | data = await self.redis_conn.get_object(key) |
| 50 | if data: |
| 51 | try: |
| 52 | return self.entity_class.build(data) |
| 53 | except Exception as e: |
| 54 | logger.error(f"Error building entity from Redis data: {e}") |
| 55 | await self.redis_conn.pop(key) |
| 56 | return None |
| 57 | |
| 58 | async def set(self, entity: ModelEntity): |
| 59 | if not self.redis_conn: |