We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7b7e744 commit 7e85654Copy full SHA for 7e85654
1 file changed
services/apps/cron_service/src/jobs/inferMemberOrganizationStintChanges.job.ts
@@ -23,7 +23,7 @@ const job: IJobDefinition = {
23
const qx = pgpQx(db)
24
25
// 1. Get a batch of work
26
- const memberIds = await redis.sRandMember(MEMBER_ORG_STINT_CHANGES_QUEUE, 500)
+ const memberIds = await redis.sRandMemberCount(MEMBER_ORG_STINT_CHANGES_QUEUE, 500)
27
if (!memberIds?.length) return
28
29
ctx.log.info({ count: memberIds.length }, 'Processing pending members.')
@@ -63,7 +63,7 @@ const job: IJobDefinition = {
63
// 4. Cleanup: Remove only the fields we actually read
64
await redis
65
.multi()
66
- .hDel(datesKey, ...orgIds)
+ .hDel(datesKey, orgIds)
67
.sRem(MEMBER_ORG_STINT_CHANGES_QUEUE, memberId)
68
.exec()
69
0 commit comments