)]}'
{"taskflow/utils/redis_utils.py":[{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ece68ee58820a717aaf3a2d8ce2828ab00b494eb","unresolved":true,"context_lines":[{"line_number":32,"context_line":"    return wrapper"},{"line_number":33,"context_line":""},{"line_number":34,"context_line":""},{"line_number":35,"context_line":"class RedisClient(redis.Redis):"},{"line_number":36,"context_line":"    \"\"\"A redis client that raises on-usage after closed."},{"line_number":37,"context_line":"    \"\"\""},{"line_number":38,"context_line":"    def __init__(self, *args, **kwargs):"},{"line_number":39,"context_line":"        super().__init__(*args, **kwargs)"},{"line_number":40,"context_line":"        self.closed \u003d False"},{"line_number":41,"context_line":""},{"line_number":42,"context_line":"    def close(self):"},{"line_number":43,"context_line":"        self.closed \u003d True"},{"line_number":44,"context_line":"        super().close()"},{"line_number":45,"context_line":""},{"line_number":46,"context_line":"    execute_command \u003d _raise_on_closed(redis.Redis.execute_command)"},{"line_number":47,"context_line":"    transaction \u003d _raise_on_closed(redis.Redis.transaction)"},{"line_number":48,"context_line":"    pubsub \u003d _raise_on_closed(redis.Redis.pubsub)"},{"line_number":49,"context_line":""},{"line_number":50,"context_line":""},{"line_number":51,"context_line":"class UnknownExpire(enum.IntEnum):"},{"line_number":52,"context_line":"    \"\"\"Non-expiry (not ttls) results return from :func:`.get_expiry`."}],"source_content_type":"text/x-python","patch_set":1,"id":"45e1c856_e3067d10","line":49,"range":{"start_line":35,"start_character":0,"end_line":49,"end_character":1},"updated":"2026-09-10 16:05:04.000000000","message":"Can we just delete this now? Or at least deprecate it and remove our own usage of it?","commit_id":"01daa3ffd99740c4b0bd1c4db8dfee69d578a422"},{"author":{"_account_id":9816,"name":"Takashi Kajinami","email":"kajinamit@oss.nttdata.com","username":"kajinamit"},"change_message_id":"990144053354f19f09e7ef4a5ea8f251ec9e92fa","unresolved":true,"context_lines":[{"line_number":32,"context_line":"    return wrapper"},{"line_number":33,"context_line":""},{"line_number":34,"context_line":""},{"line_number":35,"context_line":"class RedisClient(redis.Redis):"},{"line_number":36,"context_line":"    \"\"\"A redis client that raises on-usage after closed."},{"line_number":37,"context_line":"    \"\"\""},{"line_number":38,"context_line":"    def __init__(self, *args, **kwargs):"},{"line_number":39,"context_line":"        super().__init__(*args, **kwargs)"},{"line_number":40,"context_line":"        self.closed \u003d False"},{"line_number":41,"context_line":""},{"line_number":42,"context_line":"    def close(self):"},{"line_number":43,"context_line":"        self.closed \u003d True"},{"line_number":44,"context_line":"        super().close()"},{"line_number":45,"context_line":""},{"line_number":46,"context_line":"    execute_command \u003d _raise_on_closed(redis.Redis.execute_command)"},{"line_number":47,"context_line":"    transaction \u003d _raise_on_closed(redis.Redis.transaction)"},{"line_number":48,"context_line":"    pubsub \u003d _raise_on_closed(redis.Redis.pubsub)"},{"line_number":49,"context_line":""},{"line_number":50,"context_line":""},{"line_number":51,"context_line":"class UnknownExpire(enum.IntEnum):"},{"line_number":52,"context_line":"    \"\"\"Non-expiry (not ttls) results return from :func:`.get_expiry`."}],"source_content_type":"text/x-python","patch_set":1,"id":"57f3a478_9e57aed0","line":49,"range":{"start_line":35,"start_character":0,"end_line":49,"end_character":1},"in_reply_to":"45e1c856_e3067d10","updated":"2026-09-10 16:18:13.000000000","message":"I\u0027ll try that but I decided to put that out of the initial scope because I\u0027ve not evaluated the impact of this fully.","commit_id":"01daa3ffd99740c4b0bd1c4db8dfee69d578a422"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"decbf3c5e1dfa1b98fcea50fe18fc7ddf09246cf","unresolved":false,"context_lines":[{"line_number":32,"context_line":"    return wrapper"},{"line_number":33,"context_line":""},{"line_number":34,"context_line":""},{"line_number":35,"context_line":"class RedisClient(redis.Redis):"},{"line_number":36,"context_line":"    \"\"\"A redis client that raises on-usage after closed."},{"line_number":37,"context_line":"    \"\"\""},{"line_number":38,"context_line":"    def __init__(self, *args, **kwargs):"},{"line_number":39,"context_line":"        super().__init__(*args, **kwargs)"},{"line_number":40,"context_line":"        self.closed \u003d False"},{"line_number":41,"context_line":""},{"line_number":42,"context_line":"    def close(self):"},{"line_number":43,"context_line":"        self.closed \u003d True"},{"line_number":44,"context_line":"        super().close()"},{"line_number":45,"context_line":""},{"line_number":46,"context_line":"    execute_command \u003d _raise_on_closed(redis.Redis.execute_command)"},{"line_number":47,"context_line":"    transaction \u003d _raise_on_closed(redis.Redis.transaction)"},{"line_number":48,"context_line":"    pubsub \u003d _raise_on_closed(redis.Redis.pubsub)"},{"line_number":49,"context_line":""},{"line_number":50,"context_line":""},{"line_number":51,"context_line":"class UnknownExpire(enum.IntEnum):"},{"line_number":52,"context_line":"    \"\"\"Non-expiry (not ttls) results return from :func:`.get_expiry`."}],"source_content_type":"text/x-python","patch_set":1,"id":"f3d90ff8_89c7b228","line":49,"range":{"start_line":35,"start_character":0,"end_line":49,"end_character":1},"in_reply_to":"57f3a478_9e57aed0","updated":"2026-09-10 16:30:40.000000000","message":"Acknowledged","commit_id":"01daa3ffd99740c4b0bd1c4db8dfee69d578a422"},{"author":{"_account_id":9816,"name":"Takashi Kajinami","email":"kajinamit@oss.nttdata.com","username":"kajinamit"},"change_message_id":"4cbdb383b221fdc582a0a39e9055b975f559c90e","unresolved":false,"context_lines":[{"line_number":32,"context_line":"    return wrapper"},{"line_number":33,"context_line":""},{"line_number":34,"context_line":""},{"line_number":35,"context_line":"class RedisClient(redis.Redis):"},{"line_number":36,"context_line":"    \"\"\"A redis client that raises on-usage after closed."},{"line_number":37,"context_line":"    \"\"\""},{"line_number":38,"context_line":"    def __init__(self, *args, **kwargs):"},{"line_number":39,"context_line":"        super().__init__(*args, **kwargs)"},{"line_number":40,"context_line":"        self.closed \u003d False"},{"line_number":41,"context_line":""},{"line_number":42,"context_line":"    def close(self):"},{"line_number":43,"context_line":"        self.closed \u003d True"},{"line_number":44,"context_line":"        super().close()"},{"line_number":45,"context_line":""},{"line_number":46,"context_line":"    execute_command \u003d _raise_on_closed(redis.Redis.execute_command)"},{"line_number":47,"context_line":"    transaction \u003d _raise_on_closed(redis.Redis.transaction)"},{"line_number":48,"context_line":"    pubsub \u003d _raise_on_closed(redis.Redis.pubsub)"},{"line_number":49,"context_line":""},{"line_number":50,"context_line":""},{"line_number":51,"context_line":"class UnknownExpire(enum.IntEnum):"},{"line_number":52,"context_line":"    \"\"\"Non-expiry (not ttls) results return from :func:`.get_expiry`."}],"source_content_type":"text/x-python","patch_set":1,"id":"3cb84a9f_30d921e3","line":49,"range":{"start_line":35,"start_character":0,"end_line":49,"end_character":1},"in_reply_to":"c28167e0_b3d9a77a","updated":"2026-09-10 16:48:04.000000000","message":"Yeah, though we shouldn\u0027t really need that in this layer and the coordination driver should take care of that properly, IMHO.","commit_id":"01daa3ffd99740c4b0bd1c4db8dfee69d578a422"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"32d577153f71675301561956e509b7d317a4aa55","unresolved":false,"context_lines":[{"line_number":32,"context_line":"    return wrapper"},{"line_number":33,"context_line":""},{"line_number":34,"context_line":""},{"line_number":35,"context_line":"class RedisClient(redis.Redis):"},{"line_number":36,"context_line":"    \"\"\"A redis client that raises on-usage after closed."},{"line_number":37,"context_line":"    \"\"\""},{"line_number":38,"context_line":"    def __init__(self, *args, **kwargs):"},{"line_number":39,"context_line":"        super().__init__(*args, **kwargs)"},{"line_number":40,"context_line":"        self.closed \u003d False"},{"line_number":41,"context_line":""},{"line_number":42,"context_line":"    def close(self):"},{"line_number":43,"context_line":"        self.closed \u003d True"},{"line_number":44,"context_line":"        super().close()"},{"line_number":45,"context_line":""},{"line_number":46,"context_line":"    execute_command \u003d _raise_on_closed(redis.Redis.execute_command)"},{"line_number":47,"context_line":"    transaction \u003d _raise_on_closed(redis.Redis.transaction)"},{"line_number":48,"context_line":"    pubsub \u003d _raise_on_closed(redis.Redis.pubsub)"},{"line_number":49,"context_line":""},{"line_number":50,"context_line":""},{"line_number":51,"context_line":"class UnknownExpire(enum.IntEnum):"},{"line_number":52,"context_line":"    \"\"\"Non-expiry (not ttls) results return from :func:`.get_expiry`."}],"source_content_type":"text/x-python","patch_set":1,"id":"c28167e0_b3d9a77a","line":49,"range":{"start_line":35,"start_character":0,"end_line":49,"end_character":1},"in_reply_to":"f3d90ff8_89c7b228","updated":"2026-09-10 16:32:41.000000000","message":"Just to note that I\u0027d misunderstood what this was doing and hadn\u0027t noticed the `_raise_on_closed` wrappers. I now understand what this is doing.","commit_id":"01daa3ffd99740c4b0bd1c4db8dfee69d578a422"}]}