diff --git a/backend/package-lock.json b/backend/package-lock.json
index 5e87b678f9..196ff82c57 100644
--- a/backend/package-lock.json
+++ b/backend/package-lock.json
@@ -12308,11 +12308,13 @@
         "@opentelemetry/instrumentation-bunyan": "~0.32.1",
         "@opentelemetry/instrumentation-express": "~0.33.1",
         "@opentelemetry/instrumentation-http": "~0.43.0",
-        "@opentelemetry/instrumentation-redis": "~0.35.1",
+        "@opentelemetry/instrumentation-pg": "^0.36.2",
+        "@opentelemetry/instrumentation-redis-4": "^0.35.3",
         "@opentelemetry/resource-detector-aws": "~1.3.1",
         "@opentelemetry/resources": "~1.17.0",
         "@opentelemetry/sdk-node": "~0.43.0",
         "@opentelemetry/semantic-conventions": "~1.17.0",
+        "opentelemetry-instrumentation-kafkajs": "~0.39.1",
         "opentelemetry-instrumentation-sequelize": "~0.39.1"
       },
       "devDependencies": {
@@ -55247,7 +55249,8 @@
         "@opentelemetry/instrumentation-bunyan": "~0.32.1",
         "@opentelemetry/instrumentation-express": "~0.33.1",
         "@opentelemetry/instrumentation-http": "~0.43.0",
-        "@opentelemetry/instrumentation-redis": "~0.35.1",
+        "@opentelemetry/instrumentation-pg": "^0.36.2",
+        "@opentelemetry/instrumentation-redis-4": "^0.35.3",
         "@opentelemetry/resource-detector-aws": "~1.3.1",
         "@opentelemetry/resources": "~1.17.0",
         "@opentelemetry/sdk-node": "~0.43.0",
@@ -55258,6 +55261,7 @@
         "eslint": "^8.39.0",
         "eslint-config-prettier": "^8.8.0",
         "eslint-plugin-prettier": "^4.2.1",
+        "opentelemetry-instrumentation-kafkajs": "~0.39.1",
         "opentelemetry-instrumentation-sequelize": "~0.39.1",
         "prettier": "^2.8.8",
         "typescript": "^5.0.4"
diff --git a/frontend/src/modules/member/components/member-dropdown.vue b/frontend/src/modules/member/components/member-dropdown.vue
index 2f265afd45..cdd97cc74e 100644
--- a/frontend/src/modules/member/components/member-dropdown.vue
+++ b/frontend/src/modules/member/components/member-dropdown.vue
@@ -29,9 +29,7 @@
             class="h-10 mb-1"
             :disabled="isEditLockedForSampleData"
           >
-            <i class="ri-pencil-line text-base mr-2" /><span class="text-xs"
-              >Edit contact</span
-            >
+            <i class="ri-pencil-line text-base mr-2" /><span class="text-xs">Edit contact</span>
           </el-dropdown-item>
         </router-link>
         <el-tooltip
@@ -65,10 +63,9 @@
                 :class="{
                   'text-gray-400': isEnrichmentDisabledForMember,
                 }"
-                >{{
-                  member.lastEnriched ? "Re-enrich contact" : "Enrich contact"
-                }}</span
-              >
+              >{{
+                member.lastEnriched ? "Re-enrich contact" : "Enrich contact"
+              }}</span>
             </el-dropdown-item>
           </span>
         </el-tooltip>
@@ -81,9 +78,10 @@
           class="h-10 mb-1"
           :disabled="!isFindingGitHubDisabled"
         >
-          <span class="max-w-[16px]" color="#9CA3AF"
-            ><i class="ri-github-fill"
-          /></span>
+          <span
+            class="max-w-[16px]"
+            color="#9CA3AF"
+          ><i class="ri-github-fill" /></span>
           <span class="ml-2 text-xs"> Find GitHub </span>
         </el-dropdown-item>
         <el-dropdown-item
@@ -94,9 +92,7 @@
           }"
           :disabled="isEditLockedForSampleData"
         >
-          <i class="ri-group-line text-base mr-2" /><span class="text-xs"
-            >Merge contact</span
-          >
+          <i class="ri-group-line text-base mr-2" /><span class="text-xs">Merge contact</span>
         </el-dropdown-item>
 
         <!-- Hubspot -->
@@ -144,9 +140,7 @@
           }"
           :disabled="isEditLockedForSampleData"
         >
-          <i class="ri-bookmark-line text-base mr-2" /><span class="text-xs"
-            >Mark as team contact</span
-          >
+          <i class="ri-bookmark-line text-base mr-2" /><span class="text-xs">Mark as team contact</span>
         </el-dropdown-item>
         <el-dropdown-item
           v-if="member.attributes.isTeamMember?.default"
@@ -158,9 +152,7 @@
           }"
           :disabled="isEditLockedForSampleData"
         >
-          <i class="ri-bookmark-2-line text-base mr-2" /><span class="text-xs"
-            >Unmark as team contact</span
-          >
+          <i class="ri-bookmark-2-line text-base mr-2" /><span class="text-xs">Unmark as team contact</span>
         </el-dropdown-item>
         <el-dropdown-item
           v-if="!member.attributes.isBot?.default"
@@ -171,9 +163,7 @@
           }"
           :disabled="isEditLockedForSampleData"
         >
-          <i class="ri-robot-line text-base mr-2" /><span class="text-xs"
-            >Mark as bot</span
-          >
+          <i class="ri-robot-line text-base mr-2" /><span class="text-xs">Mark as bot</span>
         </el-dropdown-item>
         <el-dropdown-item
           v-if="member.attributes.isBot?.default"
@@ -184,9 +174,7 @@
           }"
           :disabled="isEditLockedForSampleData"
         >
-          <i class="ri-robot-line text-base mr-2" /><span class="text-xs"
-            >Unmark as bot</span
-          >
+          <i class="ri-robot-line text-base mr-2" /><span class="text-xs">Unmark as bot</span>
         </el-dropdown-item>
         <el-divider class="border-gray-200" />
         <el-dropdown-item
@@ -207,8 +195,7 @@
             :class="{
               'text-red-500': !isDeleteLockedForSampleData,
             }"
-            >Delete contact</span
-          >
+          >Delete contact</span>
         </el-dropdown-item>
       </template>
     </el-dropdown>
@@ -220,23 +207,23 @@
 </template>
 
 <script>
-import { mapActions, mapGetters } from "vuex";
-import { mapActions as piniaMapActions } from "pinia";
-import { MemberService } from "@/modules/member/member-service";
-import Message from "@/shared/message/message";
-import { MemberPermissions } from "@/modules/member/member-permissions";
-import ConfirmDialog from "@/shared/dialog/confirm-dialog";
-import AppSvg from "@/shared/svg/svg.vue";
-import { useMemberStore } from "@/modules/member/store/pinia";
-import { CrowdIntegrations } from "@/integrations/integrations-config";
-import { HubspotEntity } from "@/integrations/hubspot/types/HubspotEntity";
-import { HubspotApiService } from "@/integrations/hubspot/hubspot.api.service";
-import AppMemberFindGithubDrawer from "./member-find-github-drawer.vue";
-import { FeatureFlag, FEATURE_FLAGS } from "@/featureFlag";
-import { isEnrichmentFeatureEnabled } from "@/modules/member/member-enrichment";
+import { mapActions, mapGetters } from 'vuex';
+import { mapActions as piniaMapActions } from 'pinia';
+import { MemberService } from '@/modules/member/member-service';
+import Message from '@/shared/message/message';
+import { MemberPermissions } from '@/modules/member/member-permissions';
+import ConfirmDialog from '@/shared/dialog/confirm-dialog';
+import AppSvg from '@/shared/svg/svg.vue';
+import { useMemberStore } from '@/modules/member/store/pinia';
+import { CrowdIntegrations } from '@/integrations/integrations-config';
+import { HubspotEntity } from '@/integrations/hubspot/types/HubspotEntity';
+import { HubspotApiService } from '@/integrations/hubspot/hubspot.api.service';
+import { isEnrichmentFeatureEnabled } from '@/modules/member/member-enrichment';
+import AppMemberFindGithubDrawer from './member-find-github-drawer.vue';
+import { FeatureFlag, FEATURE_FLAGS } from '@/featureFlag';
 
 export default {
-  name: "AppMemberDropdown",
+  name: 'AppMemberDropdown',
   components: {
     AppSvg,
     AppMemberFindGithubDrawer,
@@ -247,27 +234,27 @@ export default {
       default: () => {},
     },
   },
-  emits: ["merge"],
+  emits: ['merge'],
   data() {
     return {
       isMergeLoading: false,
       pair: [],
       openFindGitHubDrawer: false,
       isFindGitHubFeatureEnabled: FeatureFlag.isFlagEnabled(
-        FEATURE_FLAGS.findGitHub
+        FEATURE_FLAGS.findGitHub,
       ),
     };
   },
 
   computed: {
     ...mapGetters({
-      currentTenant: "auth/currentTenant",
-      currentUser: "auth/currentUser",
+      currentTenant: 'auth/currentTenant',
+      currentUser: 'auth/currentUser',
     }),
     isReadOnly() {
       return (
-        new MemberPermissions(this.currentTenant, this.currentUser).edit ===
-        false
+        new MemberPermissions(this.currentTenant, this.currentUser).edit
+        === false
       );
     },
     isEnrichmentDisabled() {
@@ -277,12 +264,12 @@ export default {
     },
     isFindingGitHubDisabled() {
       console.log(
-        this.member.username?.github === undefined ||
-          !this.member.username?.github?.length
+        this.member.username?.github === undefined
+          || !this.member.username?.github?.length,
       );
       return (
-        this.member.username?.github === undefined ||
-        !this.member.username?.github?.length
+        this.member.username?.github === undefined
+        || !this.member.username?.github?.length
       );
     },
     isEditLockedForSampleData() {
@@ -300,19 +287,19 @@ export default {
     },
     isEnrichmentActionDisabled() {
       return (
-        this.isEnrichmentDisabledForMember ||
-        this.isEditLockedForSampleData ||
-        !this.isEnrichmentFeatureEnabled()
+        this.isEnrichmentDisabledForMember
+        || this.isEditLockedForSampleData
+        || !this.isEnrichmentFeatureEnabled()
       );
     },
     isSyncingWithHubspot() {
       return this.member.attributes?.syncRemote?.hubspot || false;
     },
     isHubspotConnected() {
-      const hubspot = CrowdIntegrations.getMappedConfig("hubspot", this.$store);
+      const hubspot = CrowdIntegrations.getMappedConfig('hubspot', this.$store);
       const enabledFor = hubspot.settings?.enabledFor || [];
       return (
-        hubspot.status === "done" && enabledFor.includes(HubspotEntity.MEMBERS)
+        hubspot.status === 'done' && enabledFor.includes(HubspotEntity.MEMBERS)
       );
     },
     isHubspotDisabledForMember() {
@@ -323,29 +310,29 @@ export default {
     },
     isHubspotActionDisabled() {
       return (
-        !this.isHubspotConnected ||
-        this.isHubspotDisabledForMember ||
-        !this.isHubspotFeatureEnabled
+        !this.isHubspotConnected
+        || this.isHubspotDisabledForMember
+        || !this.isHubspotFeatureEnabled
       );
     },
   },
   methods: {
     ...mapActions({
-      doFind: "member/doFind",
-      doDestroy: "member/doDestroy",
-      doEnrich: "member/doEnrich",
+      doFind: 'member/doFind',
+      doDestroy: 'member/doDestroy',
+      doEnrich: 'member/doEnrich',
     }),
-    ...piniaMapActions(useMemberStore, ["fetchMembers"]),
+    ...piniaMapActions(useMemberStore, ['fetchMembers']),
     async doDestroyWithConfirm(id) {
       try {
         await ConfirmDialog({
-          type: "danger",
-          title: "Delete contact",
+          type: 'danger',
+          title: 'Delete contact',
           message:
             "Are you sure you want to proceed? You can't undo this action",
-          confirmButtonText: "Confirm",
-          cancelButtonText: "Cancel",
-          icon: "ri-delete-bin-line",
+          confirmButtonText: 'Confirm',
+          cancelButtonText: 'Cancel',
+          icon: 'ri-delete-bin-line',
         });
 
         await this.doDestroy(id);
@@ -356,34 +343,34 @@ export default {
       return null;
     },
     async handleCommand(command) {
-      if (command.action === "memberDelete") {
+      if (command.action === 'memberDelete') {
         await this.doDestroyWithConfirm(command.member.id);
       } else if (
-        command.action === "syncHubspot" ||
-        command.action === "stopSyncHubspot"
+        command.action === 'syncHubspot'
+        || command.action === 'stopSyncHubspot'
       ) {
         // Hubspot
-        const sync = command.action === "syncHubspot";
+        const sync = command.action === 'syncHubspot';
         (sync
           ? HubspotApiService.syncMember(command.member.id)
           : HubspotApiService.stopSyncMember(command.member.id)
         )
           .then(() => {
-            if (this.$route.name === "member") {
+            if (this.$route.name === 'member') {
               this.fetchMembers({ reload: true });
             } else {
               this.doFind(command.member.id);
             }
             if (sync) {
-              Message.success("Contact is now syncing with HubSpot");
+              Message.success('Contact is now syncing with HubSpot');
             } else {
-              Message.success("Contact syncing stopped");
+              Message.success('Contact syncing stopped');
             }
           })
           .catch(() => {
-            Message.error("There was an error");
+            Message.error('There was an error');
           });
-      } else if (command.action === "memberMarkAsTeamMember") {
+      } else if (command.action === 'memberMarkAsTeamMember') {
         await MemberService.update(command.member.id, {
           attributes: {
             ...command.member.attributes,
@@ -394,39 +381,39 @@ export default {
         });
         await this.fetchMembers({ reload: true });
 
-        Message.success("Contact updated successfully");
+        Message.success('Contact updated successfully');
 
-        if (this.$route.name === "member") {
+        if (this.$route.name === 'member') {
           await this.fetchMembers({ reload: true });
         } else {
           this.doFind(command.member.id);
         }
       } else if (
-        command.action === "memberMarkAsBot" ||
-        command.action === "memberUnmarkAsBot"
+        command.action === 'memberMarkAsBot'
+        || command.action === 'memberUnmarkAsBot'
       ) {
         await MemberService.update(command.member.id, {
           attributes: {
             ...command.member.attributes,
             isBot: {
-              default: command.action === "memberMarkAsBot",
+              default: command.action === 'memberMarkAsBot',
             },
           },
         });
         await this.fetchMembers({ reload: true });
-        Message.success("Contact updated successfully");
-        if (this.$route.name === "member") {
+        Message.success('Contact updated successfully');
+        if (this.$route.name === 'member') {
           await this.fetchMembers({ reload: true });
         } else {
           this.doFind(command.member.id);
         }
-      } else if (command.action === "memberMerge") {
-        this.$emit("merge");
-      } else if (command.action === "memberEnrich") {
+      } else if (command.action === 'memberMerge') {
+        this.$emit('merge');
+      } else if (command.action === 'memberEnrich') {
         await this.doEnrich(command.member.id);
         await this.fetchMembers({ reload: true });
-      } else if (command.action === "memberFindGitHub") {
-        console.log("here");
+      } else if (command.action === 'memberFindGitHub') {
+        console.log('here');
         this.openFindGitHubDrawer = true;
         console.log(this.openFindGitHubDrawer);
       }
diff --git a/frontend/src/modules/member/components/member-enrichment.vue b/frontend/src/modules/member/components/member-enrichment.vue
index 1401fc1235..47db5f0510 100644
--- a/frontend/src/modules/member/components/member-enrichment.vue
+++ b/frontend/src/modules/member/components/member-enrichment.vue
@@ -7,9 +7,7 @@
           class="w-5 h-5 enrichment-icon"
           color="#111827"
         />
-        <span class="text-gray-900 font-semibold text-sm"
-          >Contact enrichment</span
-        >
+        <span class="text-gray-900 font-semibold text-sm">Contact enrichment</span>
       </div>
       <el-tooltip placement="top" content="Learn more">
         <a
@@ -18,8 +16,7 @@
           href="https://docs.crowd.dev/docs/member-enrichment"
           target="_blank"
           rel="noopener noreferrer"
-          ><i class="ri-question-line text-lg"
-        /></a>
+        ><i class="ri-question-line text-lg" /></a>
       </el-tooltip>
     </div>
 
@@ -40,8 +37,7 @@
           class="btn btn--primary btn--full !h-8"
           :disabled="isEditLockedForSampleData"
           @click="onEnrichmentClick"
-          >Enrich member</el-button
-        >
+        >Enrich member</el-button>
         <el-button
           v-else
           class="btn btn--primary btn--full !h-8"
@@ -74,14 +70,16 @@
 </template>
 
 <script setup>
-import { computed, defineProps, onMounted, ref } from "vue";
-import { mapActions, mapGetters } from "@/shared/vuex/vuex.helpers";
-import AppSvg from "@/shared/svg/svg.vue";
-import { isEnrichmentFeatureEnabled } from "@/modules/member/member-enrichment";
-import { useRouter } from "vue-router";
-import { MemberPermissions } from "../member-permissions";
-import AppMemberFindGithubDrawer from "./member-find-github-drawer.vue";
-import { FeatureFlag, FEATURE_FLAGS } from "@/featureFlag";
+import {
+  computed, defineProps, onMounted, ref,
+} from 'vue';
+import { mapActions, mapGetters } from '@/shared/vuex/vuex.helpers';
+import AppSvg from '@/shared/svg/svg.vue';
+import { isEnrichmentFeatureEnabled } from '@/modules/member/member-enrichment';
+import { useRouter } from 'vue-router';
+import { MemberPermissions } from '../member-permissions';
+import AppMemberFindGithubDrawer from './member-find-github-drawer.vue';
+import { FeatureFlag, FEATURE_FLAGS } from '@/featureFlag';
 
 const router = useRouter();
 const props = defineProps({
@@ -91,28 +89,27 @@ const props = defineProps({
   },
 });
 
-const { doEnrich } = mapActions("member");
-const { doRefreshCurrentUser } = mapActions("auth");
-const { currentTenant, currentUser } = mapGetters("auth");
+const { doEnrich } = mapActions('member');
+const { doRefreshCurrentUser } = mapActions('auth');
+const { currentTenant, currentUser } = mapGetters('auth');
 
 const isFindGitHubFeatureEnabled = FeatureFlag.isFlagEnabled(
-  FEATURE_FLAGS.findGitHub
+  FEATURE_FLAGS.findGitHub,
 );
 
 const isEnrichmentDisabled = computed(
-  () => !props.member.username?.github?.length && !props.member.emails?.length
+  () => !props.member.username?.github?.length && !props.member.emails?.length,
 );
 
 const openFindGitHubDrawer = ref(false);
 
 const isEditLockedForSampleData = computed(
-  () =>
-    new MemberPermissions(currentTenant.value, currentUser.value)
-      .editLockedForSampleData
+  () => new MemberPermissions(currentTenant.value, currentUser.value)
+    .editLockedForSampleData,
 );
 
 const isEnrichmentActionDisabled = computed(
-  () => isEnrichmentDisabled.value || isEditLockedForSampleData.value
+  () => isEnrichmentDisabled.value || isEditLockedForSampleData.value,
 );
 
 onMounted(() => {
@@ -121,7 +118,7 @@ onMounted(() => {
 
 const onEnrichmentClick = async () => {
   if (!isEnrichmentFeatureEnabled()) {
-    router.push("/settings?activeTab=plans");
+    router.push('/settings?activeTab=plans');
     return;
   }
   await doEnrich(props.member.id);
diff --git a/frontend/src/modules/member/components/member-find-github-drawer.vue b/frontend/src/modules/member/components/member-find-github-drawer.vue
index 1ffa08f5bb..35184d738a 100644
--- a/frontend/src/modules/member/components/member-find-github-drawer.vue
+++ b/frontend/src/modules/member/components/member-find-github-drawer.vue
@@ -6,7 +6,9 @@
     custom-class="identities-drawer"
   >
     <template #content>
-      <p class="text-sm text-gray-600 mb-6">We have found the following profiles on GitHub that could match {{ member.displayName }}. You can select the correct one to add it to the member.</p>
+      <p class="text-sm text-gray-600 mb-6">
+        We have found the following profiles on GitHub that could match {{ member.displayName }}. You can select the correct one to add it to the member.
+      </p>
       <div v-for="suggestion in suggestions" key="suggestion.url" class="flex items-center">
         <div
           class="py-2 flex justify-between w-full px-4 cursor-pointer hover:bg-gray-50 rounded-md hover:shadow-sm"
@@ -102,8 +104,6 @@ const drawerModel = computed({
 
 const title = computed(() => `Find the GitHub identity for ${props.member.displayName}`);
 
-
-
 const loading = ref(false);
 
 const handleCancel = () => {
diff --git a/frontend/src/utils/featureFlag/index.js b/frontend/src/utils/featureFlag/index.js
index f87437acd7..3f30f52c5a 100644
--- a/frontend/src/utils/featureFlag/index.js
+++ b/frontend/src/utils/featureFlag/index.js
@@ -1,18 +1,18 @@
-import { UnleashClient } from "unleash-proxy-client";
-import { useLogRocket } from "@/utils/logRocket";
-import config from "@/config";
-import { store } from "@/store";
+import { UnleashClient } from 'unleash-proxy-client';
+import { useLogRocket } from '@/utils/logRocket';
+import config from '@/config';
+import { store } from '@/store';
 
 export const FEATURE_FLAGS = {
-  eagleEye: "eagle-eye",
-  organizations: "organizations",
-  automations: "automations",
-  linkedin: "linkedin",
-  memberEnrichment: "member-enrichment",
-  csvExport: "csv-export",
-  hubspot: "hubspot",
-  findGitHub: "find-github",
-  logRocket: "log-rocket",
+  eagleEye: 'eagle-eye',
+  organizations: 'organizations',
+  automations: 'automations',
+  linkedin: 'linkedin',
+  memberEnrichment: 'member-enrichment',
+  csvExport: 'csv-export',
+  hubspot: 'hubspot',
+  findGitHub: 'find-github',
+  logRocket: 'log-rocket',
 };
 
 class FeatureFlagService {
@@ -23,8 +23,8 @@ class FeatureFlagService {
       const unleashConfig = {
         url: `${config.unleash.url}/api/frontend`,
         clientKey: config.unleash.apiKey,
-        appName: "crowd-web-app",
-        environment: "production",
+        appName: 'crowd-web-app',
+        environment: 'production',
       };
       this.unleash = new UnleashClient(unleashConfig);
     }
@@ -45,18 +45,18 @@ class FeatureFlagService {
       this.updateContext(context);
     }
 
-    this.unleash.on("ready", () => {
+    this.unleash.on('ready', () => {
       initLogRocket();
 
-      store.dispatch("tenant/doUpdateFeatureFlag", {
+      store.dispatch('tenant/doUpdateFeatureFlag', {
         isReady: true,
       });
     });
 
-    this.unleash.on("error", (error) => {
+    this.unleash.on('error', (error) => {
       captureException(error);
 
-      store.dispatch("tenant/doUpdateFeatureFlag", {
+      store.dispatch('tenant/doUpdateFeatureFlag', {
         hasError: true,
       });
     });
@@ -66,7 +66,7 @@ class FeatureFlagService {
     if (config.isCommunityVersion) {
       return true;
     }
-    console.log("unleash", flag, this.unleash.isEnabled(flag));
+    console.log('unleash', flag, this.unleash.isEnabled(flag));
     return this.unleash.isEnabled(flag);
   }
 
@@ -101,16 +101,16 @@ class FeatureFlagService {
 
   premiumFeatureCopy() {
     if (config.isCommunityVersion) {
-      return "Enterprise";
+      return 'Enterprise';
     }
-    return "Scale";
+    return 'Scale';
   }
 
   scaleFeatureCopy() {
     if (config.isCommunityVersion) {
-      return "Enterprise";
+      return 'Enterprise';
     }
-    return "Scale";
+    return 'Scale';
   }
 }
 
diff --git a/services/scripts/install_lib_packages.sh b/services/scripts/install_lib_packages.sh
index d889cd7673..ad474263bd 100755
--- a/services/scripts/install_lib_packages.sh
+++ b/services/scripts/install_lib_packages.sh
@@ -1,9 +1,23 @@
 #!/usr/bin/env bash
+if [[ ${TERM} == "" || ${TERM} == "dumb" ]]; then
+    RED=""
+    GREEN=""
+    GREY=""
+    YELLOW=""
+    RESET=""
+else
+    RED=`tput setaf 1`
+    GREEN=`tput setaf 2`
+    GREY=`tput setaf 7`
+    YELLOW=`tput setaf 3`
+    RESET=`tput sgr0`
+fi
 
 set -eo pipefail
 CLI_HOME="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null 2>&1 && pwd )"
 
-source $CLI_HOME/utils.sh
+FLAGS=$1
+N=3  # change this to control the concurrency level
 
 printf '%s\0' $CLI_HOME/../libs/*/ | xargs -0 -n1 -P$N -I{} bash -c '
     if [ -f "$0/package.json" ]; then