;
+}) {
+ return (
+
+
+
+
+ Rate limits
+
+
+
+
+
+
+
+ Rate limit
+
+
+ Type
+
+
+
+
+ Requests consume tokens from a bucket that refills over time. When empty,
+ requests are rate limited.
+
+
+
+
+
+ Allows a set number of requests per time window. The window resets at
+ fixed intervals.
+
+
+
+
+
+ Allows a set number of requests per rolling time window. The limit is
+ continuously evaluated.
+
+
+
+ }
+ disableHoverableContent
+ />
+
+
+ Configuration
+
+
+ Available
+
+
+
+ Upgrade
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {info.currentTokens !== null ? (
+
+
+ {formatNumber(info.currentTokens)}
+
+
+ of {formatNumber(maxTokens)}
+
+
+ ) : (
+ –
+ )}
+
+
+
+ {info.name === "Batch rate limit" ? (
+ isOnTopPlan ? (
+ Contact us}
+ defaultValue="help"
+ />
+ ) : (
+
+ View plans
+
+ )
+ ) : (
+ Contact us}
+ defaultValue="help"
+ />
+ )}
+
+
+
+ );
+}
+
+function RateLimitTypeBadge({
+ config,
+ type,
+}: {
+ config?: RateLimitInfo["config"];
+ type?: "tokenBucket" | "fixedWindow" | "slidingWindow";
+}) {
+ const rateLimitType = type ?? config?.type;
+ switch (rateLimitType) {
+ case "tokenBucket":
+ return (
+
+ Token bucket
+
+ );
+ case "fixedWindow":
+ return (
+
+ Fixed window
+
+ );
+ case "slidingWindow":
+ return (
+
+ Sliding window
+
+ );
+ default:
+ return null;
+ }
+}
+
+function RateLimitConfigDisplay({ config }: { config: RateLimitInfo["config"] }) {
+ if (config.type === "tokenBucket") {
+ return (
+
+
+ Max tokens:{" "}
+ {formatNumber(config.maxTokens)}
+
+
+ Refill:{" "}
+
+ {formatNumber(config.refillRate)}/{config.interval}
+
+
+
+ );
+ }
+
+ if (config.type === "fixedWindow" || config.type === "slidingWindow") {
+ return (
+
+
+ Tokens:{" "}
+ {formatNumber(config.tokens)}
+
+
+ Window:{" "}
+ {config.window}
+
+
+ );
+ }
+
+ return –;
+}
+
+function QuotasSection({
+ quotas,
+ batchConcurrency,
+ isOnTopPlan,
+ billingPath,
+}: {
+ quotas: LimitsResult["quotas"];
+ batchConcurrency: LimitsResult["batchConcurrency"];
+ isOnTopPlan: boolean;
+ billingPath: string;
+}) {
+ // Collect all quotas that should be shown
+ const quotaRows: QuotaInfo[] = [];
+
+ // Always show projects
+ quotaRows.push(quotas.projects);
+
+ // Add plan-based quotas if they exist
+ if (quotas.teamMembers) quotaRows.push(quotas.teamMembers);
+ if (quotas.schedules) quotaRows.push(quotas.schedules);
+ if (quotas.alerts) quotaRows.push(quotas.alerts);
+ if (quotas.branches) quotaRows.push(quotas.branches);
+ if (quotas.realtimeConnections) quotaRows.push(quotas.realtimeConnections);
+ if (quotas.logRetentionDays) quotaRows.push(quotas.logRetentionDays);
+
+ // Include batch processing concurrency as a quota row
+ quotaRows.push({
+ name: "Batch processing concurrency",
+ description: "Controls how many batch items can be processed simultaneously.",
+ limit: batchConcurrency.limit,
+ currentUsage: 0,
+ source: batchConcurrency.source,
+ canExceed: true, // Allow contact us on top plan, view plans otherwise
+ isUpgradable: true,
+ });
+
+ // Add queue size quotas if set
+ if (quotas.devQueueSize.limit !== null) quotaRows.push(quotas.devQueueSize);
+ if (quotas.deployedQueueSize.limit !== null) quotaRows.push(quotas.deployedQueueSize);
+
+ return (
+
+
+
+ Quotas
+
+
+
+
+
+ Quota
+ Limit
+ Current
+ Source
+ Upgrade
+
+
+
+ {quotaRows.map((quota) => (
+
+ ))}
+
+
+
+ {canUpgrade ? (
+
+ View plans
+
+ ) : (
+ Contact us}
+ defaultValue="help"
+ />
+ )}
+
+
+
+ );
+ }
+
+ const renderUpgrade = () => {
+ // Projects always show Contact us (regardless of upgrade flags)
+ if (quota.name === "Projects") {
+ return (
+
+ Contact us}
+ defaultValue="help"
+ />
+
+ );
+ }
+
+ if (!quota.isUpgradable) {
+ return null;
+ }
+
+ // Not on top plan - show View plans
+ if (!isOnTopPlan) {
+ return (
+
+
+ View plans
+
+
+ );
+ }
+
+ // On top plan - show Contact us if canExceed is true
+ if (quota.canExceed) {
+ return (
+
+ Contact us}
+ defaultValue="help"
+ />
+
+ );
+ }
+
+ // On top plan but cannot exceed - no upgrade option
+ return null;
+ };
+
+ return (
+
+
+ {quota.name}
+
+
+
+ {quota.limit !== null
+ ? isRetentionQuota
+ ? `${formatNumber(quota.limit)} days`
+ : formatNumber(quota.limit)
+ : "Unlimited"}
+
+
+ {isRetentionQuota ? "–" : formatNumber(quota.currentUsage)}
+
+
+
+
+ {renderUpgrade()}
+
+ );
+}
+
+function FeaturesSection({
+ features,
+ isOnTopPlan,
+ billingPath,
+}: {
+ features: LimitsResult["features"];
+ isOnTopPlan: boolean;
+ billingPath: string;
+}) {
+ // For staging environment: show View plans if not enabled (i.e., on Free plan)
+ const stagingUpgradeType = features.hasStagingEnvironment.enabled ? "none" : "view-plans";
+
+ return (
+
+
+
+ Plan features
+
+
+
+
+ Feature
+ Status
+ Upgrade
+
+
+
+
+
+
+
+
+
+
+ View plans
+
+
+ );
+ case "contact-us":
+ return (
+
+ Contact us}
+ defaultValue="help"
+ />
+
+ );
+ case "none":
+ return null;
+ }
+ };
+
+ return (
+
+
+ {feature.name}
+
+
+ {displayValue()}
+ {renderUpgrade()}
+
+ );
+}
+
+/**
+ * Returns the appropriate color class based on usage percentage.
+ * @param percentage - The usage percentage (0-1 scale)
+ * @param mode - "usage" means higher is worse (quotas), "remaining" means lower is worse (rate limits)
+ * @returns Tailwind color class
+ */
+function getUsageColorClass(
+ percentage: number | null,
+ mode: "usage" | "remaining" = "usage"
+): string {
+ if (percentage === null) return "text-text-dimmed";
+
+ if (mode === "remaining") {
+ // For remaining tokens: 0 = bad (red), <=10% = warning (orange)
+ if (percentage <= 0) return "text-error";
+ if (percentage <= 0.1) return "text-warning";
+ return "text-text-bright";
+ } else {
+ // For usage: 100% = bad (red), >=90% = warning (orange)
+ if (percentage >= 1) return "text-error";
+ if (percentage >= 0.9) return "text-warning";
+ return "text-text-bright";
+ }
+}
+
+function SourceBadge({ source }: { source: "default" | "plan" | "override" }) {
+ const variants: Record = {
+ default: {
+ label: "Default",
+ className: "bg-indigo-500/20 text-indigo-400",
+ },
+ plan: {
+ label: "Plan",
+ className: "bg-purple-500/20 text-purple-400",
+ },
+ override: {
+ label: "Override",
+ className: "bg-amber-500/20 text-amber-400",
+ },
+ };
+
+ const variant = variants[source];
+
+ return (
+
+ {variant.label}
+
+ );
+}
diff --git a/apps/webapp/app/utils/pathBuilder.ts b/apps/webapp/app/utils/pathBuilder.ts
index a2756f7e5b..639f2f7294 100644
--- a/apps/webapp/app/utils/pathBuilder.ts
+++ b/apps/webapp/app/utils/pathBuilder.ts
@@ -507,6 +507,14 @@ export function concurrencyPath(
return `${v3EnvironmentPath(organization, project, environment)}/concurrency`;
}
+export function limitsPath(
+ organization: OrgForPath,
+ project: ProjectForPath,
+ environment: EnvironmentForPath
+) {
+ return `${v3EnvironmentPath(organization, project, environment)}/limits`;
+}
+
export function regionsPath(
organization: OrgForPath,
project: ProjectForPath,
diff --git a/apps/webapp/package.json b/apps/webapp/package.json
index 175fb5b230..987e983862 100644
--- a/apps/webapp/package.json
+++ b/apps/webapp/package.json
@@ -111,7 +111,7 @@
"@sentry/remix": "9.46.0",
"@slack/web-api": "7.9.1",
"@socket.io/redis-adapter": "^8.3.0",
- "@tabler/icons-react": "^2.39.0",
+ "@tabler/icons-react": "^3.36.1",
"@tailwindcss/container-queries": "^0.1.1",
"@tanstack/react-virtual": "^3.0.4",
"@team-plain/typescript-sdk": "^3.5.0",
diff --git a/apps/webapp/tailwind.config.js b/apps/webapp/tailwind.config.js
index 9f4e4381b8..d7ee335694 100644
--- a/apps/webapp/tailwind.config.js
+++ b/apps/webapp/tailwind.config.js
@@ -160,6 +160,9 @@ const batches = colors.pink[500];
const schedules = colors.yellow[500];
const queues = colors.purple[500];
const deployments = colors.green[500];
+const concurrency = colors.amber[500];
+const limits = colors.purple[500];
+const regions = colors.green[500];
const logs = colors.blue[500];
const tests = colors.lime[500];
const apiKeys = colors.amber[500];
@@ -235,7 +238,10 @@ module.exports = {
runs,
batches,
schedules,
+ concurrency,
queues,
+ regions,
+ limits,
deployments,
logs,
tests,
diff --git a/internal-packages/tsql/src/query/printer.test.ts b/internal-packages/tsql/src/query/printer.test.ts
index 5612b6e257..3ffb8eac27 100644
--- a/internal-packages/tsql/src/query/printer.test.ts
+++ b/internal-packages/tsql/src/query/printer.test.ts
@@ -2278,3 +2278,150 @@ describe("Field Mapping Value Transformation", () => {
// But the column metadata should use the exposed name
});
});
+
+describe("Required Filters", () => {
+ /**
+ * Tests for tables with requiredFilters, which inject internal ClickHouse
+ * column conditions (like engine = 'V2') that aren't exposed in the schema.
+ */
+
+ const schemaWithRequiredFilters: TableSchema = {
+ name: "runs",
+ clickhouseName: "trigger_dev.task_runs_v2",
+ description: "Task runs table with required filters",
+ tenantColumns: {
+ organizationId: "organization_id",
+ projectId: "project_id",
+ environmentId: "environment_id",
+ },
+ requiredFilters: [{ column: "engine", value: "V2" }],
+ columns: {
+ run_id: {
+ name: "run_id",
+ clickhouseName: "friendly_id",
+ ...column("String", { description: "Run ID", coreColumn: true }),
+ },
+ status: {
+ name: "status",
+ ...column("String", { description: "Status" }),
+ },
+ triggered_at: {
+ name: "triggered_at",
+ clickhouseName: "created_at",
+ ...column("DateTime64", { description: "When the run was triggered", coreColumn: true }),
+ },
+ total_cost: {
+ name: "total_cost",
+ ...column("Float64", { description: "Total cost" }),
+ expression: "(cost_in_cents + base_cost_in_cents) / 100.0",
+ },
+ },
+ };
+
+ function createRequiredFiltersContext(): PrinterContext {
+ const schemaRegistry = createSchemaRegistry([schemaWithRequiredFilters]);
+ return createPrinterContext({
+ organizationId: "org_test123",
+ projectId: "proj_test456",
+ environmentId: "env_test789",
+ schema: schemaRegistry,
+ });
+ }
+
+ function printQueryWithFilters(query: string): PrintResult {
+ const ctx = createRequiredFiltersContext();
+ const ast = parseTSQLSelect(query);
+ const printer = new ClickHousePrinter(ctx);
+ return printer.print(ast);
+ }
+
+ it("should NOT throw for internal engine column from requiredFilters", () => {
+ // This query should work even though 'engine' is not in the schema
+ // because it's automatically injected by requiredFilters
+ const { sql, params } = printQueryWithFilters("SELECT run_id, status FROM runs LIMIT 10");
+
+ // The engine filter should be in the WHERE clause
+ expect(sql).toContain("engine");
+ // The V2 value is parameterized, so check the params
+ expect(Object.values(params)).toContain("V2");
+ });
+
+ it("should allow TSQL column names that map to different ClickHouse names", () => {
+ // User writes 'triggered_at' but it maps to 'created_at' in ClickHouse
+ const { sql } = printQueryWithFilters(`
+ SELECT run_id, status, triggered_at
+ FROM runs
+ WHERE triggered_at > now() - INTERVAL 14 DAY
+ ORDER BY triggered_at DESC
+ LIMIT 100
+ `);
+
+ // The ClickHouse SQL should use 'created_at' instead of 'triggered_at'
+ expect(sql).toContain("created_at");
+ // The result should still have the alias for the user-friendly name
+ expect(sql).toContain("AS triggered_at");
+ });
+
+ it("should allow filtering by mapped column name", () => {
+ const { sql } = printQueryWithFilters(`
+ SELECT run_id FROM runs WHERE triggered_at > '2024-01-01' LIMIT 10
+ `);
+
+ // Should use the ClickHouse column name in the WHERE clause
+ expect(sql).toContain("created_at");
+ });
+
+ it("should allow ORDER BY on mapped column name", () => {
+ const { sql } = printQueryWithFilters(`
+ SELECT run_id FROM runs ORDER BY triggered_at DESC LIMIT 10
+ `);
+
+ // ORDER BY should use the ClickHouse column name
+ expect(sql).toContain("ORDER BY");
+ expect(sql).toContain("created_at");
+ });
+
+ it("should handle virtual columns with expressions", () => {
+ const { sql } = printQueryWithFilters(`
+ SELECT run_id, total_cost FROM runs ORDER BY total_cost DESC LIMIT 10
+ `);
+
+ // Virtual column should be expanded to its expression with an alias
+ expect(sql).toContain("cost_in_cents");
+ expect(sql).toContain("base_cost_in_cents");
+ expect(sql).toContain("AS total_cost");
+ });
+
+ it("should combine tenant guards with required filters", () => {
+ const { sql, params } = printQueryWithFilters("SELECT run_id FROM runs LIMIT 10");
+
+ // Should have all tenant columns AND the engine filter
+ expect(sql).toContain("organization_id");
+ expect(sql).toContain("project_id");
+ expect(sql).toContain("environment_id");
+ expect(sql).toContain("engine");
+ // The V2 value is parameterized, so check the params
+ expect(Object.values(params)).toContain("V2");
+ });
+
+ it("should allow complex queries with mapped columns", () => {
+ // This query is similar to what a user might write
+ const { sql } = printQueryWithFilters(`
+ SELECT
+ run_id,
+ status,
+ total_cost,
+ triggered_at
+ FROM runs
+ WHERE triggered_at > now() - INTERVAL 14 DAY
+ ORDER BY total_cost DESC
+ LIMIT 100
+ `);
+
+ // All should work without errors
+ expect(sql).toContain("friendly_id"); // run_id maps to friendly_id
+ expect(sql).toContain("status");
+ expect(sql).toContain("created_at"); // triggered_at maps to created_at
+ expect(sql).toContain("cost_in_cents"); // total_cost is a virtual column
+ });
+});
diff --git a/internal-packages/tsql/src/query/printer.ts b/internal-packages/tsql/src/query/printer.ts
index 734b4dc87c..4f92a14073 100644
--- a/internal-packages/tsql/src/query/printer.ts
+++ b/internal-packages/tsql/src/query/printer.ts
@@ -1338,6 +1338,14 @@ export class ClickHousePrinter {
// Register this table context for column name resolution
this.tableContexts.set(effectiveAlias, tableSchema);
+ // Register required filter columns as allowed internal columns
+ // These are ClickHouse columns used for internal filtering (e.g., engine = 'V2')
+ if (tableSchema.requiredFilters) {
+ for (const filter of tableSchema.requiredFilters) {
+ this.allowedInternalColumns.add(filter.column);
+ }
+ }
+
// Add tenant isolation guard
extraWhere = this.createTenantGuard(tableSchema, effectiveAlias);
} else if (
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
index 1fc310de96..76ba461892 100644
--- a/pnpm-lock.yaml
+++ b/pnpm-lock.yaml
@@ -463,8 +463,8 @@ importers:
specifier: ^8.3.0
version: 8.3.0(socket.io-adapter@2.5.4(bufferutil@4.0.9))
'@tabler/icons-react':
- specifier: ^2.39.0
- version: 2.47.0(react@18.2.0)
+ specifier: ^3.36.1
+ version: 3.36.1(react@18.2.0)
'@tailwindcss/container-queries':
specifier: ^0.1.1
version: 0.1.1(tailwindcss@3.4.1)
@@ -10170,13 +10170,13 @@ packages:
resolution: {integrity: sha512-XIB2XbzHTN6ieIjfIMV9hlVcfPU26s2vafYWQcZHWXHOxiaRZYEDKEwdl129Zyg50+foYV2jCgtrqSA6qNuNSA==}
engines: {node: '>=6'}
- '@tabler/icons-react@2.47.0':
- resolution: {integrity: sha512-iqly2FvCF/qUbgmvS8E40rVeYY7laltc5GUjRxQj59DuX0x/6CpKHTXt86YlI2whg4czvd/c8Ce8YR08uEku0g==}
+ '@tabler/icons-react@3.36.1':
+ resolution: {integrity: sha512-/8nOXeNeMoze9xY/QyEKG65wuvRhkT3q9aytaur6Gj8bYU2A98YVJyLc9MRmc5nVvpy+bRlrrwK/Ykr8WGyUWg==}
peerDependencies:
- react: ^16.5.1 || ^17.0.0 || ^18.0.0
+ react: '>= 16'
- '@tabler/icons@2.47.0':
- resolution: {integrity: sha512-4w5evLh+7FUUiA1GucvGj2ReX2TvOjEr4ejXdwL/bsjoSkof6r1gQmzqI+VHrE2CpJpB3al7bCTulOkFa/RcyA==}
+ '@tabler/icons@3.36.1':
+ resolution: {integrity: sha512-f4Jg3Fof/Vru5ioix/UO4GX+sdDsF9wQo47FbtvG+utIYYVQ/QVAC0QYgcBbAjQGfbdOh2CCf0BgiFOF9Ixtjw==}
'@tailwindcss/container-queries@0.1.1':
resolution: {integrity: sha512-p18dswChx6WnTSaJCSGx6lTmrGzNNvm2FtXmiO6AuA1V4U5REyoqwmT6kgAsIMdjo07QdAfYXHJ4hnMtfHzWgA==}
@@ -30258,13 +30258,12 @@ snapshots:
dependencies:
defer-to-connect: 1.1.3
- '@tabler/icons-react@2.47.0(react@18.2.0)':
+ '@tabler/icons-react@3.36.1(react@18.2.0)':
dependencies:
- '@tabler/icons': 2.47.0
- prop-types: 15.8.1
+ '@tabler/icons': 3.36.1
react: 18.2.0
- '@tabler/icons@2.47.0': {}
+ '@tabler/icons@3.36.1': {}
'@tailwindcss/container-queries@0.1.1(tailwindcss@3.4.1)':
dependencies: