diff --git a/apps/webapp/app/v3/featureFlags.server.ts b/apps/webapp/app/v3/featureFlags.server.ts index 7760df8fe..d45cdfd39 100644 --- a/apps/webapp/app/v3/featureFlags.server.ts +++ b/apps/webapp/app/v3/featureFlags.server.ts @@ -252,7 +252,7 @@ async function stampGracedGroups( graceMs: number ): Promise> { const existingRows = await tx.featureFlag.findMany({ - where: { key: { in: GRACED_GLOBAL_KEYS } }, + where: { key: { in: boundedIn(GRACED_GLOBAL_KEYS) } }, select: { key: true, value: true }, }); const existingGlobal: Record = {}; diff --git a/apps/webapp/app/v3/runOpsMigration/runOpsMintShard.server.ts b/apps/webapp/app/v3/runOpsMigration/runOpsMintShard.server.ts index 02a432fb5..9a93eeb22 100644 --- a/apps/webapp/app/v3/runOpsMigration/runOpsMintShard.server.ts +++ b/apps/webapp/app/v3/runOpsMigration/runOpsMintShard.server.ts @@ -1,6 +1,6 @@ import { createHash } from "node:crypto"; import type { ShardKey } from "@trigger.dev/core/v3/isomorphic"; -import { $replica } from "~/db.server"; +import { $replica, boundedIn } from "~/db.server"; import { env } from "~/env.server"; import { logger } from "~/services/logger.server"; import { BoundedTtlCache } from "~/services/realtime/boundedTtlCache"; @@ -208,7 +208,7 @@ const liveCache = singleton("runOpsMintShardCache", (): { current: MintShardCach async function readSetFlags(): Promise> { const rows = await $replica.featureFlag.findMany({ - where: { key: { in: GLOBAL_SHARD_KEYS } }, + where: { key: { in: boundedIn(GLOBAL_SHARD_KEYS) } }, select: { key: true, value: true }, }); const flags: Record = {};