fix: handle TA db replication lag (#1220)

Author: joseph-sentry

services/test_analytics/ta_processing.py

@@ -47,9 +47,11 @@ def get_ta_processing_info(
     commitid: str,
     commit_yaml: dict[str, Any],
 ) -> TAProcInfo:
-    repository = Repository.objects.get(repoid=repoid)
+    repository = Repository.objects.using("default").get(repoid=repoid)
 
-    commit = Commit.objects.get(repository=repository, commitid=commitid)
+    commit = Commit.objects.using("default").get(
+        repository=repository, commitid=commitid
+    )
     branch = commit.branch
 
     user_yaml: UserYaml = UserYaml(commit_yaml)

services/test_analytics/ta_processor.py

@@ -39,7 +39,7 @@ def ta_processor_impl(
     if upload_id is None:
         return False
 
-    upload = ReportSession.objects.get(id=upload_id)
+    upload = ReportSession.objects.using("default").get(id=upload_id)
     if upload.state == "processed":
         # don't need to process again because the intermediate result should already be in redis
         return False