not work with pipeline if extend Redis

[guileen]

Pipeline extends Redis, If I want to write a subclass extends Redis ,add some new method just like set_obj,get_obj in my own serialization, the pipeline should not work with these method. Because it extends Redis not my subclass.

Should pipeline be a embedded executor ?

Any good ideas?

[andymccurdy]

What's an embedded executor?

Multiple Inheritance could probably solve your problem fairly easily.

class MyCustomRedisClass(redis.Redis):
    # ... your custom methods ...
    def pipeline(self, transaction=True):
        return MyCustomRedisPipeline(self.connection, transaction, self.encoding, self.errors)

class MyCustomRedisPipeline(MyCustomRedisClass, redis.Pipeline):
    pass

[guileen]

thanks a lot.