@@ -0,0 +1,6 @@
+---
+area: webapp
+type: improvement
+---
+
+You can now buy or reduce extra schedules from the Schedules row on the Limits page.
@@ -1,7 +1,8 @@
 import { Ratelimit } from "@upstash/ratelimit";
 import type { RuntimeEnvironmentType } from "@trigger.dev/database";
 import { env } from "~/env.server";
-import { getCurrentPlan } from "~/services/platform.v3.server";
+import { type SchedulePricing } from "~/components/schedules/PurchaseSchedulesModal";
+import { getCachedPlans, getCurrentPlan } from "~/services/platform.v3.server";
 import {
   RateLimiterConfig,
   createLimiterFromConfig,
@@ -91,6 +92,13 @@ export type LimitsResult = {
   planName: string | null;
   organizationId: string;
   isOnTopPlan: boolean;
+  /** Set when the plan allows self-serve schedule add-on purchases. */
+  schedulePurchase: {
+    schedulePricing: SchedulePricing;
+    extraSchedules: number;
+    maxScheduleQuota: number;
+    planScheduleLimit: number;
+  } | null;
 };
 
 export class LimitsPresenter extends BasePresenter {
@@ -135,6 +143,10 @@ export class LimitsPresenter extends BasePresenter {
     const currentPlan = await getCurrentPlan(organizationId);
     const limits = currentPlan?.v3Subscription?.plan?.limits;
     const isOnTopPlan = currentPlan?.v3Subscription?.plan?.code === "v3_pro_1";
+    // Same gate as the scheduled task page's purchase button (ScheduleListPresenter).
+    // Cached because this page polls. Started now and awaited at the end so it overlaps
+    // with the queries below.
+    const plansPromise = limits?.schedules?.canExceed === true ? getCachedPlans() : undefined;
 
     // Resolve rate limit configs (org override or default)
     const apiRateLimitConfig = resolveApiRateLimitConfig(organization.apiRateLimiterConfig);
@@ -255,8 +267,20 @@ export class LimitsPresenter extends BasePresenter {
     const hasStagingEnvironment = limits?.hasStagingEnvironment ?? false;
     const supportLevel = limits?.support ?? "community";
 
+    const schedulePricing = (await plansPromise)?.addOnPricing.schedules ?? null;
+    const extraSchedules = currentPlan?.v3Subscription?.addOns?.schedules?.purchased ?? 0;
+
     return {
       isOnTopPlan,
+      schedulePurchase:
+        schedulePricing && schedulesLimit !== null
+          ? {
+              schedulePricing,
+              extraSchedules,
+              maxScheduleQuota: currentPlan?.v3Subscription?.addOns?.schedules?.quota ?? 0,
+              planScheduleLimit: schedulesLimit - extraSchedules,
+            }
+          : null,
       rateLimits: {
         api: {
           name: "API rate limit",
 
@@ -25,6 +25,7 @@ import {
   TableRow,
 } from "~/components/primitives/Table";
 import { InfoIconTooltip } from "~/components/primitives/Tooltip";
+import { PurchaseSchedulesModal } from "~/components/schedules/PurchaseSchedulesModal";
 import { useAutoRevalidate } from "~/hooks/useAutoRevalidate";
 import { useEnvironment } from "~/hooks/useEnvironment";
 import { useShowSelfServe } from "~/hooks/useShowSelfServe";
@@ -39,6 +40,7 @@ import {
   type QuotaInfo,
   type RateLimitInfo,
 } from "~/presenters/v3/LimitsPresenter.server";
+import { rbac } from "~/services/rbac.server";
 import { requireUser } from "~/services/session.server";
 import { hasWebhooksAccess } from "~/v3/webhooksAccess.server";
 import { cn } from "~/utils/cn";
@@ -48,6 +50,7 @@ import {
   docsPath,
   EnvironmentParamSchema,
   organizationBillingPath,
+  v3SchedulesAddOnPath,
 } from "~/utils/pathBuilder";
 import { limitsAgentPageContext } from "~/components/dashboard-agent/suggested-prompts";
 import { WhenAgentUnavailable } from "~/components/dashboard-agent/WhenAgentUnavailable";
@@ -81,6 +84,12 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
     });
   }
 
+  const auth = await rbac.authenticateSession(request, {
+    userId,
+    organizationId: project.organizationId,
+  });
+  const canManageBilling = auth.ok && auth.ability.can("manage", { type: "billing" });
+
   const presenter = new LimitsPresenter();
   const [error, result] = await tryCatch(
     presenter.call({
@@ -103,6 +112,7 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
 
   return typedjson({
     ...result,
+    canManageBilling,
     autoReloadPollIntervalMs,
   });
 };
@@ -174,6 +184,8 @@ export default function Page() {
               quotas={data.quotas}
               isOnTopPlan={data.isOnTopPlan}
               billingPath={organizationBillingPath(organization)}
+              schedulePurchase={data.schedulePurchase}
+              canManageBilling={data.canManageBilling}
             />
 
             {/* Features Section */}
@@ -517,10 +529,14 @@ function QuotasSection({
   quotas,
   isOnTopPlan,
   billingPath,
+  schedulePurchase,
+  canManageBilling,
 }: {
   quotas: LimitsResult["quotas"];
   isOnTopPlan: boolean;
   billingPath: string;
+  schedulePurchase: LimitsResult["schedulePurchase"];
+  canManageBilling: boolean;
 }) {
   // Collect all quotas that should be shown
   const quotaRows: QuotaInfo[] = [];
@@ -584,6 +600,8 @@ function QuotasSection({
               isOnTopPlan={isOnTopPlan}
               billingPath={billingPath}
               showSelfServe={showSelfServe}
+              schedulePurchase={schedulePurchase}
+              canManageBilling={canManageBilling}
             />
           ))}
         </TableBody>
@@ -597,12 +615,18 @@ function QuotaRow({
   isOnTopPlan,
   billingPath,
   showSelfServe,
+  schedulePurchase,
+  canManageBilling,
 }: {
   quota: QuotaInfo;
   isOnTopPlan: boolean;
   billingPath: string;
   showSelfServe: boolean;
+  schedulePurchase: LimitsResult["schedulePurchase"];
+  canManageBilling: boolean;
 }) {
+  const organization = useOrganization();
+
   // For log retention and query period, we don't show current usage as it's a duration, not a count
   // For widgets per dashboard, the usage varies per dashboard so we don't show a single number
   const isDurationQuota =
@@ -675,6 +699,24 @@ function QuotaRow({
       );
     }
 
+    // Same purchase flow as the scheduled task page
+    if (quota.name === "Schedules" && schedulePurchase) {
+      return (
+        <div className="flex justify-end">
+          <PurchaseSchedulesModal
+            actionPath={v3SchedulesAddOnPath(organization)}
+            schedulePricing={schedulePurchase.schedulePricing}
+            extraSchedules={schedulePurchase.extraSchedules}
+            usedSchedules={quota.currentUsage}
+            maxQuota={schedulePurchase.maxScheduleQuota}
+            planScheduleLimit={schedulePurchase.planScheduleLimit}
+            canManageBilling={canManageBilling}
+            triggerButton={<Button variant="secondary/small">Manage</Button>}
+          />
+        </div>
+      );
+    }
+
     if (!quota.isUpgradable) {
       return null;
     }
 
@@ -208,6 +208,16 @@ function initializePlatformCache() {
       fresh: 60_000,
       stale: 120_000,
     }),
+    // Own context: getCachedPlans' loader throws on failure, and the default context would
+    // leave a failed background refresh as an unhandled rejection.
+    plans: new Namespace<PlansResult>(
+      { waitUntil: (p) => void p.catch(() => {}) },
+      {
+        stores: [memory, redisCacheStore],
+        fresh: 60_000,
+        stale: 120_000,
+      }
+    ),
   });
 
   return cache;
@@ -555,6 +565,31 @@ export async function getPlans() {
   }
 }
 
+type PlansResult = NonNullable<Awaited<ReturnType<typeof getPlans>>>;
+
+/**
+ * {@link getPlans} behind a short SWR cache, for pages that poll. The catalog is the same for
+ * every org, so it is cached under one key. The loader throws on failure because `swr` stores
+ * whatever it returns, `undefined` included, which would overwrite a good stale catalog. A
+ * failed background refresh therefore keeps the stale value; a failed cold fetch returns
+ * `undefined`.
+ */
+export async function getCachedPlans(): Promise<PlansResult | undefined> {
+  if (!client) return undefined;
+
+  try {
+    const result = await platformCache.plans.swr("all", async () => {
+      const plans = await getPlans();
+      if (!plans) throw new Error("getPlans failed");
+      return plans;
+    });
+    return result.err ? undefined : result.val;
+  } catch (_e) {
+    recordPlatformFailure("getPlans", "caught");
+    return undefined;
+  }
+}
+
 export async function activateFreePlan(
   organizationId: string,
   userId: string,