forgot to add insert

Signed-off-by: Isaac Milarsky <imilarsky@gmail.com>
chaoss · Aug 31, 2024 · 07d4e92 · 07d4e92
1 parent c0ac99a
commit 07d4e92
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/augur/tasks/git/facade_tasks.py b/augur/tasks/git/facade_tasks.py
@@ -170,6 +170,8 @@ def facade_fetch_missing_commit_messages(repo_git):
 
     missing_message_hashes = get_missing_commit_message_hashes(repo.repo_id)
 
+    to_insert = []
+
     for hash in missing_message_hashes:
 
         absolute_path = get_absolute_repo_path(facade_helper.repo_base_directory, repo.repo_id, repo.repo_path,repo.repo_name)
@@ -188,6 +190,14 @@ def facade_fetch_missing_commit_messages(repo_git):
             'data_source' : 'git',
             'data_collection_date' : datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
         }
+
+        if len(to_insert) >= 1000:
+            bulk_insert_dicts(logger,to_insert, CommitMessage, ["repo_id","cmt_hash"])
+
+        to_insert.append(msg_record)
+
+    if to_insert:
+        bulk_insert_dicts(logger, to_insert, CommitMessage, ["repo_id","cmt_hash"])
 
 
 #enable celery multithreading