fix(webapp): cast concurrency limits in allocation query

Mono-RevId: 91cf6369dd693fc72a235b7c59cb238e61210231

Author: carderne

apps/webapp/app/v3/services/allocateConcurrency.server.ts

@@ -363,7 +363,7 @@ async function computeOrgExtraAllocatedConcurrency(
   }
 
   const limitCases = Prisma.join(
-    typeLimits.map((entry) => Prisma.sql`WHEN ${entry.type}::text THEN ${entry.limit}`),
+    typeLimits.map((entry) => Prisma.sql`WHEN ${entry.type}::text THEN ${entry.limit}::integer`),
     " "
   );
   const countableTypes = Prisma.join(typeLimits.map((entry) => entry.type));

apps/webapp/test/allocateConcurrency.test.ts

@@ -1,4 +1,4 @@
-import { postgresTest } from "@internal/testcontainers";
+import { postgresBlipTest, postgresTest } from "@internal/testcontainers";
 import type { PrismaClient } from "@trigger.dev/database";
 import { describe, expect, vi } from "vitest";
 import { ManageConcurrencyPresenter } from "~/presenters/v3/ManageConcurrencyPresenter.server";
@@ -176,6 +176,21 @@ describe("AllocateConcurrencyService", () => {
     }
   );
 
+  postgresBlipTest("allocates with the production database adapter", async ({ prisma }) => {
+    const { organization, project, environments } = await seedProjectWithEnvironments(prisma, 1);
+    getCurrentPlanMock.mockResolvedValue(planWithPurchasedConcurrency(10));
+
+    const service = new AllocateConcurrencyService(prisma);
+    const result = await service.call({
+      userId: "user_1",
+      projectId: project.id,
+      organizationId: organization.id,
+      environments: [{ id: environments[0].id, amount: 1 }],
+    });
+
+    expect(result).toEqual({ success: true });
+  });
+
   postgresTest(
     "rejects an allocation that exceeds the unallocated pool and syncs nothing",
     async ({ prisma }) => {