diff --git a/scripts/flush_db.py b/scripts/flush_db.py index 68d45e6..32231cc 100644 --- a/scripts/flush_db.py +++ b/scripts/flush_db.py @@ -34,12 +34,11 @@ async def main(): async for key in items: try: data_bytes = await redis.get(key) - data = data_bytes.decode("utf-8").replace("'", '"') - json_string = json.dumps(data) - data = json.loads(json.loads(json_string)) + data_str = data_bytes.decode("utf-8") + data = json.loads(data_str) except ValueError as e: - print(e) print("flush_db: invalid key") + print(e) continue events.append(