fix

Author: skwowet

services/apps/script_executor_worker/src/activities.ts

@@ -13,7 +13,6 @@ import {
 import {
   addOrgIdToRedisCache,
   calculateMemberAffiliations,
-  createActivities,
   findActivitiesPg,
   getMembersWithDeletedOrgAffilations,
 } from './activities/fix-deleted-member-org-affilations'
@@ -69,7 +68,7 @@ export {
   getMembersWithDeletedOrgAffilations,
   // getActivities,
   findActivitiesPg,
-  createActivities,
+  // createActivities,
   addOrgIdToRedisCache,
   calculateMemberAffiliations,
 }

services/apps/script_executor_worker/src/activities/fix-deleted-member-org-affilations/index.ts

@@ -1,4 +1,4 @@
-import { insertActivities, queryActivities } from '@crowd/data-access-layer'
+// import { insertActivities, queryActivities } from '@crowd/data-access-layer'
 import {
   IDbActivity,
   IDbActivityCreateData,
@@ -46,13 +46,13 @@ export async function findActivitiesPg(memberId: string, orgId: string): Promise
   return repo.findActivities(memberId, orgId)
 }
 
-export async function createActivities(activities: IDbActivityCreateData[]): Promise<void> {
-  try {
-    await insertActivities(svc.queue, activities)
-  } catch (err) {
-    throw new Error(err)
-  }
-}
+// export async function createActivities(activities: IDbActivityCreateData[]): Promise<void> {
+//   try {
+//     await insertActivities(svc.queue, activities)
+//   } catch (err) {
+//     throw new Error(err)
+//   }
+// }
 
 export async function calculateMemberAffiliations(memberId: string): Promise<void> {
   try {