register workflow

Author: skwowet

services/apps/script_executor_worker/src/workflows.ts

@@ -1,11 +1,13 @@
 import { dissectMember } from './workflows/dissectMember'
 import { findAndMergeMembersWithSamePlatformIdentitiesDifferentCapitalization } from './workflows/findAndMergeMembersWithSamePlatformIdentitiesDifferentCapitalization'
 import { findAndMergeMembersWithSameVerifiedEmailsInDifferentPlatforms } from './workflows/findAndMergeMembersWithSameVerifiedEmailsInDifferentPlatforms'
+import { fixActivitiesWithWrongMember } from './workflows/fixActivitiesWithWrongMember'
 import { fixOrgIdentitiesWithWrongUrls } from './workflows/fixOrgIdentitiesWithWrongUrls'
 
 export {
   findAndMergeMembersWithSameVerifiedEmailsInDifferentPlatforms,
   findAndMergeMembersWithSamePlatformIdentitiesDifferentCapitalization,
   dissectMember,
   fixOrgIdentitiesWithWrongUrls,
+  fixActivitiesWithWrongMember,
 }

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

@@ -7,7 +7,7 @@ const activity = proxyActivities<typeof activities>({
   startToCloseTimeout: '45 minutes',
 })
 
-export async function fixMisattributedActivities(
+export async function fixActivitiesWithWrongMember(
   args: IFixActivitiesWithWrongMembersArgs,
 ): Promise<void> {
   let records = await activity.findActivitiesWithWrongMembers(args.limit)