Merge branch 'main' into fix-nango-trigger-schedules-CM-962

Author: themarolt

scripts/cli

@@ -225,9 +225,21 @@ function select_services() {
         SERVICES+=("$filename")
     done < <(find "$CLI_HOME/services" -name '*.yaml')
 
-    # Show multiselect and store results in SELECTED_SERVICES
-    multiselect SELECTED_SERVICES SERVICES[@]
+    # Use fzf if available, fall back to built-in multiselect
+    if command -v fzf &>/dev/null; then
+        mapfile -t SELECTED_SERVICES < <(
+            printf '%s\n' "${SERVICES[@]}" | sort | fzf --multi --height=40% --prompt="Select services (TAB to toggle, ENTER to confirm): "
+        )
+    else
+        multiselect SELECTED_SERVICES SERVICES[@]
+    fi
+
+    if [[ ${#SELECTED_SERVICES[@]} -eq 0 ]]; then
+        error "No services selected!"
+        exit 1
+    fi
 
+    local selected_services=""
     for service in "${SELECTED_SERVICES[@]}"; do
         selected_services+="$service, "
     done

services/apps/members_enrichment_worker/package.json

@@ -6,8 +6,6 @@
     "start:debug": "CROWD_TEMPORAL_TASKQUEUE=members-enrichment SERVICE=members-enrichment-worker LOG_LEVEL=trace tsx --inspect=0.0.0.0:9232 src/main.ts",
     "dev:local": "nodemon --watch src --watch ../../../libs --ext ts --exec pnpm run start:debug:local",
     "dev": "nodemon --watch src --watch ../../../libs --ext ts --exec pnpm run start:debug",
-    "script:onboarding:local": "set -a && . ../../../../backend/.env.dist.local && . ../../../../backend/.env.override.local && set +a && SERVICE=script tsx --inspect src/bin/onboarding.ts",
-    "script:onboarding": "SERVICE=script tsx --inspect src/bin/onboarding.ts",
     "lint": "npx eslint --ext .ts src --max-warnings=0",
     "format": "npx prettier --write \"src/**/*.ts\"",
     "format-check": "npx prettier --check .",

services/apps/members_enrichment_worker/src/activities.ts

@@ -3,28 +3,21 @@ import {
   fetchMemberDataForLLMSquashing,
   findMemberEnrichmentCache,
   findMemberIdentityWithTheMostActivityInPlatform,
-  findWhichLinkedinProfileToUseAmongScraperResult,
   getEnrichmentData,
   getEnrichmentInput,
+  getMaxConcurrentRequests,
   getObsoleteSourcesOfMember,
   getPriorityArray,
   hasRemainingCredits,
   insertMemberEnrichmentCache,
   isCacheObsolete,
   normalizeEnrichmentData,
   refreshMemberEnrichmentMaterializedView,
-  squashMultipleValueAttributesWithLLM,
-  squashWorkExperiencesWithLLM,
   touchMemberEnrichmentCacheUpdatedAt,
   touchMemberEnrichmentLastTriedAt,
   updateMemberEnrichmentCache,
   updateMemberUsingSquashedPayload,
 } from './activities/enrichment'
-import {
-  getEnrichableMembers,
-  getMaxConcurrentRequests,
-  getMemberById,
-} from './activities/getMembers'
 import { refreshToken } from './activities/lf-auth0/authenticateLFAuth0'
 import {
   getIdentitiesExistInOtherMembers,
@@ -40,9 +33,16 @@ import {
   updateIdentitySourceId,
 } from './activities/lf-auth0/githubIdentities'
 import {
+  findWhichLinkedinProfileToUseAmongScraperResult,
+  squashMultipleValueAttributesWithLLM,
+  squashWorkExperiencesWithLLM,
+} from './activities/llm'
+import {
+  getEnrichableMembers,
+  getMemberById,
   syncMembersToOpensearch,
   syncOrganizationsToOpensearch,
-} from './activities/syncEnrichedData'
+} from './activities/member'
 
 export {
   touchMemberEnrichmentLastTriedAt,