Trigger.dev – build and deploy fully‑managed AI agents and workflows
963 matches across 14 categories. Click a row to expand file-level details.
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | internal-packages/database/src/transaction.ts | 51 | export function isPrismaRaceConditionError(error: unknown): boolean { |
| LOW | internal-packages/clickhouse/src/errors.ts | 24 | export function getErrorGroupsListQueryBuilder( |
| LOW | internal-packages/clickhouse/src/errors.ts | 154 | export function getErrorHourlyOccurrences(ch: ClickhouseReader, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/errors.ts | 232 | export function getErrorAffectedVersionsQueryBuilder( |
| LOW | internal-packages/clickhouse/src/errors.ts | 265 | export function getErrorOccurrencesListQueryBuilder( |
| LOW | internal-packages/clickhouse/src/errors.ts | 298 | export function createErrorOccurrencesQueryBuilder( |
| LOW | internal-packages/clickhouse/src/errors.ts | 333 | export function createErrorOccurrencesByVersionQueryBuilder( |
| LOW | internal-packages/clickhouse/src/errors.ts | 377 | export function getActiveErrorsSinceQueryBuilder( |
| LOW | internal-packages/clickhouse/src/errors.ts | 414 | export function getOccurrenceCountsSinceQueryBuilder( |
| LOW | internal-packages/clickhouse/src/errors.ts | 447 | export function getOccurrenceCountSinceQueryBuilder( |
| LOW | internal-packages/clickhouse/src/taskRuns.ts | 200 | export function insertTaskRunsCompactArrays(ch: ClickhouseWriter, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/taskRuns.ts | 329 | export function insertRawTaskRunPayloadsCompactArrays( |
| LOW | internal-packages/clickhouse/src/taskRuns.ts | 389 | export function getPendingVersionIdsQueryBuilder( |
| LOW | internal-packages/clickhouse/src/taskRuns.ts | 401 | export function getTaskRunsCountQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/taskRuns.ts | 418 | export function getTaskRunTagsQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/taskRuns.ts | 443 | export function getTaskActivityQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/taskRuns.ts | 573 | export function getTaskUsageByOrganization(ch: ClickhouseReader, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/sessions.ts | 109 | export function insertSessionsCompactArrays(ch: ClickhouseWriter, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/sessions.ts | 156 | export function getSessionsCountQueryBuilder( |
| LOW | internal-packages/clickhouse/src/sessions.ts | 174 | export function getSessionTagsQueryBuilder( |
| LOW | internal-packages/clickhouse/src/taskEvents.ts | 55 | export function getTraceSummaryQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/taskEvents.ts | 89 | export function getTraceDetailedSummaryQueryBuilder( |
| LOW | internal-packages/clickhouse/src/taskEvents.ts | 126 | export function getSpanDetailsQueryBuilder(ch: ClickhouseReader, settings?: ClickHouseSettings) { |
| LOW | internal-packages/clickhouse/src/taskEvents.ts | 261 | export function getLogsSearchListQueryBuilder(ch: ClickhouseReader) { |
| LOW | internal-packages/clickhouse/src/client/client.ts | 914 | function convertLogLevelToClickhouseLogLevel(logLevel?: LogLevel): ClickHouseLogLevel { |
| LOW | internal-packages/rbac/src/fallback.ts | 412 | function toAuthenticatedEnvironment(env: RbacEnvironment): RbacEnvironment { |
| LOW | internal-packages/llm-model-catalog/src/sync.test.ts | 76 | async function createGeminiProWithStaleBaseModelName(prisma: PrismaClient) { |
| LOW | …es/schedule-engine/src/engine/distributedScheduling.ts | 6 | export function calculateDistributedExecutionTime( |
| LOW | …ages/schedule-engine/src/engine/scheduleCalculation.ts | 3 | export function calculateNextScheduledTimestampFromNow(schedule: string, timezone: string | null) { |
| LOW | …ages/schedule-engine/src/engine/scheduleCalculation.ts | 7 | export function calculateNextScheduledTimestamp( |
| LOW | …ages/schedule-engine/src/engine/scheduleCalculation.ts | 38 | export function previousScheduledTimestamp( |
| LOW | internal-packages/emails/src/index.tsx | 167 | function formatErrorMessageForSubject(message?: string) { |
| LOW | internal-packages/tsql/src/index.ts | 249 | export function isColumnReferencedInExpression( |
| LOW | internal-packages/tsql/src/query/schema.ts | 610 | export function getVirtualColumnExpression(col: ColumnSchema): string | undefined { |
| LOW | internal-packages/tsql/src/query/schema.ts | 745 | export function getInternalValueFromMapping( |
| LOW | internal-packages/tsql/src/query/schema.ts | 774 | export function getInternalValueFromMappingCaseInsensitive( |
| LOW | internal-packages/tsql/src/query/ast.ts | 654 | export function createSelectSetQueryFromQueries( |
| LOW | internal-packages/tsql/src/query/printer.test.ts | 909 | function createJoinTextColumnContext() { |
| LOW | internal-packages/tsql/src/query/printer.test.ts | 2004 | function createVirtualColumnContext() { |
| LOW | internal-packages/tsql/src/query/printer.test.ts | 2247 | function createCostExpressionContext() { |
| LOW | internal-packages/tsql/src/query/printer.test.ts | 2393 | function createMetadataTestContext() { |
| LOW | internal-packages/tsql/src/query/printer.test.ts | 3092 | function createFieldMappingContext(): PrinterContext { |
| LOW | internal-packages/tsql/src/query/printer.test.ts | 3222 | function createHiddenTenantContext(): PrinterContext { |
| LOW | internal-packages/tsql/src/query/printer.test.ts | 3234 | function createHiddenFilterContext(): PrinterContext { |
| LOW | internal-packages/tsql/src/query/printer.test.ts | 3407 | function createRequiredFiltersContext(): PrinterContext { |
| LOW | internal-packages/tsql/src/query/parse_string.ts | 6 | function replaceCommonEscapeCharacters(text: string): string { |
| LOW | internal-packages/tsql/src/query/database.ts | 410 | function constantTypeToSerializedFieldType( |
| LOW | internal-packages/tsql/src/query/escape.ts | 89 | export function escapeClickHouseIdentifier(identifier: string): string { |
| LOW | internal-packages/tsql/src/query/time_buckets.ts | 86 | export function calculateTimeBucketInterval( |
| LOW | internal-packages/tsql/src/query/validator.ts | 519 | function extractColumnFromExpression( |
| LOW | internal-packages/tsql/src/query/functions.ts | 625 | export function getAllExposedFunctionNames(): string[] { |
| LOW | internal-packages/testcontainers/src/utils.ts | 50 | export async function createClickHouseContainer(network: StartedNetwork) { |
| LOW | internal-packages/testcontainers/src/docker.ts | 37 | export async function getDockerNetworkAttachments(): Promise<DockerNetworkAttachment[]> { |
| LOW | internal-packages/testcontainers/src/docker.ts | 91 | export async function getDockerContainerNetworks(): Promise<DockerContainerNetwork[]> { |
| LOW | internal-packages/testcontainers/src/clickhouse.ts | 158 | async function getAllClickhouseMigrationQueries(migrationsPath: string) { |
| LOW | internal-packages/replication/src/pgoutput.ts | 536 | export function getPgoutputStartReplicationSQL( |
| LOW | …ackages/run-engine/src/batch-queue/tests/index.test.ts | 781 | function createBatchQueueWithRetry( |
| LOW | …src/run-queue/tests/fairQueueSelectionStrategy.test.ts | 710 | async function runWithQueueAgeRandomization(queueAgeRandomization: number) { |
| LOW | …src/run-queue/tests/fairQueueSelectionStrategy.test.ts | 1296 | function calculateStandardDeviation(values: number[]): number { |
| LOW | internal-packages/run-engine/src/shared/index.ts | 36 | export function attributesFromAuthenticatedEnv(env: MinimalAuthenticatedEnvironment): Attributes { |
| 524 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 148 | // ─── Arithmetic functions ───────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 169 | // ─── Mathematical functions ─────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 205 | // ─── String functions ───────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 278 | // ─── Null functions ─────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 293 | // ─── Conditional functions ──────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 306 | // ─── Comparison functions ───────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 320 | // ─── Logical functions ──────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 332 | // ─── Type conversion functions ──────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 376 | // ─── Date/time functions ────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 489 | // ─── Interval functions ─────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 505 | // ─── Array functions ────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 555 | // ─── JSON functions ─────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 578 | // ─── Tuple functions ────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 589 | // ─── Map functions ──────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 602 | // ─── Hash functions ─────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 632 | // ─── URL functions ──────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 665 | // ─── UUID functions ─────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 685 | // ─── Misc functions ─────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 713 | // ─── Aggregate functions ────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 758 | // ─── Conditional aggregate functions ────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/tsqlFunctions.test.ts | 789 | // ─── Search functions ───────────────────────────────────────────────────── |
| MEDIUM | internal-packages/clickhouse/src/sessions.ts | 135 | // ─── read path ─────────────────────────────────────────────────── |
| MEDIUM | internal-packages/tsql/src/grammar/TSQLLexer.ts | 806 | // ───── opening tag test ───── |
| MEDIUM | internal-packages/tsql/src/query/parser.ts | 228 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/tsql/src/query/parser.ts | 230 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/tsql/src/query/parser.ts | 317 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/tsql/src/query/parser.ts | 319 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/compute/src/types.ts | 3 | // ── Templates ──────────────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/compute/src/types.ts | 36 | // ── Instances ──────────────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/compute/src/types.ts | 62 | // ── Snapshots ──────────────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/compute/src/client.ts | 29 | // ── HTTP transport (shared plumbing) ───────────────────────────────────────── |
| MEDIUM | internal-packages/compute/src/client.ts | 89 | // ── Error ──────────────────────────────────────────────────────────────────── |
| MEDIUM | internal-packages/compute/src/client.ts | 102 | // ── Namespaces ─────────────────────────────────────────────────────────────── |
| MEDIUM | references/hello-world/src/trigger/prompts.ts | 6 | // ─── Prompt definitions ────────────────────────────────── |
| MEDIUM | references/hello-world/src/trigger/prompts.ts | 88 | // ─── Test task: resolve prompts locally ────────────────── |
| MEDIUM | references/hello-world/src/trigger/prompts.ts | 123 | // ─── AI SDK integration: generateText with prompt ──────── |
| MEDIUM | references/hello-world/src/trigger/prompts.ts | 152 | // ─── AI SDK integration: summarize with prompt ─────────── |
| MEDIUM | references/hello-world/src/trigger/prompts.ts | 179 | // ─── AI SDK integration: streamText with prompt ────────── |
| MEDIUM | references/hello-world/src/trigger/prompts.ts | 238 | // ─── Prompt for structured extraction ──────────────────── |
| MEDIUM | references/hello-world/src/trigger/prompts.ts | 254 | // ─── AI SDK integration: generateObject with prompt ────── |
| MEDIUM | references/hello-world/src/trigger/prompts.ts | 286 | // ─── Prompt management SDK methods ─────────────────────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 11 | // ─── Example 1: Simple multi-turn conversation ───────────────────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 41 | // ─── Example 2: Streaming chunks ─────────────────────────────────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 76 | // ─── Example 3: PR review agent (typed clientData) ───────────────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 115 | // ─── Example 4: Low-level sendRaw + ChatStream ───────────────────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 144 | // ─── Example 5: Agent-to-agent orchestration ─────────────────────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 175 | // ─── Example 6: Single-turn sub-agent tool ───────────────────────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 207 | // ─── Example 7: Multi-turn sub-agent (LLM-driven, cross-turn) ────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 337 | // ─── Example 8: chat.requestUpgrade() test ──────────────────────── |
| MEDIUM | references/ai-chat/src/trigger/chat-client-test.ts | 402 | // ─── Example 9: Quick-fire burst test ────────────────────────────── |
| MEDIUM | references/ai-chat/src/trigger/test-chat.test.ts | 11 | // ── Helpers ──────────────────────────────────────────────────────────── |
| MEDIUM | references/ai-chat/src/trigger/test-chat.test.ts | 56 | // ── Tests ────────────────────────────────────────────────────────────── |
| MEDIUM | references/ai-chat/src/components/chat.tsx | 486 | // ── Test bridge ────────────────────────────────────────────────── |
| MEDIUM | references/ai-chat/src/components/chat.tsx | 545 | // ── State ───────────────────────────────────────────────────── |
| MEDIUM | references/ai-chat/src/components/chat.tsx | 593 | // ── Actions ─────────────────────────────────────────────────── |
| MEDIUM | references/ai-chat/src/components/chat.tsx | 602 | // ── Waiters ─────────────────────────────────────────────────── |
| MEDIUM | references/ai-chat/src/components/chat.tsx | 647 | // ── Scripted helpers ───────────────────────────────────────── |
| MEDIUM | …ckages/core/src/v3/test/test-session-stream-manager.ts | 210 | // ── Test driver API (not part of SessionStreamManager interface) ────── |
| MEDIUM | …ages/core/src/v3/test/test-realtime-streams-manager.ts | 127 | // ── Test driver API (not part of RealtimeStreamsManager interface) ────── |
| MEDIUM | packages/core/src/v3/test/test-input-stream-manager.ts | 150 | // ── Test driver API (not part of InputStreamManager interface) ────────── |
| 64 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …es/llm-model-catalog/scripts/generate-model-catalog.sh | 1 | #!/usr/bin/env bash |
| LOW | internal-packages/schedule-engine/src/engine/index.ts | 201 | // Determine the lastScheduleTime to embed in the next worker job's |
| LOW | internal-packages/tsql/src/query/property_types.ts | 681 | // if (!context.team) { |
| LOW | internal-packages/zod-worker/src/index.ts | 141 | |
| LOW | internal-packages/testcontainers/src/utils.ts | 181 | |
| LOW | internal-packages/run-engine/src/run-queue/index.ts | 3021 | // |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 3101 | // Move delayUntil to a small but safe future offset. The herd's |
| LOW | …ckages/run-engine/src/engine/systems/debounceSystem.ts | 481 | const prisma = tx ?? this.$.prisma; |
| LOW | docker/docker-compose.extras.yml | 1 | # Optional services for advanced local-dev workflows. Pair with |
| LOW | docker/scripts/wait-for-it.sh | 1 | #!/bin/sh |
| LOW | .zed/tasks.json | 1 | [ |
| LOW | .zed/tasks.json | 21 | // * `always` — always hide the terminal tab, hide the pane also if it was the last tab in it |
| LOW | references/hello-world/src/trigger/batches.ts | 1 | import { batch, BatchTriggerError, logger, runs, task, tasks } from "@trigger.dev/sdk/v3"; |
| LOW | references/hello-world/src/trigger/batches.ts | 1061 | return output; |
| LOW | references/hello-world/src/trigger/init.ts | 1 | import { logger, tasks } from "@trigger.dev/sdk"; |
| LOW | references/hello-world/src/trigger/init.ts | 21 | // tasks.handleError(({ ctx, payload, error, retry, retryAt, retryDelayInMs }) => { |
| LOW | references/hello-world/src/trigger/init.ts | 41 | // }); |
| LOW | references/d3-openai-agents/requirements.txt | 1 | # This file was autogenerated by uv via the following command: |
| LOW | references/d3-openai-agents/requirements.txt | 21 | # openai |
| LOW | references/d3-openai-agents/requirements.txt | 41 | # via |
| LOW | references/d3-openai-agents/requirements.txt | 61 | distro==1.9.0 |
| LOW | references/d3-openai-agents/requirements.txt | 81 | greenlet==3.1.1 |
| LOW | references/d3-openai-agents/requirements.txt | 101 | humanize==4.12.2 |
| LOW | references/d3-openai-agents/requirements.txt | 121 | jsonschema-specifications==2024.10.1 |
| LOW | references/d3-openai-agents/requirements.txt | 141 | nltk==3.9.1 |
| LOW | references/d3-openai-agents/requirements.txt | 161 | opentelemetry-exporter-otlp-proto-http==1.31.1 |
| LOW | references/d3-openai-agents/requirements.txt | 181 | pillow==10.4.0 |
| LOW | references/d3-openai-agents/requirements.txt | 201 | pydantic==2.10.6 |
| LOW | references/d3-openai-agents/requirements.txt | 221 | python-dotenv==1.1.0 |
| LOW | references/d3-openai-agents/requirements.txt | 241 | # huggingface-hub |
| LOW | references/d3-openai-agents/requirements.txt | 261 | sse-starlette==2.2.1 |
| LOW | references/d3-openai-agents/requirements.txt | 281 | # via types-requests |
| LOW | references/d3-openai-agents/requirements.txt | 301 | # via |
| LOW | references/ai-chat/next-env.d.ts | 1 | /// <reference types="next" /> |
| LOW | references/ai-chat/src/trigger/chat.ts | 881 | // |
| LOW | references/ai-chat/src/components/chat.tsx | 481 | }, |
| LOW | references/ai-chat/src/components/chat.tsx | 501 | // `setMessages` so scripts can inject fixture state for |
| LOW | references/d3-chat/requirements.txt | 1 | # This file was autogenerated by uv via the following command: |
| LOW | references/d3-chat/requirements.txt | 21 | attrs==25.3.0 |
| LOW | references/d3-chat/requirements.txt | 61 | # via |
| LOW | references/d3-chat/requirements.txt | 81 | idna==3.10 |
| LOW | references/d3-chat/requirements.txt | 101 | lxml==5.3.1 |
| LOW | references/d3-chat/requirements.txt | 121 | packaging==24.2 |
| LOW | references/d3-chat/requirements.txt | 141 | # litellm |
| LOW | references/d3-chat/requirements.txt | 161 | referencing==0.36.2 |
| LOW | references/d3-chat/requirements.txt | 181 | # via |
| LOW | references/d3-chat/requirements.txt | 201 | # aiosqlite |
| LOW | references/d3-chat/src/trigger/chat.ts | 81 | |
| LOW | references/d3-chat/src/trigger/chat.ts | 101 | |
| LOW | scripts/batch-concurrency-cleaner.sh | 1 | #!/bin/bash |
| LOW | packages/core/test/resourceCatalog.test.ts | 1 | import { afterEach, describe, expect, it, vi } from "vitest"; |
| LOW | packages/core/src/v3/types/tasks.ts | 541 | // isCached: boolean; |
| LOW | packages/core/src/v3/auth/environment.ts | 1 | // Slim shape of an authenticated runtime environment, structural and |
| LOW | packages/core/src/v3/apiClient/runStream.ts | 221 | retryJitter?: number; |
| LOW | packages/core/src/v3/sessionStreams/manager.ts | 41 | * stream SSE. |
| LOW | packages/core/src/v3/sessionStreams/manager.ts | 61 | // SSE timestamp is <= the bound are dropped before dispatch — used by |
| LOW | packages/core/src/v3/sessionStreams/manager.ts | 121 | // Advance the committed-consume cursor to the highest seq drained |
| LOW | packages/plugins/src/rbac.ts | 141 | // Dashboard loaders/actions (session cookie): one DB query → user + pre-built ability. |
| LOW | packages/plugins/src/rbac.ts | 181 | ): Promise<SessionAuthResult>; |
| LOW | packages/trigger-sdk/test/chatHandover.test.ts | 161 | } |
| 90 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | internal-packages/tsql/src/query/schema.ts | 902 | // Step 0: Remove internal prefixes that leak implementation details |
| LOW | internal-packages/tsql/src/query/schema.ts | 905 | // Step 1: Remove tenant isolation and required filter conditions |
| LOW | internal-packages/tsql/src/query/schema.ts | 920 | // Step 2: Clean up any leftover empty WHERE conditions or double parentheses |
| LOW | internal-packages/tsql/src/query/schema.ts | 946 | // Step 3: Replace fully qualified column references first (table.column) |
| LOW | internal-packages/tsql/src/query/schema.ts | 961 | // Step 4: Replace standalone table names (after column references to avoid partial matches) |
| LOW | internal-packages/tsql/src/query/schema.ts | 970 | // Step 5: Replace standalone column names (for unqualified references) |
| LOW | internal-packages/tsql/src/query/schema.ts | 984 | // Step 6: Remove redundant column aliases like "run_id AS run_id" |
| LOW | internal-packages/tsql/src/query/schema.ts | 987 | // Step 7: Remove table aliases like "runs AS runs" |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2010 | // Step 1: Server A claims the key with claimId-A |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2023 | // Step 4: Server A attempts to register with its stale claimId-A |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2035 | // Step 5: Verify Server A's registration failed |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2038 | // Step 6: Verify Redis still contains runId-B (not overwritten by Server A) |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2112 | // Step 1: Server A claims the key with a pending claim |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2116 | // Step 2: Delete the key to simulate Server A's claim expiring |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2119 | // Step 3: Server B calls handleDebounce - since key is gone, it should atomically claim |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2129 | // Step 4: Verify result is { status: "new" } WITH a claimId |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2136 | // Step 5: Verify the key now contains Server B's pending claim |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2140 | // Step 6: Server C tries to claim the same key - should fail |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2151 | // Step 7: Server B registers its run using its claimId |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2163 | // Step 8: Verify Server B's registration succeeded |
| LOW | …-packages/run-engine/src/engine/tests/debounce.test.ts | 2166 | // Step 9: Verify Redis contains Server B's run ID |
| LOW | …n-engine/src/engine/systems/executionSnapshotSystem.ts | 274 | // Step 1: Find the createdAt of the sinceSnapshotId |
| LOW | …n-engine/src/engine/systems/executionSnapshotSystem.ts | 284 | // Step 2: Fetch snapshots WITHOUT waitpoints to avoid N×M data explosion |
| LOW | …n-engine/src/engine/systems/executionSnapshotSystem.ts | 301 | // Step 3: Get waitpoint IDs for the LATEST snapshot only (first in desc order) |
| LOW | …n-engine/src/engine/systems/executionSnapshotSystem.ts | 305 | // Step 4: Fetch waitpoints in chunks to avoid NAPI string conversion limits |
| LOW | …n-engine/src/engine/systems/executionSnapshotSystem.ts | 308 | // Step 5: Build enhanced snapshots - only latest gets waitpoints, others get empty arrays |
| LOW | …/run-engine/src/engine/systems/pendingVersionSystem.ts | 74 | // Step 1: ask the injected lookup (typically ClickHouse-backed) for |
| LOW | …/run-engine/src/engine/systems/pendingVersionSystem.ts | 91 | // Step 2: fetch the actual rows from the primary by id, filtered by |
| LOW | references/hello-world/src/trigger/jsonSchemaSimple.ts | 188 | // Step 1: Validate uniqueness |
| LOW | references/hello-world/src/trigger/jsonSchemaSimple.ts | 192 | // Step 2: Create user account |
| LOW | references/hello-world/src/trigger/jsonSchemaSimple.ts | 197 | // Step 3: Send welcome email |
| LOW | references/hello-world/src/trigger/jsonSchemaSimple.ts | 204 | // Step 4: Apply referral code if provided |
| LOW | packages/cli-v3/src/deploy/buildImage.ts | 250 | // Step 4: Build and push the image |
| LOW | …/webapp/app/v3/services/finalizeDeploymentV2.server.ts | 202 | // Step 1: We need to "login" to the registry |
| LOW | …/webapp/app/v3/services/finalizeDeploymentV2.server.ts | 221 | // Step 2: We need to run the depot push command |
| LOW | …tes/api.v1.runs.$runFriendlyId.session-streams.wait.ts | 98 | // Step 1: Create the waitpoint. |
| LOW | …tes/api.v1.runs.$runFriendlyId.session-streams.wait.ts | 108 | // Step 2: Register the waitpoint on the session channel so the next |
| LOW | …tes/api.v1.runs.$runFriendlyId.session-streams.wait.ts | 121 | // Step 3: Race-check. If a record landed on the channel before this |
| LOW | apps/webapp/app/routes/metrics.ts | 6 | // 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.ts | 77 | // Step 1: Create the waitpoint |
| LOW | …outes/api.v1.runs.$runFriendlyId.input-streams.wait.ts | 87 | // Step 2: Cache the mapping in Redis for fast lookup from .send() |
| LOW | …outes/api.v1.runs.$runFriendlyId.input-streams.wait.ts | 96 | // Step 3: Check if data was already sent to this input stream (race condition handling). |
| LOW | apps/webapp/test/objectStore.test.ts | 233 | // Step 1: Upload old data without protocol (using default provider) |
| LOW | apps/webapp/test/objectStore.test.ts | 252 | // Step 2: Configure new provider (S3) and set default protocol |
| LOW | apps/webapp/test/objectStore.test.ts | 259 | // Step 3: Upload new data with explicit protocol |
| LOW | apps/webapp/test/objectStore.test.ts | 273 | // Step 4: Verify both can be downloaded |
| LOW | apps/webapp/test/replay-after-crash.test.ts | 128 | // Step 1: read snapshot — returns undefined (fresh boot, no snap). |
| LOW | apps/webapp/test/replay-after-crash.test.ts | 132 | // Step 2: replay tail. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | internal-packages/emails/emails/mfa-enabled.tsx | 16 | userEmail: "user@example.com", |
| LOW | internal-packages/emails/emails/mfa-disabled.tsx | 16 | userEmail: "user@example.com", |
| LOW | references/seed/src/trigger/logSpammer.ts | 3 | const LONG_TEXT = `Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore e |
| LOW | references/seed/src/trigger/logSpammer.ts | 3 | const LONG_TEXT = `Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore e |
| LOW | references/hello-world/src/trigger/jsonSchema.ts | 402 | name: "John Doe", |
| LOW | references/hello-world/src/trigger/agentRelay.ts | 59 | return `[Completed] ${instruction} — Lorem ipsum dolor sit amet.`; |
| LOW | references/hello-world/src/trigger/agentRelay.ts | 59 | return `[Completed] ${instruction} — Lorem ipsum dolor sit amet.`; |
| LOW | references/hello-world/src/trigger/circularPayload.ts | 16 | answer: "John Doe", |
| LOW | references/hello-world/src/trigger/telemetry.ts | 1040 | email: ["user@example.com", "admin@company.org", "contact@business.net", "info@service.co.uk"], |
| LOW | references/hello-world/src/trigger/jsonSchemaApi.ts | 185 | email: "user@example.com", |
| LOW | references/hello-world/src/trigger/jsonSchemaApi.ts | 186 | name: "John Doe", |
| LOW | references/hello-world/src/trigger/jsonSchemaSimple.ts | 124 | to: "user@example.com", |
| LOW | tests/e2e/e2e.spec.ts | 11 | await page.getByLabel("Full name").type("John Doe"); |
| LOW | packages/core/test/eventFilterMatches.test.ts | 26 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 45 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 64 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 83 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 102 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 121 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 140 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 162 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 181 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 200 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 220 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 242 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 263 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 287 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 311 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 333 | street: "123 Main St", |
| LOW | packages/core/test/eventFilterMatches.test.ts | 355 | street: "123 Main St", |
| LOW | packages/core/test/flattenAttributes.test.ts | 582 | "user.details.name": "John Doe", |
| LOW | packages/core/test/flattenAttributes.test.ts | 591 | name: "John Doe", |
| LOW | apps/webapp/test/errorGroupWebhook.test.ts | 31 | name: "Acme Corp", |
| LOW | apps/webapp/test/errorGroupWebhook.test.ts | 68 | name: "Acme Corp", |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | internal-packages/tsql/src/query/printer.ts | 157 | print(node: SelectQuery | SelectSetQuery): PrintResult { |
| HIGH | references/python-catalog/src/trigger/pythonTasks.ts | 39 | print(h.handle("<p>Hello, <a href='https://www.google.com/earth/'>world</a>!")) |
| HIGH | references/python-catalog/src/trigger/pythonTasks.ts | 40 | print(f"API Key: {os.environ['OPENAI_API_KEY']}") |
| HIGH | references/python-catalog/src/trigger/pythonTasks.ts | 56 | print(h.handle("<p>Hello, <a href='https://www.google.com/earth/'>world</a>!")) |
| HIGH | references/python-catalog/src/trigger/pythonTasks.ts | 57 | print(h.handle("<p>Hello, <a href='https://www.google.com/earth/'>world</a>!")) |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | scripts/update-e2e-package.sh | 11 | # Check if package-lock.json exists in the current directory |
| LOW | packages/cli-v3/install-mcp.sh | 89 | # Check if the CLI file exists |
| LOW | packages/cli-v3/install-mcp.sh | 110 | # Check if Claude config exists, create if it doesn't |
| LOW | packages/cli-v3/install-mcp.sh | 185 | # Check if Claude Desktop config exists, create if it doesn't |
| LOW | packages/cli-v3/install-mcp.sh | 260 | # Check if Cursor config exists, create if it doesn't |
| LOW | packages/cli-v3/install-mcp.sh | 335 | # Check if VS Code config exists, create if it doesn't |
| LOW | packages/cli-v3/install-mcp.sh | 410 | # Check if Crush config exists, create if it doesn't |
| LOW | packages/cli-v3/install-mcp.sh | 489 | # Check if Windsurf config exists, create if it doesn't |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | internal-packages/testcontainers/src/index.ts | 155 | // Add more robust connection options |
| LOW | references/ai-chat/src/trigger/chat.ts | 539 | // #region run — just return streamText(), chat.agent handles everything else |
| LOW | hosting/k8s/setup-kind.sh | 19 | # If you're only supporting newer relases, you can just use `kind create cluster` here. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | apps/webapp/memory-leak-detector.js | 947 | node memory-leak-detector.js --token "your-admin-token" --api-key "your-api-key" --verbose |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | …rnal-packages/otlp-importer/scripts/generate-protos.sh | 3 | # Define the application root and directories for generated files and proto files |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | references/d3-openai-agents/src/trigger/python/agent.py | 152 | print("Error: Agent output was not valid JSON") |
| MEDIUM | references/python-catalog/src/python/html2text_url.py | 13 | print(f"Error fetching URL: {e}", file=sys.stderr) |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | hosting/k8s/helm/values.yaml | 21 | # When disabled, you can also use extraEnvVars and podAnnotations for secret injection |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | scripts/batch-concurrency-cleaner.sh | 10 | # Usage: |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | apps/webapp/app/entry.server.tsx | 47 | export default function handleRequest( |