diff --git a/db.py b/db.py index 4a82cd1..9e898e8 100644 --- a/db.py +++ b/db.py @@ -127,13 +127,9 @@ async def store_batch(data): else: indexmap[INDEX].append(msg) - print("KEYS", indexmap.keys()) - for index, index_messages in indexmap.items(): for message in index_messages: result = await client.index(index=index, body=message) - if index == "internal": - print("INTERNAL RES", result) if not result["result"] == "created": log.error(f"Indexing failed: {result}") log.debug(f"Indexed {len(data)} messages in ES")