diff --git a/db.py b/db.py
index 1deb398..0574fc5 100644
--- a/db.py
+++ b/db.py
@@ -50,7 +50,7 @@ async def store_kafka_batch(data):
     batch = producer.create_batch()
     for msg in data:
         if msg["type"] in TYPES_MAIN:
-            #index = "main"
+            # index = "main"
             index = MAIN_SRC_MAP[msg["src"]]
             # schema = mc_s.schema_main
         elif msg["type"] in TYPES_META: