minor correction
This commit is contained in:
@@ -46,8 +46,7 @@ def process_records(records, thread):
|
||||
:param thread: thread id of processing thread
|
||||
"""
|
||||
data = []
|
||||
#for i in tqdm(range(len(records)), desc=f"thread {thread}"):
|
||||
for i in tqdm(range(1), desc=f"thread {thread}"):
|
||||
for i in tqdm(range(len(records)), desc=f"thread {thread}"):
|
||||
record = process_record(records[i])
|
||||
data.append(InsertOne(record))
|
||||
collection = connect_db()
|
||||
|
||||
Reference in New Issue
Block a user