Method set

backend/tkhelper/models/redis.py:58–73

(self, entity: ModelEntity)

        return None

    async def set(self, entity: ModelEntity):
        if not self.redis_conn:
            return

        # Extract primary key fields and their values from entity
        pk_fields = self.entity_class.primary_key_fields()
        pk_values = {field: getattr(entity, field) for field in pk_fields}

        # Generate the Redis key using primary key values
        key = self.__key(**pk_values, postfix=self.redis_key_postfix)

        # Convert entity to a dictionary suitable for Redis (assuming such a method exists)
        entity_dict = entity.to_redis_dict()  # This method depends on the actual implementation of ModelEntity

        # Set the object in Redis with the generated key and expiration
        await self.redis_conn.set_object(key, entity_dict, self.expire)

    async def pop(self, entity: ModelEntity):
        if not self.redis_conn: