optimize the db query and check

Author: skwowet

services/apps/script_executor_worker/src/workflows/syncMembers.ts

@@ -6,7 +6,7 @@ import * as activities from '../activities/sync/member'
 import { ISyncMembersArgs } from '../types'
 
 const activity = proxyActivities<typeof activities>({
-  startToCloseTimeout: '30 minute',
+  startToCloseTimeout: '45 minutes',
   retry: { maximumAttempts: 3, backoffCoefficient: 3 },
 })
 

services/libs/opensearch/src/repo/member.repo.ts

@@ -42,19 +42,23 @@ export class MemberRepository extends RepositoryBase<MemberRepository> {
   }
 
   public async getMembersForSync(perPage: number): Promise<string[]> {
-    // eslint-disable-next-line @typescript-eslint/no-explicit-any
     const results = await this.db().any(
       `
-        select m.id
-        from members m
-        left join indexed_entities ie on m.id = ie.entity_id and ie.type = $(type)
-        where ie.entity_id is null
-        limit ${perPage};`,
+        SELECT m.id
+        FROM members m
+        WHERE NOT EXISTS (
+          SELECT 1
+          FROM indexed_entities ie 
+          WHERE ie.entity_id = m.id
+            AND ie.type = $(type)
+        )
+        ORDER BY m.id
+        LIMIT ${perPage};
+      `,
       {
         type: IndexedEntityType.MEMBER,
       },
     )
-
     return results.map((r) => r.id)
   }