use pg reader instance for getMembersForSync

skwowet · skwowet · commit be017ecba750 · 2025-02-10T13:49:57.000+05:30
diff --git a/services/apps/script_executor_worker/src/activities/sync/member.ts b/services/apps/script_executor_worker/src/activities/sync/member.ts
@@ -21,7 +21,7 @@ export async function markEntitiesIndexed(
 }
 
 export async function getMembersForSync(batchSize: number): Promise<string[]> {
-  const memberRepo = new MemberRepository(svc.redis, svc.postgres.writer, svc.log)
+  const memberRepo = new MemberRepository(svc.redis, svc.postgres.reader, svc.log)
   return memberRepo.getMembersForSync(batchSize)
 }
 

Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@ export async function markEntitiesIndexed(`
`21`	`21`	`}`
`22`	`22`
`23`	`23`	`export async function getMembersForSync(batchSize: number): Promise<string[]> {`
`24`		`- const memberRepo = new MemberRepository(svc.redis, svc.postgres.writer, svc.log)`
	`24`	`+ const memberRepo = new MemberRepository(svc.redis, svc.postgres.reader, svc.log)`
`25`	`25`	`return memberRepo.getMembersForSync(batchSize)`
`26`	`26`	`}`
`27`	`27`