revert(webapp): drop buffered scan from bulk-action service

The bulk-action confirmation count is sourced from ClickHouse, so PG
rows not yet replicated to ClickHouse are silently excluded from both
the count and the processing pass. Phase 4's first-batch mollifier-
buffer scan broke that symmetry — buffered runs were processed without
being counted, so a customer confirming "Replay ~0 runs" could see N
buffered runs replayed without seeing them anywhere in the UI.

Restore the eventually-consistent contract: bulk actions only target
runs visible to ClickHouse. Buffered runs are picked up by subsequent
bulk actions once they drain into PG → ClickHouse, mirroring how
PG-not-yet-CH runs already work today.

Removes `bulkActionBuffer.server.ts` (helper) and its container-backed
test. Will reimplement once the buffered-runs UX (global status
indicator) gives the customer a way to see and confirm against the
buffered set.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: d-cs

.server-changes/mollifier-bulk-action-drop-buffered-scan.md

@@ -0,0 +1,6 @@
+---
+area: webapp
+type: improvement
+---
+
+Drop the first-batch mollifier-buffer scan from `BulkActionV2`. The action's confirmation count comes from ClickHouse (eventually consistent for PG-but-not-yet-replicated runs) and never included buffered runs, so processing buffered entries created a safety gap: a customer confirming "Replay ~0 runs" could see N buffered runs replayed they didn't know about. Bulk actions are now uniformly bound by what ClickHouse can see; buffered runs are picked up by subsequent bulk actions once they drain into PG → ClickHouse — matching the existing eventually-consistent contract for PG-not-yet-CH runs. Removes `bulkActionBuffer.server.ts` and its container-backed tests; the buffered-runs UX will be reimplemented when the global status indicator lands.

apps/webapp/app/v3/mollifier/bulkActionBuffer.server.ts

@@ -20,10 +20,6 @@ import { logger } from "@trigger.dev/sdk";
 import { CancelTaskRunService } from "../cancelTaskRun.server";
 import { tryCatch } from "@trigger.dev/core";
 import { ReplayTaskRunService } from "../replayTaskRun.server";
-import {
-  processBufferedCancelBulkAction,
-  processBufferedReplayBulkAction,
-} from "~/v3/mollifier/bulkActionBuffer.server";
 import { timeFilters } from "~/components/runs/v3/SharedFilters";
 import parseDuration from "parse-duration";
 import { v3BulkActionPath } from "~/utils/pathBuilder";
@@ -177,45 +173,6 @@ export class BulkActionService extends BaseService {
     // Slice because we fetch an extra for the cursor
     const runIdsToProcess = runIds.slice(0, env.BULK_ACTION_BATCH_SIZE);
 
-    // First-batch only: also process runs that are currently sitting in
-    // the mollifier buffer. They aren't in ClickHouse (no OTEL events
-    // yet) so the listRunIds query never returned them. Gated on the
-    // cursor being null so worker retries don't reprocess the same set.
-    const isFirstBatch = !group.cursor;
-    if (isFirstBatch && group.environmentId) {
-      const bufferedFilters = {
-        tasks: filters.tasks,
-        tags: filters.tags,
-        statuses: filters.statuses,
-        period: filters.period,
-        from: filters.from,
-        to: filters.to,
-        isTest: filters.isTest,
-        runId: filters.runId,
-      };
-      const bufferedCtx = {
-        envId: group.environmentId,
-        organizationId: group.project.organizationId,
-        filters: bufferedFilters,
-      };
-      if (group.type === BulkActionType.CANCEL) {
-        const r = await processBufferedCancelBulkAction({
-          ...bufferedCtx,
-          cancelReason: `Bulk action ${group.friendlyId} cancelled run`,
-        });
-        successCount += r.successCount;
-        failureCount += r.failureCount;
-      } else if (group.type === BulkActionType.REPLAY) {
-        const r = await processBufferedReplayBulkAction({
-          ...bufferedCtx,
-          bulkActionId,
-          prismaClient: this._prisma,
-        });
-        successCount += r.successCount;
-        failureCount += r.failureCount;
-      }
-    }
-
     switch (group.type) {
       case BulkActionType.CANCEL: {
         const cancelService = new CancelTaskRunService(this._prisma);