Loading csst_dag/redis.py +2 −2 Original line number Diff line number Diff line Loading @@ -26,10 +26,10 @@ class Redis(redis.Redis): print(f" - {k}: {v}") def push(self, msg): self.lpush(self.name, msg) self.lpush(self.qname, msg) def pop(self): return self.rpop(self.name) return self.rpop(self.qname) def get_all(self): return self.lrange(self.qname, 0, -1) Loading Loading
csst_dag/redis.py +2 −2 Original line number Diff line number Diff line Loading @@ -26,10 +26,10 @@ class Redis(redis.Redis): print(f" - {k}: {v}") def push(self, msg): self.lpush(self.name, msg) self.lpush(self.qname, msg) def pop(self): return self.rpop(self.name) return self.rpop(self.qname) def get_all(self): return self.lrange(self.qname, 0, -1) Loading