diff --git a/services/libs/data-access-layer/src/old/apps/profiles_worker/index.ts b/services/libs/data-access-layer/src/old/apps/profiles_worker/index.ts index 4be9d9a139..62da025ec6 100644 --- a/services/libs/data-access-layer/src/old/apps/profiles_worker/index.ts +++ b/services/libs/data-access-layer/src/old/apps/profiles_worker/index.ts @@ -143,15 +143,18 @@ export async function runMemberAffiliationsUpdate( } async function insertIfMatches(activity: IDbActivityCreateData) { - for (const condition of orgCases) { - if (!condition.matches(activity)) { - continue - } + activity.organizationId = null - activity.organizationId = condition.orgId - await insertActivities([activity], true) - return + if (orgCases.length > 0) { + for (const condition of orgCases) { + if (condition.matches(activity)) { + activity.organizationId = condition.orgId + break + } + } } + + await insertActivities([activity], true) } const qs = new QueryStream(