Merge pull request #2470 from trycompai/main

[comp] Production Deploy

Author: Marfuen

.github/workflows/trigger-api-tasks-deploy-main.yml

@@ -18,6 +18,8 @@ jobs:
           node-version: "22.x" # Updated to match Node.js w/ Vercel
       - name: Setup Bun
         uses: oven-sh/setup-bun@v2
+        with:
+          bun-version: "1.3.4"
       - name: Clear cache
         run: rm -rf node_modules .bun
       - name: Install dependencies

.github/workflows/trigger-api-tasks-deploy-release.yml

@@ -21,6 +21,8 @@ jobs:
 
       - name: Setup Bun
         uses: oven-sh/setup-bun@v2
+        with:
+          bun-version: "1.3.4"
 
       - name: Install dependencies
         run: bun install --frozen-lockfile || bun install --frozen-lockfile --ignore-scripts

.github/workflows/trigger-tasks-deploy-main.yml

@@ -14,6 +14,8 @@ jobs:
           node-version: "22.x" # Updated to match Node.js w/ Vercel
       - name: Setup Bun
         uses: oven-sh/setup-bun@v2
+        with:
+          bun-version: "1.3.4"
       - name: Clear cache
         run: rm -rf node_modules .bun
       - name: Install dependencies

.github/workflows/trigger-tasks-deploy-release.yml

@@ -18,6 +18,8 @@ jobs:
 
       - name: Setup Bun
         uses: oven-sh/setup-bun@v2
+        with:
+          bun-version: "1.3.4"
 
       - name: Install dependencies
         run: bun install --frozen-lockfile || bun install --frozen-lockfile --ignore-scripts

apps/api/package.json

@@ -12,7 +12,7 @@
         "@aws-sdk/client-securityhub": "^3.948.0",
         "@aws-sdk/client-sts": "^3.948.0",
         "@aws-sdk/s3-request-presigner": "^3.859.0",
-        "@browserbasehq/sdk": "^2.6.0",
+        "@browserbasehq/sdk": "2.6.0",
         "@browserbasehq/stagehand": "^3.0.5",
         "@mendable/firecrawl-js": "^4.9.3",
         "@nestjs/common": "^11.0.1",

apps/api/src/trigger/browser-automation/run-browser-automation.ts

@@ -1,5 +1,5 @@
 import { db } from '@db';
-import { logger, task } from '@trigger.dev/sdk';
+import { logger, tags, task } from '@trigger.dev/sdk';
 import { BrowserbaseService } from '../../browserbase/browserbase.service';
 import { triggerEmail } from '../../email/trigger-email';
 import { TaskStatusChangedEmail } from '../../email/templates/task-status-changed';
@@ -187,6 +187,8 @@ export const runBrowserAutomation = task({
   }) => {
     const { automationId, automationName, organizationId, taskId } = payload;
 
+    await tags.add([`org:${organizationId}`]);
+
     logger.info(`Running browser automation "${automationName}"`, {
       automationId,
       organizationId,

apps/api/src/trigger/cloud-security/run-cloud-security-scan.ts

@@ -1,5 +1,5 @@
 import { db } from '@db';
-import { logger, task } from '@trigger.dev/sdk';
+import { logger, tags, task } from '@trigger.dev/sdk';
 
 /**
  * Trigger task that runs a cloud security scan for a single connection.
@@ -20,6 +20,8 @@ export const runCloudSecurityScan = task({
     const { connectionId, organizationId, providerSlug, connectionName } =
       payload;
 
+    await tags.add([`org:${organizationId}`]);
+
     logger.info(
       `Starting cloud security scan for connection: ${connectionName}`,
       {

apps/api/src/trigger/integration-platform/run-connection-checks.ts

@@ -1,6 +1,6 @@
 import { getManifest, runAllChecks } from '@trycompai/integration-platform';
 import { db } from '@db';
-import { logger, task } from '@trigger.dev/sdk';
+import { logger, tags, task } from '@trigger.dev/sdk';
 
 /**
  * Trigger task that runs all checks for a connection.
@@ -22,6 +22,8 @@ export const runConnectionChecks = task({
   }) => {
     const { connectionId, organizationId, providerSlug } = payload;
 
+    await tags.add([`org:${organizationId}`]);
+
     logger.info(`Auto-running checks for connection ${connectionId}`, {
       provider: providerSlug,
       organizationId,

apps/api/src/trigger/integration-platform/run-task-integration-checks.ts

@@ -1,6 +1,6 @@
 import { getManifest, runAllChecks } from '@trycompai/integration-platform';
 import { db } from '@db';
-import { logger, task } from '@trigger.dev/sdk';
+import { logger, tags, task } from '@trigger.dev/sdk';
 import { triggerEmail } from '../../email/trigger-email';
 import { TaskStatusChangedEmail } from '../../email/templates/task-status-changed';
 import { isUserUnsubscribed } from '@trycompai/email';
@@ -185,6 +185,8 @@ export const runTaskIntegrationChecks = task({
       checkIds,
     } = payload;
 
+    await tags.add([`org:${organizationId}`]);
+
     logger.info(`Running integration checks for task "${taskTitle}"`, {
       taskId,
       connectionId,

apps/api/src/trigger/policies/update-policy.ts

@@ -1,4 +1,4 @@
-import { logger, metadata, queue, schemaTask } from '@trigger.dev/sdk';
+import { logger, metadata, queue, schemaTask, tags } from '@trigger.dev/sdk';
 import { z } from 'zod';
 import { processPolicyUpdate } from './update-policy-helpers';
 
@@ -29,6 +29,8 @@ export const updatePolicy = schemaTask({
     memberId: z.string().optional(),
   }),
   run: async (params) => {
+    await tags.add([`org:${params.organizationId}`]);
+
     try {
       logger.info(`Starting policy update for policy ${params.policyId}`);