more logging and type casting

CrowdDotDev · Jan 4, 2024 · c42e8d1 · c42e8d1
1 parent 2558ba6
commit c42e8d1
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 8 deletions.
diff --git a/...s/merge_suggestions_worker/src/activities/member-merge-suggestions/getMergeSuggestions.ts b/...s/merge_suggestions_worker/src/activities/member-merge-suggestions/getMergeSuggestions.ts
@@ -165,13 +165,23 @@ export async function getMergeSuggestions(
     ],
   }
 
-  const membersToMerge: ISimilarMemberOpensearch[] =
-    (
-      await svc.opensearch.client.search({
-        index: OpenSearchIndex.MEMBERS,
-        body: similarMembersQueryBody,
-      })
-    ).body?.hits?.hits || []
+  let membersToMerge: ISimilarMemberOpensearch[]
+
+  try {
+    membersToMerge =
+      (
+        await svc.opensearch.client.search({
+          index: OpenSearchIndex.MEMBERS,
+          body: similarMembersQueryBody,
+        })
+      ).body?.hits?.hits || []
+  } catch (e) {
+    svc.log.info(
+      { error: e, query: identitiesPartialQuery },
+      'Error while searching for similar members!',
+    )
+    throw e
+  }
 
   for (const memberToMerge of membersToMerge) {
     mergeSuggestions.push({

diff --git a/services/apps/merge_suggestions_worker/src/repo/memberMergeSuggestions.repo.ts b/services/apps/merge_suggestions_worker/src/repo/memberMergeSuggestions.repo.ts
@@ -106,7 +106,7 @@ class MemberMergeSuggestionsRepository {
           'toMergeId',
         )})::uuid, $(${idPlaceholder('similarity')}), $(${idPlaceholder(
           'activityEstimate',
-        )}), NOW(), NOW())`,
+        )})::integer, NOW(), NOW())`,
         replacements: {
           [idPlaceholder('memberId')]: memberId,
           [idPlaceholder('toMergeId')]: toMergeId,