Reformat comment
This commit is contained in:
parent
3ed382ec13
commit
ebfa06e8d6
2
db.py
2
db.py
|
@ -50,7 +50,7 @@ async def store_kafka_batch(data):
|
||||||
batch = producer.create_batch()
|
batch = producer.create_batch()
|
||||||
for msg in data:
|
for msg in data:
|
||||||
if msg["type"] in TYPES_MAIN:
|
if msg["type"] in TYPES_MAIN:
|
||||||
#index = "main"
|
# index = "main"
|
||||||
index = MAIN_SRC_MAP[msg["src"]]
|
index = MAIN_SRC_MAP[msg["src"]]
|
||||||
# schema = mc_s.schema_main
|
# schema = mc_s.schema_main
|
||||||
elif msg["type"] in TYPES_META:
|
elif msg["type"] in TYPES_META:
|
||||||
|
|
Loading…
Reference in New Issue