Repository Analysis

triggerdotdev/trigger.dev

Trigger.dev – build and deploy fully‑managed AI agents and workflows

2.1 Likely human-written View on GitHub
2.1
Adjusted Score
2.1
Raw Score
100%
Time Factor
2026-05-30
Last Push
15,158
Stars
TypeScript
Language
615,540
Lines of Code
2943
Files
963
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 0HIGH 6MEDIUM 129LOW 828

Pattern Findings

963 matches across 14 categories. Click a row to expand file-level details.

Hyper-Verbose Identifiers584 hits · 595 pts
SeverityFileLineSnippet
LOWinternal-packages/database/src/transaction.ts51export function isPrismaRaceConditionError(error: unknown): boolean {
LOWinternal-packages/clickhouse/src/errors.ts24export function getErrorGroupsListQueryBuilder(
LOWinternal-packages/clickhouse/src/errors.ts154export function getErrorHourlyOccurrences(ch: ClickhouseReader, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/errors.ts232export function getErrorAffectedVersionsQueryBuilder(
LOWinternal-packages/clickhouse/src/errors.ts265export function getErrorOccurrencesListQueryBuilder(
LOWinternal-packages/clickhouse/src/errors.ts298export function createErrorOccurrencesQueryBuilder(
LOWinternal-packages/clickhouse/src/errors.ts333export function createErrorOccurrencesByVersionQueryBuilder(
LOWinternal-packages/clickhouse/src/errors.ts377export function getActiveErrorsSinceQueryBuilder(
LOWinternal-packages/clickhouse/src/errors.ts414export function getOccurrenceCountsSinceQueryBuilder(
LOWinternal-packages/clickhouse/src/errors.ts447export function getOccurrenceCountSinceQueryBuilder(
LOWinternal-packages/clickhouse/src/taskRuns.ts200export function insertTaskRunsCompactArrays(ch: ClickhouseWriter, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/taskRuns.ts329export function insertRawTaskRunPayloadsCompactArrays(
LOWinternal-packages/clickhouse/src/taskRuns.ts389export function getPendingVersionIdsQueryBuilder(
LOWinternal-packages/clickhouse/src/taskRuns.ts401export function getTaskRunsCountQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/taskRuns.ts418export function getTaskRunTagsQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/taskRuns.ts443export function getTaskActivityQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/taskRuns.ts573export function getTaskUsageByOrganization(ch: ClickhouseReader, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/sessions.ts109export function insertSessionsCompactArrays(ch: ClickhouseWriter, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/sessions.ts156export function getSessionsCountQueryBuilder(
LOWinternal-packages/clickhouse/src/sessions.ts174export function getSessionTagsQueryBuilder(
LOWinternal-packages/clickhouse/src/taskEvents.ts55export function getTraceSummaryQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/taskEvents.ts89export function getTraceDetailedSummaryQueryBuilder(
LOWinternal-packages/clickhouse/src/taskEvents.ts126export function getSpanDetailsQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) {
LOWinternal-packages/clickhouse/src/taskEvents.ts261export function getLogsSearchListQueryBuilder(ch: ClickhouseReader) {
LOWinternal-packages/clickhouse/src/client/client.ts914function convertLogLevelToClickhouseLogLevel(logLevel?: LogLevel): ClickHouseLogLevel {
LOWinternal-packages/rbac/src/fallback.ts412function toAuthenticatedEnvironment(env: RbacEnvironment): RbacEnvironment {
LOWinternal-packages/llm-model-catalog/src/sync.test.ts76async function createGeminiProWithStaleBaseModelName(prisma: PrismaClient) {
LOW…es/schedule-engine/src/engine/distributedScheduling.ts6export function calculateDistributedExecutionTime(
LOW…ages/schedule-engine/src/engine/scheduleCalculation.ts3export function calculateNextScheduledTimestampFromNow(schedule: string, timezone: string | null) {
LOW…ages/schedule-engine/src/engine/scheduleCalculation.ts7export function calculateNextScheduledTimestamp(
LOW…ages/schedule-engine/src/engine/scheduleCalculation.ts38export function previousScheduledTimestamp(
LOWinternal-packages/emails/src/index.tsx167function formatErrorMessageForSubject(message?: string) {
LOWinternal-packages/tsql/src/index.ts249export function isColumnReferencedInExpression(
LOWinternal-packages/tsql/src/query/schema.ts610export function getVirtualColumnExpression(col: ColumnSchema): string | undefined {
LOWinternal-packages/tsql/src/query/schema.ts745export function getInternalValueFromMapping(
LOWinternal-packages/tsql/src/query/schema.ts774export function getInternalValueFromMappingCaseInsensitive(
LOWinternal-packages/tsql/src/query/ast.ts654export function createSelectSetQueryFromQueries(
LOWinternal-packages/tsql/src/query/printer.test.ts909 function createJoinTextColumnContext() {
LOWinternal-packages/tsql/src/query/printer.test.ts2004 function createVirtualColumnContext() {
LOWinternal-packages/tsql/src/query/printer.test.ts2247 function createCostExpressionContext() {
LOWinternal-packages/tsql/src/query/printer.test.ts2393 function createMetadataTestContext() {
LOWinternal-packages/tsql/src/query/printer.test.ts3092 function createFieldMappingContext(): PrinterContext {
LOWinternal-packages/tsql/src/query/printer.test.ts3222 function createHiddenTenantContext(): PrinterContext {
LOWinternal-packages/tsql/src/query/printer.test.ts3234 function createHiddenFilterContext(): PrinterContext {
LOWinternal-packages/tsql/src/query/printer.test.ts3407 function createRequiredFiltersContext(): PrinterContext {
LOWinternal-packages/tsql/src/query/parse_string.ts6function replaceCommonEscapeCharacters(text: string): string {
LOWinternal-packages/tsql/src/query/database.ts410function constantTypeToSerializedFieldType(
LOWinternal-packages/tsql/src/query/escape.ts89export function escapeClickHouseIdentifier(identifier: string): string {
LOWinternal-packages/tsql/src/query/time_buckets.ts86export function calculateTimeBucketInterval(
LOWinternal-packages/tsql/src/query/validator.ts519function extractColumnFromExpression(
LOWinternal-packages/tsql/src/query/functions.ts625export function getAllExposedFunctionNames(): string[] {
LOWinternal-packages/testcontainers/src/utils.ts50export async function createClickHouseContainer(network: StartedNetwork) {
LOWinternal-packages/testcontainers/src/docker.ts37export async function getDockerNetworkAttachments(): Promise<DockerNetworkAttachment[]> {
LOWinternal-packages/testcontainers/src/docker.ts91export async function getDockerContainerNetworks(): Promise<DockerContainerNetwork[]> {
LOWinternal-packages/testcontainers/src/clickhouse.ts158async function getAllClickhouseMigrationQueries(migrationsPath: string) {
LOWinternal-packages/replication/src/pgoutput.ts536export function getPgoutputStartReplicationSQL(
LOW…ackages/run-engine/src/batch-queue/tests/index.test.ts781 function createBatchQueueWithRetry(
LOW…src/run-queue/tests/fairQueueSelectionStrategy.test.ts710 async function runWithQueueAgeRandomization(queueAgeRandomization: number) {
LOW…src/run-queue/tests/fairQueueSelectionStrategy.test.ts1296function calculateStandardDeviation(values: number[]): number {
LOWinternal-packages/run-engine/src/shared/index.ts36export function attributesFromAuthenticatedEnv(env: MinimalAuthenticatedEnvironment): Attributes {
524 more matches not shown…
Decorative Section Separators124 hits · 370 pts
SeverityFileLineSnippet
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts148 // ─── Arithmetic functions ─────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts169 // ─── Mathematical functions ───────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts205 // ─── String functions ─────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts278 // ─── Null functions ───────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts293 // ─── Conditional functions ────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts306 // ─── Comparison functions ─────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts320 // ─── Logical functions ────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts332 // ─── Type conversion functions ────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts376 // ─── Date/time functions ──────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts489 // ─── Interval functions ───────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts505 // ─── Array functions ──────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts555 // ─── JSON functions ───────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts578 // ─── Tuple functions ──────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts589 // ─── Map functions ────────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts602 // ─── Hash functions ───────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts632 // ─── URL functions ────────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts665 // ─── UUID functions ───────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts685 // ─── Misc functions ───────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts713 // ─── Aggregate functions ──────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts758 // ─── Conditional aggregate functions ──────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/tsqlFunctions.test.ts789 // ─── Search functions ─────────────────────────────────────────────────────
MEDIUMinternal-packages/clickhouse/src/sessions.ts135// ─── read path ───────────────────────────────────────────────────
MEDIUMinternal-packages/tsql/src/grammar/TSQLLexer.ts806 // ───── opening tag test ─────
MEDIUMinternal-packages/tsql/src/query/parser.ts228 // ─────────────────────────────────────────────────────────────────────────────
MEDIUMinternal-packages/tsql/src/query/parser.ts230 // ─────────────────────────────────────────────────────────────────────────────
MEDIUMinternal-packages/tsql/src/query/parser.ts317 // ─────────────────────────────────────────────────────────────────────────────
MEDIUMinternal-packages/tsql/src/query/parser.ts319 // ─────────────────────────────────────────────────────────────────────────────
MEDIUMinternal-packages/compute/src/types.ts3// ── Templates ────────────────────────────────────────────────────────────────
MEDIUMinternal-packages/compute/src/types.ts36// ── Instances ────────────────────────────────────────────────────────────────
MEDIUMinternal-packages/compute/src/types.ts62// ── Snapshots ────────────────────────────────────────────────────────────────
MEDIUMinternal-packages/compute/src/client.ts29// ── HTTP transport (shared plumbing) ─────────────────────────────────────────
MEDIUMinternal-packages/compute/src/client.ts89// ── Error ────────────────────────────────────────────────────────────────────
MEDIUMinternal-packages/compute/src/client.ts102// ── Namespaces ───────────────────────────────────────────────────────────────
MEDIUMreferences/hello-world/src/trigger/prompts.ts6// ─── Prompt definitions ──────────────────────────────────
MEDIUMreferences/hello-world/src/trigger/prompts.ts88// ─── Test task: resolve prompts locally ──────────────────
MEDIUMreferences/hello-world/src/trigger/prompts.ts123// ─── AI SDK integration: generateText with prompt ────────
MEDIUMreferences/hello-world/src/trigger/prompts.ts152// ─── AI SDK integration: summarize with prompt ───────────
MEDIUMreferences/hello-world/src/trigger/prompts.ts179// ─── AI SDK integration: streamText with prompt ──────────
MEDIUMreferences/hello-world/src/trigger/prompts.ts238// ─── Prompt for structured extraction ────────────────────
MEDIUMreferences/hello-world/src/trigger/prompts.ts254// ─── AI SDK integration: generateObject with prompt ──────
MEDIUMreferences/hello-world/src/trigger/prompts.ts286// ─── Prompt management SDK methods ───────────────────────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts11// ─── Example 1: Simple multi-turn conversation ─────────────────────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts41// ─── Example 2: Streaming chunks ───────────────────────────────────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts76// ─── Example 3: PR review agent (typed clientData) ─────────────────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts115// ─── Example 4: Low-level sendRaw + ChatStream ─────────────────────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts144// ─── Example 5: Agent-to-agent orchestration ───────────────────────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts175// ─── Example 6: Single-turn sub-agent tool ─────────────────────────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts207// ─── Example 7: Multi-turn sub-agent (LLM-driven, cross-turn) ──────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts337// ─── Example 8: chat.requestUpgrade() test ────────────────────────
MEDIUMreferences/ai-chat/src/trigger/chat-client-test.ts402// ─── Example 9: Quick-fire burst test ──────────────────────────────
MEDIUMreferences/ai-chat/src/trigger/test-chat.test.ts11// ── Helpers ────────────────────────────────────────────────────────────
MEDIUMreferences/ai-chat/src/trigger/test-chat.test.ts56// ── Tests ──────────────────────────────────────────────────────────────
MEDIUMreferences/ai-chat/src/components/chat.tsx486 // ── Test bridge ──────────────────────────────────────────────────
MEDIUMreferences/ai-chat/src/components/chat.tsx545 // ── State ─────────────────────────────────────────────────────
MEDIUMreferences/ai-chat/src/components/chat.tsx593 // ── Actions ───────────────────────────────────────────────────
MEDIUMreferences/ai-chat/src/components/chat.tsx602 // ── Waiters ───────────────────────────────────────────────────
MEDIUMreferences/ai-chat/src/components/chat.tsx647 // ── Scripted helpers ─────────────────────────────────────────
MEDIUM…ckages/core/src/v3/test/test-session-stream-manager.ts210 // ── Test driver API (not part of SessionStreamManager interface) ──────
MEDIUM…ages/core/src/v3/test/test-realtime-streams-manager.ts127 // ── Test driver API (not part of RealtimeStreamsManager interface) ──────
MEDIUMpackages/core/src/v3/test/test-input-stream-manager.ts150 // ── Test driver API (not part of InputStreamManager interface) ──────────
64 more matches not shown…
Over-Commented Block150 hits · 144 pts
SeverityFileLineSnippet
LOW…es/llm-model-catalog/scripts/generate-model-catalog.sh1#!/usr/bin/env bash
LOWinternal-packages/schedule-engine/src/engine/index.ts201 // Determine the lastScheduleTime to embed in the next worker job's
LOWinternal-packages/tsql/src/query/property_types.ts681 // if (!context.team) {
LOWinternal-packages/zod-worker/src/index.ts141
LOWinternal-packages/testcontainers/src/utils.ts181
LOWinternal-packages/run-engine/src/run-queue/index.ts3021 //
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts3101 // Move delayUntil to a small but safe future offset. The herd's
LOW…ckages/run-engine/src/engine/systems/debounceSystem.ts481 const prisma = tx ?? this.$.prisma;
LOWdocker/docker-compose.extras.yml1# Optional services for advanced local-dev workflows. Pair with
LOWdocker/scripts/wait-for-it.sh1#!/bin/sh
LOW.zed/tasks.json1[
LOW.zed/tasks.json21 // * `always` — always hide the terminal tab, hide the pane also if it was the last tab in it
LOWreferences/hello-world/src/trigger/batches.ts1import { batch, BatchTriggerError, logger, runs, task, tasks } from "@trigger.dev/sdk/v3";
LOWreferences/hello-world/src/trigger/batches.ts1061 return output;
LOWreferences/hello-world/src/trigger/init.ts1import { logger, tasks } from "@trigger.dev/sdk";
LOWreferences/hello-world/src/trigger/init.ts21// tasks.handleError(({ ctx, payload, error, retry, retryAt, retryDelayInMs }) => {
LOWreferences/hello-world/src/trigger/init.ts41// });
LOWreferences/d3-openai-agents/requirements.txt1# This file was autogenerated by uv via the following command:
LOWreferences/d3-openai-agents/requirements.txt21 # openai
LOWreferences/d3-openai-agents/requirements.txt41 # via
LOWreferences/d3-openai-agents/requirements.txt61distro==1.9.0
LOWreferences/d3-openai-agents/requirements.txt81greenlet==3.1.1
LOWreferences/d3-openai-agents/requirements.txt101humanize==4.12.2
LOWreferences/d3-openai-agents/requirements.txt121jsonschema-specifications==2024.10.1
LOWreferences/d3-openai-agents/requirements.txt141nltk==3.9.1
LOWreferences/d3-openai-agents/requirements.txt161opentelemetry-exporter-otlp-proto-http==1.31.1
LOWreferences/d3-openai-agents/requirements.txt181pillow==10.4.0
LOWreferences/d3-openai-agents/requirements.txt201pydantic==2.10.6
LOWreferences/d3-openai-agents/requirements.txt221python-dotenv==1.1.0
LOWreferences/d3-openai-agents/requirements.txt241 # huggingface-hub
LOWreferences/d3-openai-agents/requirements.txt261sse-starlette==2.2.1
LOWreferences/d3-openai-agents/requirements.txt281 # via types-requests
LOWreferences/d3-openai-agents/requirements.txt301 # via
LOWreferences/ai-chat/next-env.d.ts1/// <reference types="next" />
LOWreferences/ai-chat/src/trigger/chat.ts881//
LOWreferences/ai-chat/src/components/chat.tsx481 },
LOWreferences/ai-chat/src/components/chat.tsx501 // `setMessages` so scripts can inject fixture state for
LOWreferences/d3-chat/requirements.txt1# This file was autogenerated by uv via the following command:
LOWreferences/d3-chat/requirements.txt21attrs==25.3.0
LOWreferences/d3-chat/requirements.txt61 # via
LOWreferences/d3-chat/requirements.txt81idna==3.10
LOWreferences/d3-chat/requirements.txt101lxml==5.3.1
LOWreferences/d3-chat/requirements.txt121packaging==24.2
LOWreferences/d3-chat/requirements.txt141 # litellm
LOWreferences/d3-chat/requirements.txt161referencing==0.36.2
LOWreferences/d3-chat/requirements.txt181 # via
LOWreferences/d3-chat/requirements.txt201 # aiosqlite
LOWreferences/d3-chat/src/trigger/chat.ts81
LOWreferences/d3-chat/src/trigger/chat.ts101
LOWscripts/batch-concurrency-cleaner.sh1#!/bin/bash
LOWpackages/core/test/resourceCatalog.test.ts1import { afterEach, describe, expect, it, vi } from "vitest";
LOWpackages/core/src/v3/types/tasks.ts541// isCached: boolean;
LOWpackages/core/src/v3/auth/environment.ts1// Slim shape of an authenticated runtime environment, structural and
LOWpackages/core/src/v3/apiClient/runStream.ts221 retryJitter?: number;
LOWpackages/core/src/v3/sessionStreams/manager.ts41 * stream SSE.
LOWpackages/core/src/v3/sessionStreams/manager.ts61 // SSE timestamp is <= the bound are dropped before dispatch — used by
LOWpackages/core/src/v3/sessionStreams/manager.ts121 // Advance the committed-consume cursor to the highest seq drained
LOWpackages/plugins/src/rbac.ts141 // Dashboard loaders/actions (session cookie): one DB query → user + pre-built ability.
LOWpackages/plugins/src/rbac.ts181 ): Promise<SessionAuthResult>;
LOWpackages/trigger-sdk/test/chatHandover.test.ts161 }
90 more matches not shown…
Verbosity Indicators48 hits · 86 pts
SeverityFileLineSnippet
LOWinternal-packages/tsql/src/query/schema.ts902 // Step 0: Remove internal prefixes that leak implementation details
LOWinternal-packages/tsql/src/query/schema.ts905 // Step 1: Remove tenant isolation and required filter conditions
LOWinternal-packages/tsql/src/query/schema.ts920 // Step 2: Clean up any leftover empty WHERE conditions or double parentheses
LOWinternal-packages/tsql/src/query/schema.ts946 // Step 3: Replace fully qualified column references first (table.column)
LOWinternal-packages/tsql/src/query/schema.ts961 // Step 4: Replace standalone table names (after column references to avoid partial matches)
LOWinternal-packages/tsql/src/query/schema.ts970 // Step 5: Replace standalone column names (for unqualified references)
LOWinternal-packages/tsql/src/query/schema.ts984 // Step 6: Remove redundant column aliases like "run_id AS run_id"
LOWinternal-packages/tsql/src/query/schema.ts987 // Step 7: Remove table aliases like "runs AS runs"
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2010 // Step 1: Server A claims the key with claimId-A
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2023 // Step 4: Server A attempts to register with its stale claimId-A
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2035 // Step 5: Verify Server A's registration failed
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2038 // Step 6: Verify Redis still contains runId-B (not overwritten by Server A)
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2112 // Step 1: Server A claims the key with a pending claim
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2116 // Step 2: Delete the key to simulate Server A's claim expiring
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2119 // Step 3: Server B calls handleDebounce - since key is gone, it should atomically claim
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2129 // Step 4: Verify result is { status: "new" } WITH a claimId
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2136 // Step 5: Verify the key now contains Server B's pending claim
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2140 // Step 6: Server C tries to claim the same key - should fail
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2151 // Step 7: Server B registers its run using its claimId
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2163 // Step 8: Verify Server B's registration succeeded
LOW…-packages/run-engine/src/engine/tests/debounce.test.ts2166 // Step 9: Verify Redis contains Server B's run ID
LOW…n-engine/src/engine/systems/executionSnapshotSystem.ts274 // Step 1: Find the createdAt of the sinceSnapshotId
LOW…n-engine/src/engine/systems/executionSnapshotSystem.ts284 // Step 2: Fetch snapshots WITHOUT waitpoints to avoid N×M data explosion
LOW…n-engine/src/engine/systems/executionSnapshotSystem.ts301 // Step 3: Get waitpoint IDs for the LATEST snapshot only (first in desc order)
LOW…n-engine/src/engine/systems/executionSnapshotSystem.ts305 // Step 4: Fetch waitpoints in chunks to avoid NAPI string conversion limits
LOW…n-engine/src/engine/systems/executionSnapshotSystem.ts308 // Step 5: Build enhanced snapshots - only latest gets waitpoints, others get empty arrays
LOW…/run-engine/src/engine/systems/pendingVersionSystem.ts74 // Step 1: ask the injected lookup (typically ClickHouse-backed) for
LOW…/run-engine/src/engine/systems/pendingVersionSystem.ts91 // Step 2: fetch the actual rows from the primary by id, filtered by
LOWreferences/hello-world/src/trigger/jsonSchemaSimple.ts188 // Step 1: Validate uniqueness
LOWreferences/hello-world/src/trigger/jsonSchemaSimple.ts192 // Step 2: Create user account
LOWreferences/hello-world/src/trigger/jsonSchemaSimple.ts197 // Step 3: Send welcome email
LOWreferences/hello-world/src/trigger/jsonSchemaSimple.ts204 // Step 4: Apply referral code if provided
LOWpackages/cli-v3/src/deploy/buildImage.ts250 // Step 4: Build and push the image
LOW…/webapp/app/v3/services/finalizeDeploymentV2.server.ts202 // Step 1: We need to "login" to the registry
LOW…/webapp/app/v3/services/finalizeDeploymentV2.server.ts221 // Step 2: We need to run the depot push command
LOW…tes/api.v1.runs.$runFriendlyId.session-streams.wait.ts98 // Step 1: Create the waitpoint.
LOW…tes/api.v1.runs.$runFriendlyId.session-streams.wait.ts108 // Step 2: Register the waitpoint on the session channel so the next
LOW…tes/api.v1.runs.$runFriendlyId.session-streams.wait.ts121 // Step 3: Race-check. If a record landed on the channel before this
LOWapps/webapp/app/routes/metrics.ts6 // If the TRIGGER_METRICS_AUTH_PASSWORD is set, we need to check if the request has the correct password in auth heade
LOW…outes/api.v1.runs.$runFriendlyId.input-streams.wait.ts77 // Step 1: Create the waitpoint
LOW…outes/api.v1.runs.$runFriendlyId.input-streams.wait.ts87 // Step 2: Cache the mapping in Redis for fast lookup from .send()
LOW…outes/api.v1.runs.$runFriendlyId.input-streams.wait.ts96 // Step 3: Check if data was already sent to this input stream (race condition handling).
LOWapps/webapp/test/objectStore.test.ts233 // Step 1: Upload old data without protocol (using default provider)
LOWapps/webapp/test/objectStore.test.ts252 // Step 2: Configure new provider (S3) and set default protocol
LOWapps/webapp/test/objectStore.test.ts259 // Step 3: Upload new data with explicit protocol
LOWapps/webapp/test/objectStore.test.ts273 // Step 4: Verify both can be downloaded
LOWapps/webapp/test/replay-after-crash.test.ts128 // Step 1: read snapshot — returns undefined (fresh boot, no snap).
LOWapps/webapp/test/replay-after-crash.test.ts132 // Step 2: replay tail.
Fake / Example Data34 hits · 34 pts
SeverityFileLineSnippet
LOWinternal-packages/emails/emails/mfa-enabled.tsx16 userEmail: "user@example.com",
LOWinternal-packages/emails/emails/mfa-disabled.tsx16 userEmail: "user@example.com",
LOWreferences/seed/src/trigger/logSpammer.ts3const LONG_TEXT = `Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore e
LOWreferences/seed/src/trigger/logSpammer.ts3const LONG_TEXT = `Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore e
LOWreferences/hello-world/src/trigger/jsonSchema.ts402 name: "John Doe",
LOWreferences/hello-world/src/trigger/agentRelay.ts59 return `[Completed] ${instruction} — Lorem ipsum dolor sit amet.`;
LOWreferences/hello-world/src/trigger/agentRelay.ts59 return `[Completed] ${instruction} — Lorem ipsum dolor sit amet.`;
LOWreferences/hello-world/src/trigger/circularPayload.ts16 answer: "John Doe",
LOWreferences/hello-world/src/trigger/telemetry.ts1040 email: ["user@example.com", "admin@company.org", "contact@business.net", "info@service.co.uk"],
LOWreferences/hello-world/src/trigger/jsonSchemaApi.ts185 email: "user@example.com",
LOWreferences/hello-world/src/trigger/jsonSchemaApi.ts186 name: "John Doe",
LOWreferences/hello-world/src/trigger/jsonSchemaSimple.ts124 to: "user@example.com",
LOWtests/e2e/e2e.spec.ts11 await page.getByLabel("Full name").type("John Doe");
LOWpackages/core/test/eventFilterMatches.test.ts26 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts45 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts64 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts83 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts102 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts121 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts140 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts162 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts181 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts200 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts220 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts242 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts263 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts287 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts311 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts333 street: "123 Main St",
LOWpackages/core/test/eventFilterMatches.test.ts355 street: "123 Main St",
LOWpackages/core/test/flattenAttributes.test.ts582 "user.details.name": "John Doe",
LOWpackages/core/test/flattenAttributes.test.ts591 name: "John Doe",
LOWapps/webapp/test/errorGroupWebhook.test.ts31 name: "Acme Corp",
LOWapps/webapp/test/errorGroupWebhook.test.ts68 name: "Acme Corp",
Cross-Language Confusion (JS/TS)5 hits · 25 pts
SeverityFileLineSnippet
HIGHinternal-packages/tsql/src/query/printer.ts157 print(node: SelectQuery | SelectSetQuery): PrintResult {
HIGHreferences/python-catalog/src/trigger/pythonTasks.ts39print(h.handle("<p>Hello, <a href='https://www.google.com/earth/'>world</a>!"))
HIGHreferences/python-catalog/src/trigger/pythonTasks.ts40print(f"API Key: {os.environ['OPENAI_API_KEY']}")
HIGHreferences/python-catalog/src/trigger/pythonTasks.ts56print(h.handle("<p>Hello, <a href='https://www.google.com/earth/'>world</a>!"))
HIGHreferences/python-catalog/src/trigger/pythonTasks.ts57print(h.handle("<p>Hello, <a href='https://www.google.com/earth/'>world</a>!"))
Redundant / Tautological Comments8 hits · 12 pts
SeverityFileLineSnippet
LOWscripts/update-e2e-package.sh11# Check if package-lock.json exists in the current directory
LOWpackages/cli-v3/install-mcp.sh89# Check if the CLI file exists
LOWpackages/cli-v3/install-mcp.sh110 # Check if Claude config exists, create if it doesn't
LOWpackages/cli-v3/install-mcp.sh185 # Check if Claude Desktop config exists, create if it doesn't
LOWpackages/cli-v3/install-mcp.sh260 # Check if Cursor config exists, create if it doesn't
LOWpackages/cli-v3/install-mcp.sh335 # Check if VS Code config exists, create if it doesn't
LOWpackages/cli-v3/install-mcp.sh410 # Check if Crush config exists, create if it doesn't
LOWpackages/cli-v3/install-mcp.sh489 # Check if Windsurf config exists, create if it doesn't
AI Slop Vocabulary3 hits · 6 pts
SeverityFileLineSnippet
MEDIUMinternal-packages/testcontainers/src/index.ts155 // Add more robust connection options
LOWreferences/ai-chat/src/trigger/chat.ts539 // #region run — just return streamText(), chat.agent handles everything else
LOWhosting/k8s/setup-kind.sh19# If you're only supporting newer relases, you can just use `kind create cluster` here.
Magic Placeholder Names1 hit · 5 pts
SeverityFileLineSnippet
HIGHapps/webapp/memory-leak-detector.js947 node memory-leak-detector.js --token "your-admin-token" --api-key "your-api-key" --verbose
Self-Referential Comments1 hit · 3 pts
SeverityFileLineSnippet
MEDIUM…rnal-packages/otlp-importer/scripts/generate-protos.sh3# Define the application root and directories for generated files and proto files
Excessive Try-Catch Wrapping2 hits · 3 pts
SeverityFileLineSnippet
MEDIUMreferences/d3-openai-agents/src/trigger/python/agent.py152 print("Error: Agent output was not valid JSON")
MEDIUMreferences/python-catalog/src/python/html2text_url.py13 print(f"Error fetching URL: {e}", file=sys.stderr)
Slop Phrases1 hit · 3 pts
SeverityFileLineSnippet
MEDIUMhosting/k8s/helm/values.yaml21 # When disabled, you can also use extraEnvVars and podAnnotations for secret injection
Example Usage Blocks1 hit · 2 pts
SeverityFileLineSnippet
LOWscripts/batch-concurrency-cleaner.sh10# Usage:
Overly Generic Function Names1 hit · 1 pts
SeverityFileLineSnippet
LOWapps/webapp/app/entry.server.tsx47export default function handleRequest(