[pull] main from triggerdotdev:main

.changeset/cli-dev-without-project.md

@@ -0,0 +1,5 @@
+---
+"trigger.dev": patch
+---
+
+Running a CLI command like `dev`, `deploy`, `preview`, or `update` before initializing a project no longer crashes with a raw `Cannot find matching package.json` stack trace. The CLI now detects the missing project and points you to `npx trigger.dev@latest init` instead.

.changeset/create-session-stop-continuation.md

@@ -0,0 +1,5 @@
+---
+"@trigger.dev/sdk": patch
+---
+
+Fix two `chat.createSession()` bugs: stopping a generation no longer wedges the run (the turn loop raced a `totalUsage` promise that never settles after a stop-abort), and continuation runs now wait for the next message instead of invoking the model with an empty prompt.

.changeset/pre.json

@@ -26,16 +26,24 @@
     "backpressure-scale-up-freeze",
     "bundle-skills-single-pass",
     "cap-idempotency-key-length",
+    "chat-agent-hardening",
     "chat-agent-on-boot-hook",
     "chat-agent-tools",
     "chat-agent",
+    "chat-boot-cursor",
+    "chat-headstart-hydrate",
+    "chat-headstart-reasoning",
     "chat-history-read-primitives",
     "chat-session-attributes",
     "chat-slim-wire-merge",
     "chat-start-session-action-typed-client-data",
     "chat-transport-recreate-missing-session",
     "cli-deploy-skip-rewrite-timestamp",
+    "cli-init-ai-tooling",
     "coerce-concurrency-key-to-string",
+    "create-session-stop-continuation",
+    "dequeue-latency-histogram",
+    "duplicate-task-ids",
     "env-vars-tracing-forceflush-typecheck",
     "envvars-import-is-secret",
     "large-trigger-payload-offload",
@@ -51,13 +59,15 @@
     "mollifier-tag-cap",
     "otel-suite-0218",
     "plugin-auth-path",
+    "project-environments-endpoint",
     "resource-catalog-runtime-registration",
     "retry-middleware-errors",
     "retry-sigsegv",
     "runs-list-region-filter",
     "s2-batch-transform-linger-fix",
     "sessions-primitive",
     "trigger-client",
+    "trigger-skills-installer",
     "unflatten-attributes-conflict",
     "warm-start-external-trace-context-leak"
   ]

.github/VOUCHED.td

@@ -22,4 +22,5 @@ bharathkumar39293
 bhekanik
 jrossi
 ThullyoCunha
-ConProgramming
+ConProgramming
+saasjesus

.server-changes/locked-version-trigger-stale-replica.md

@@ -0,0 +1,6 @@
+---
+area: webapp
+type: fix
+---
+
+Fix locked-version triggers such as triggerAndWait occasionally failing with "task not found on locked version" for a task that is actually registered, by confirming against the primary database when the read replica returns no row.

apps/webapp/app/env.server.ts

@@ -768,6 +768,10 @@ const EnvironmentSchema = z
     // 2-phase batch API settings
     STREAMING_BATCH_MAX_ITEMS: z.coerce.number().int().default(1_000), // Max items in streaming batch
     STREAMING_BATCH_ITEM_MAXIMUM_SIZE: z.coerce.number().int().default(3_145_728),
+    // Number of streamed batch items ingested concurrently in Phase 2. Peak
+    // in-flight memory per request ≈ this × STREAMING_BATCH_ITEM_MAXIMUM_SIZE,
+    // so raise with care. Set to 1 for fully sequential ingestion.
+    STREAMING_BATCH_INGEST_CONCURRENCY: z.coerce.number().int().positive().default(10),
     BATCH_RATE_LIMIT_REFILL_RATE: z.coerce.number().int().default(100),
     BATCH_RATE_LIMIT_MAX: z.coerce.number().int().default(1200),
     BATCH_RATE_LIMIT_REFILL_INTERVAL: z.string().default("10s"),

apps/webapp/app/presenters/v3/ScheduleListPresenter.server.ts

@@ -2,7 +2,7 @@ import { type RuntimeEnvironmentType, type ScheduleType } from "@trigger.dev/dat
 import { type ScheduleListFilters } from "~/components/runs/v3/ScheduleFilters";
 import { displayableEnvironment } from "~/models/runtimeEnvironment.server";
 import { getTaskIdentifiers } from "~/models/task.server";
-import { getLimit } from "~/services/platform.v3.server";
+import { getCurrentPlan, getLimit, getPlans } from "~/services/platform.v3.server";
 import { findCurrentWorkerFromEnvironment } from "~/v3/models/workerDeployment.server";
 import { ServiceValidationError } from "~/v3/services/baseService.server";
 import { CheckScheduleService } from "~/v3/services/checkSchedule.server";
@@ -104,6 +104,25 @@ export class ScheduleListPresenter extends BasePresenter {
     });
 
     const limit = await getLimit(project.organizationId, "schedules", 100_000_000);
+    const [currentPlan, plans] = await Promise.all([
+      getCurrentPlan(project.organizationId),
+      getPlans(),
+    ]);
+
+    const extraSchedules = currentPlan?.v3Subscription?.addOns?.schedules?.purchased ?? 0;
+    const canPurchaseSchedules =
+      currentPlan?.v3Subscription?.plan?.limits.schedules.canExceed === true;
+    const maxScheduleQuota = currentPlan?.v3Subscription?.addOns?.schedules?.quota ?? 0;
+    const planScheduleLimit = limit - extraSchedules;
+    const schedulePricing = plans?.addOnPricing.schedules ?? null;
+
+    const purchaseInfo = {
+      canPurchaseSchedules,
+      extraSchedules,
+      maxScheduleQuota,
+      planScheduleLimit,
+      schedulePricing,
+    };
 
     //get the latest BackgroundWorker
     const latestWorker = await findCurrentWorkerFromEnvironment(environment, this._replica);
@@ -119,6 +138,7 @@ export class ScheduleListPresenter extends BasePresenter {
           used: schedulesCount,
           limit,
         },
+        ...purchaseInfo,
         filters: {
           tasks,
           search,
@@ -314,6 +334,7 @@ export class ScheduleListPresenter extends BasePresenter {
         used: schedulesCount,
         limit,
       },
+      ...purchaseInfo,
       filters: {
         tasks,
         search,