Realtime and task run performance improvements #2158

ericallam · 2025-06-09T16:46:40Z

This PR makes a number of performance improvements using the following changes:

Using realtime with filtering by tags is now much more performant by adding proper indexes, as well as enforcing a createdAt filter that works with Electric. Users are also now able to subscribe to tags for runs created in the last X time period. Maximum is 24 hours.
Removes projectId based indexes on the TaskRun table in favor on runtimeEnvironmentId. Removed some indexes that were redundant or completely unused to make room.
The aggregate queries on the TaskRun table in the Task table has moved from PostgreSQL (🐢) to ClickHouse (🐇)
The task usage aggregate query on the Usage page is now powered by ClickHouse

We've also prepared a "next" runs list page that uses ClickHouse, so we can test against real usage before fully switching over.

…g for self-hosters)

stuff

changeset-bot · 2025-06-09T16:46:44Z

🦋 Changeset detected

Latest commit: 39e97de

The changes in this PR will be included in the next version bump.

Not sure what this means? Click here to learn what changesets are.

Click here if you're a maintainer who wants to add another changeset to this PR

coderabbitai · 2025-06-09T16:46:49Z

Caution

Review failed

The pull request is closed.

Walkthrough

This change set implements a significant architectural refactor and feature expansion for task run querying, filtering, and real-time streaming within the application. The core changes include:

Refactoring run and task list presenters and repositories to use environment-based filtering instead of project-based, with corresponding updates to the database schema and indexes.
Introducing a new RunsRepository class for paginated, filterable querying of task runs from ClickHouse and Prisma, with comprehensive integration tests.
Adding a new NextRunListPresenter for paginated run lists, and refactoring TaskListPresenter to use a repository abstraction for metrics.
Enhancing ClickHouse integration with new query builders, typed query functions, and schema validation for task activity, running stats, durations, and usage.
Adding support for skipping columns in real-time subscriptions and streaming, with corresponding updates in API clients, React hooks, and SDKs.
Improving duration parsing utilities with more robust, order-independent parsing, and adding comprehensive unit tests.
Updating environment configuration to support ClickHouse and sharded electric origins.
Modifying real-time client logic to support multi-origin, caching, and dynamic filtering by creation time.
Removing obsolete project-based indexes and adding new environment-based indexes and GIN indexes for array fields in the database schema.
Adding and updating various migration scripts to reflect schema changes.
Making minor adjustments to component and route logic to align with new filtering and presenter interfaces.

No breaking changes to public APIs are introduced, but the filtering and querying mechanisms are now environment-centric, more modular, and extensible, with improved performance and test coverage.

📜 Recent review details

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

📥 Commits

Reviewing files that changed from the base of the PR and between 25e6267 and 39e97de.

📒 Files selected for processing (1)

.changeset/small-birds-arrive.md (1 hunks)

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

🪧 Tips

Chat

There are 3 ways to chat with CodeRabbit:

Review comments: Directly reply to a review comment made by CodeRabbit. Example:
- I pushed a fix in commit <commit_id>, please review it.
- Explain this complex logic.
- Open a follow-up GitHub issue for this discussion.
Files and specific lines of code (under the "Files changed" tab): Tag @coderabbitai in a new review comment at the desired location with your query. Examples:
- @coderabbitai explain this code block.
- @coderabbitai modularize this function.
PR comments: Tag @coderabbitai in a new PR comment to ask questions about the PR branch. For the best results, please provide a very specific query, as very limited context is provided in this mode. Examples:
- @coderabbitai gather interesting stats about this repository and render them as a table. Additionally, render a pie chart showing the language distribution in the codebase.
- @coderabbitai read src/utils.ts and explain its main purpose.
- @coderabbitai read the files in the src/scheduler package and generate a class diagram using mermaid and a README in the markdown format.
- @coderabbitai help me debug CodeRabbit configuration file.

Support

Need help? Create a ticket on our support page for assistance with any issues or questions.

Note: Be mindful of the bot's finite context window. It's strongly recommended to break down tasks such as reading entire modules into smaller chunks. For a focused discussion, use review comments to chat about specific files and their changes, instead of using the PR comments.

CodeRabbit Commands (Invoked using PR comments)

@coderabbitai pause to pause the reviews on a PR.
@coderabbitai resume to resume the paused reviews.
@coderabbitai review to trigger an incremental review. This is useful when automatic reviews are disabled for the repository.
@coderabbitai full review to do a full review from scratch and review all the files again.
@coderabbitai summary to regenerate the summary of the PR.
@coderabbitai generate docstrings to generate docstrings for this PR.
@coderabbitai generate sequence diagram to generate a sequence diagram of the changes in this PR.
@coderabbitai resolve resolve all the CodeRabbit review comments.
@coderabbitai configuration to show the current CodeRabbit configuration for the repository.
@coderabbitai help to get help.

Other keywords and placeholders

Add @coderabbitai ignore anywhere in the PR description to prevent this PR from being reviewed.
Add @coderabbitai summary to generate the high-level summary at a specific location in the PR description.
Add @coderabbitai anywhere in the PR title to generate the title automatically.

CodeRabbit Configuration File (`.coderabbit.yaml`)

You can programmatically configure CodeRabbit by adding a .coderabbit.yaml file to the root of your repository.
Please see the configuration documentation for more information.
If your editor has YAML language server enabled, you can add the path at the top of this file to enable auto-completion and validation: # yaml-language-server: $schema=https://coderabbit.ai/integrations/schema.v2.json

Documentation and Community

Visit our Documentation for detailed information on how to use CodeRabbit.
Join our Discord Community to get help, request features, and share feedback.
Follow us on X/Twitter for updates and announcements.

packages/core/src/v3/isomorphic/duration.ts

coderabbitai

Actionable comments posted: 16

🧹 Nitpick comments (16)

.claude/settings.local.json (2)

4-6: Restrict broad shell command permissions
Allowing grep:*, rg:*, and find:* without any constraints grants overly permissive shell access. Narrow the scope to only the flags and patterns you actually need, or consolidate into specific targeted entries.

9-9: Broaden web-fetch domain if needed
WebFetch(domain:clickhouse.com) may not cover subdomains (e.g. docs.clickhouse.com). If you intend to fetch from any ClickHouse endpoint, consider a wildcard like *.clickhouse.com.
internal-packages/database/prisma/migrations/20250605220110_remove_unused_completed_at_idnex/migration.sql (1)
1-1: Add IF EXISTS clause for safer migration.

Consider adding IF EXISTS to prevent potential errors if the index doesn't exist, maintaining consistency with other migrations in this PR.
-DROP INDEX CONCURRENTLY "TaskRun_completedAt_idx";
+DROP INDEX CONCURRENTLY IF EXISTS "TaskRun_completedAt_idx";
apps/webapp/app/routes/realtime.v1.runs.ts (1)

12-12: Ensure valid date format for createdAt filter.
Accepting arbitrary strings for createdAt may lead to runtime errors when parsing downstream. Consider refining the Zod schema to enforce an ISO-8601 format (e.g., z.string().datetime()) or transforming to a Date via z.coerce.date().

packages/core/src/v3/apiClient/types.ts (1)

44-45: Strengthen typing and docs for new query params.
The added createdAt?: string and skipColumns?: string[] enable filtering and bandwidth control, but consider:

Using the RealtimeRunSkipColumns union type instead of a plain string[] for skipColumns.

Adding JSDoc to clarify the expected format for createdAt (e.g., ISO-8601).
apps/webapp/app/models/task.server.ts (1)
6-6: Update the comment to reflect environment-scoped filtering.

The comment still mentions "get all task identifiers for a project" but the function now takes environmentId and filters by runtime environment.
- * @param prisma An efficient query to get all task identifiers for a project.
+ * @param prisma An efficient query to get all task identifiers for an environment.
apps/webapp/app/services/clickhouseInstance.server.ts (1)
9-13: Use consistent logging service instead of console.log.

The file uses console.log while the rest of the codebase likely uses the logger service for consistency.

Apply this diff to use consistent logging:
+ import { logger } from "~/services/logger.server";
  if (!env.CLICKHOUSE_URL) {
-   console.log("🗃️  Clickhouse service not enabled");
+   logger.info("🗃️  Clickhouse service not enabled");
    return;
  }

- console.log("🗃️  Clickhouse service enabled");
+ logger.info("🗃️  Clickhouse service enabled");
internal-packages/clickhouse/src/client/queryBuilder.ts (1)
41-46: Improve type safety for the condition parameter.

The condition parameter should have a more specific type than any to maintain type safety.
-  whereIf(condition: any, clause: string, params?: QueryParams): this {
+  whereIf(condition: unknown, clause: string, params?: QueryParams): this {
apps/webapp/app/presenters/v3/UsagePresenter.server.ts (1)
121-183: Consider extracting the common transformation logic to reduce duplication.

The transformation logic for mapping database results to TaskUsageItem objects is duplicated between the ClickHouse path (lines 139-147) and the SQL path (lines 172-180). Both apply the same transformations including adding env.CENTS_PER_RUN / 100 to the average cost.

Extract the transformation into a helper function:
+function transformTaskUsageData(item: any): TaskUsageItem {
+  return {
+    taskIdentifier: item.task_identifier || item.taskIdentifier,
+    runCount: Number(item.run_count || item.runCount),
+    averageDuration: Number(item.average_duration || item.averageDuration),
+    averageCost: Number(item.average_cost || item.averageCost) + env.CENTS_PER_RUN / 100,
+    totalDuration: Number(item.total_duration || item.totalDuration),
+    totalCost: Number(item.total_cost || item.totalCost) + Number(item.total_base_cost || item.totalBaseCost),
+  };
+}

 async function getTaskUsageByOrganization(
   organizationId: string,
   startOfMonth: Date,
   endOfMonth: Date,
   replica: PrismaClientOrTransaction
 ) {
   if (clickhouseClient) {
     const [queryError, tasks] = await clickhouseClient.taskRuns.getTaskUsageByOrganization({
       startTime: startOfMonth.getTime(),
       endTime: endOfMonth.getTime(),
       organizationId,
     });

     if (queryError) {
       throw queryError;
     }

-    return tasks
-      .map((task) => ({
-        taskIdentifier: task.task_identifier,
-        runCount: Number(task.run_count),
-        averageDuration: Number(task.average_duration),
-        averageCost: Number(task.average_cost) + env.CENTS_PER_RUN / 100,
-        totalDuration: Number(task.total_duration),
-        totalCost: Number(task.total_cost) + Number(task.total_base_cost),
-      }))
-      .sort((a, b) => b.totalCost - a.totalCost);
+    return tasks
+      .map(transformTaskUsageData)
+      .sort((a, b) => b.totalCost - a.totalCost);
   } else {
     return replica.$queryRaw<TaskUsageItem[]>`
     SELECT
       tr."taskIdentifier",
       COUNT(*) AS "runCount",
       AVG(tr."usageDurationMs") AS "averageDuration",
       SUM(tr."usageDurationMs") AS "totalDuration",
       AVG(tr."costInCents") / 100.0 AS "averageCost",
       SUM(tr."costInCents") / 100.0 AS "totalCost",
       SUM(tr."baseCostInCents") / 100.0 AS "totalBaseCost"
     FROM
         ${sqlDatabaseSchema}."TaskRun" tr
         JOIN ${sqlDatabaseSchema}."Project" pr ON pr.id = tr."projectId"
         JOIN ${sqlDatabaseSchema}."Organization" org ON org.id = pr."organizationId"
         JOIN ${sqlDatabaseSchema}."RuntimeEnvironment" env ON env."id" = tr."runtimeEnvironmentId"
     WHERE
         env.type <> 'DEVELOPMENT'
         AND tr."createdAt" > ${startOfMonth}
         AND tr."createdAt" < ${endOfMonth}
         AND org.id = ${organizationId}
     GROUP BY
         tr."taskIdentifier";
   `.then((data) => {
       return data
-        .map((item) => ({
-          taskIdentifier: item.taskIdentifier,
-          runCount: Number(item.runCount),
-          averageDuration: Number(item.averageDuration),
-          averageCost: Number(item.averageCost) + env.CENTS_PER_RUN / 100,
-          totalDuration: Number(item.totalDuration),
-          totalCost: Number(item.totalCost) + Number(item.totalBaseCost),
-        }))
+        .map(transformTaskUsageData)
         .sort((a, b) => b.totalCost - a.totalCost);
     });
   }
 }
apps/webapp/test/runsRepository.test.ts (1)

1408-1501: Add test coverage for missing scenarios.

The test suite is comprehensive but missing coverage for:

Backward pagination direction (only forward is tested)

The period filter option

Negative test cases (e.g., empty results, invalid inputs)

Would you like me to generate additional test cases to cover these scenarios? This would ensure complete coverage of the RunsRepository functionality.

apps/webapp/app/presenters/v3/RunListPresenter.server.ts (1)

42-64: Breaking change: Method signature updated to accept environmentId

The call method now requires environmentId as the first parameter. This is a significant architectural change that aligns with the shift to environment-scoped queries.

Ensure all callers of this method have been updated to pass the environmentId parameter.
apps/webapp/app/services/runsRepository.server.ts (1)
131-135: Enhance error handling with logging

The error handling could be improved by utilizing the logger provided in options.

Consider adding error logging:
const [queryError, result] = await queryBuilder.execute();

if (queryError) {
+  this.options.logger?.error("Failed to query runs from ClickHouse", { 
+    error: queryError,
+    options 
+  });
  throw queryError;
}
apps/webapp/app/presenters/v3/TaskListPresenter.server.ts (1)

34-98: Smart performance optimization with deferred loading

The method correctly implements deferred loading by returning promises without awaiting them. The comment on lines 76-77 clearly explains this design decision.

Consider documenting how consumers should handle potential errors from these deferred promises.

apps/webapp/app/services/realtimeClient.server.ts (1)

189-225: Smart createdAt filter calculation with proper boundaries

The implementation correctly:

Enforces a 7-day maximum age limit

Handles both new filters and cached filters

Provides sensible defaults

Consider extracting the magic number "24h" to a constant for maintainability.
apps/webapp/app/services/environmentMetricsRepository.server.ts (2)
67-67: Use lowercase primitive types for consistency.

TypeScript convention is to use lowercase primitive types instead of their object wrapper types.

Apply these changes throughout the file:
-        count: BigInt;
+        count: bigint;
-        duration: Number;
+        duration: number;
Also applies to: 110-110, 152-152, 274-274, 318-318

🧰 Tools

🪛 Biome (1.9.4)

[error] 67-67: Don't use 'BigInt' as a type.

Use lowercase primitives for consistency.
Safe fix: Use 'bigint' instead

(lint/complexity/noBannedTypes)

293-296: Initialize all task run statuses to prevent undefined values.

Currently only COMPLETED_SUCCESSFULLY is initialized to 0, but other statuses remain undefined. This could cause issues when accessing status counts.

Initialize all possible task run statuses:
existingTask.push({
  day: day.toISOString(),
-  ["COMPLETED_SUCCESSFULLY"]: 0,
+  PENDING: 0,
+  WAITING_FOR_DEPLOY: 0,
+  WAITING_TO_RESUME: 0,
+  QUEUED: 0,
+  EXECUTING: 0,
+  COMPLETED_SUCCESSFULLY: 0,
+  COMPLETED_WITH_ERRORS: 0,
+  SYSTEM_FAILURE: 0,
+  CRASHED: 0,
+  INTERRUPTED: 0,
+  CANCELED: 0,
+  EXPIRED: 0,
} as { day: string } & Record<TaskRunStatus, number>);

📜 Review details

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

📥 Commits

Reviewing files that changed from the base of the PR and between e617c14 and d4c6d06.

⛔ Files ignored due to path filters (4)

internal-packages/clickhouse/src/__snapshots__/taskRuns.test.ts.snap is excluded by !**/*.snap
references/d3-chat/src/components/chat-container.tsx is excluded by !references/**
references/d3-chat/src/trigger/chat.ts is excluded by !references/**
references/hello-world/src/trigger/realtime.ts is excluded by !references/**

📒 Files selected for processing (56)

.claude/settings.local.json (1 hunks)
apps/webapp/app/components/runs/v3/TaskRunsTable.tsx (1 hunks)
apps/webapp/app/env.server.ts (2 hunks)
apps/webapp/app/models/runtimeEnvironment.server.ts (1 hunks)
apps/webapp/app/models/task.server.ts (2 hunks)
apps/webapp/app/presenters/v3/ApiRunListPresenter.server.ts (4 hunks)
apps/webapp/app/presenters/v3/NextRunListPresenter.server.ts (1 hunks)
apps/webapp/app/presenters/v3/RunListPresenter.server.ts (9 hunks)
apps/webapp/app/presenters/v3/TaskListPresenter.server.ts (2 hunks)
apps/webapp/app/presenters/v3/UsagePresenter.server.ts (2 hunks)
apps/webapp/app/presenters/v3/ViewSchedulePresenter.server.ts (3 hunks)
apps/webapp/app/presenters/v3/WaitpointPresenter.server.ts (1 hunks)
apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam._index/route.tsx (2 hunks)
apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.next.runs._index/route.tsx (2 hunks)
apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.runs._index/route.tsx (1 hunks)
apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.schedules.$scheduleParam/route.tsx (3 hunks)
apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.waitpoints.tokens.$waitpointParam/route.tsx (0 hunks)
apps/webapp/app/routes/api.v1.schedules.$scheduleId.activate.ts (1 hunks)
apps/webapp/app/routes/api.v1.schedules.$scheduleId.deactivate.ts (1 hunks)
apps/webapp/app/routes/api.v1.schedules.$scheduleId.ts (1 hunks)
apps/webapp/app/routes/realtime.v1.runs.ts (1 hunks)
apps/webapp/app/services/clickhouseInstance.server.ts (1 hunks)
apps/webapp/app/services/environmentMetricsRepository.server.ts (1 hunks)
apps/webapp/app/services/realtimeClient.server.ts (10 hunks)
apps/webapp/app/services/realtimeClientGlobal.server.ts (1 hunks)
apps/webapp/app/services/runsRepository.server.ts (1 hunks)
apps/webapp/test/runsRepository.test.ts (1 hunks)
apps/webapp/test/utils/replicationUtils.ts (1 hunks)
internal-packages/clickhouse/src/client/client.ts (4 hunks)
internal-packages/clickhouse/src/client/noop.ts (1 hunks)
internal-packages/clickhouse/src/client/queryBuilder.ts (1 hunks)
internal-packages/clickhouse/src/client/types.ts (3 hunks)
internal-packages/clickhouse/src/index.ts (2 hunks)
internal-packages/clickhouse/src/taskRuns.test.ts (2 hunks)
internal-packages/clickhouse/src/taskRuns.ts (2 hunks)
internal-packages/database/prisma/migrations/20250605220110_remove_unused_completed_at_idnex/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250605220552_remove_unused_schedule_instance_id_index/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250606131749_remove_task_run_project_id_index/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250606132144_remove_task_run_project_id_task_identifier_index/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250606132316_remove_task_run_project_id_status_index/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250606132630_remove_task_run_project_id_task_identifier_status_index/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250606132928_remove_project_id_created_at_task_identifier_index/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250606133133_remove_task_run_project_id_id_desc_index/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250609163214_add_task_run_environment_created_at_id_index/migration.sql (1 hunks)
internal-packages/database/prisma/migrations/20250609164201_add_task_run_run_tags_gin_index/migration.sql (1 hunks)
internal-packages/database/prisma/schema.prisma (1 hunks)
packages/core/src/v3/apiClient/index.ts (5 hunks)
packages/core/src/v3/apiClient/runStream.ts (3 hunks)
packages/core/src/v3/apiClient/stream.ts (1 hunks)
packages/core/src/v3/apiClient/types.ts (1 hunks)
packages/core/src/v3/isomorphic/duration.ts (1 hunks)
packages/core/src/v3/schemas/api.ts (1 hunks)
packages/core/test/duration.test.ts (1 hunks)
packages/react-hooks/src/hooks/useRealtime.ts (12 hunks)
packages/react-hooks/src/hooks/useTaskTrigger.ts (2 hunks)
packages/trigger-sdk/src/v3/runs.ts (4 hunks)

💤 Files with no reviewable changes (1)

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.waitpoints.tokens.$waitpointParam/route.tsx

🧰 Additional context used

🧬 Code Graph Analysis (14)

packages/react-hooks/src/hooks/useTaskTrigger.ts (1)

packages/core/src/v3/apiClient/runStream.ts (1)

RealtimeRunSkipColumns (58-77)

internal-packages/clickhouse/src/client/noop.ts (2)

internal-packages/clickhouse/src/client/types.ts (3)

ClickhouseReader (20-75)

ClickhouseWriter (85-94)

ClickhouseQueryBuilderFunction (16-18)

internal-packages/clickhouse/src/client/queryBuilder.ts (1)

ClickhouseQueryBuilder (7-93)

internal-packages/clickhouse/src/client/client.ts (2)

internal-packages/clickhouse/src/client/types.ts (1)

ClickhouseQueryBuilderFunction (16-18)

internal-packages/clickhouse/src/client/queryBuilder.ts (1)

ClickhouseQueryBuilder (7-93)

internal-packages/clickhouse/src/index.ts (1)

internal-packages/clickhouse/src/taskRuns.ts (5)

getTaskRunsQueryBuilder (97-104)

getTaskActivityQueryBuilder (120-147)

getCurrentRunningStats (162-186)

getAverageDurations (200-222)

getTaskUsageByOrganization (240-268)

internal-packages/clickhouse/src/taskRuns.test.ts (3)

internal-packages/testcontainers/src/index.ts (1)

clickhouseTest (219-223)

internal-packages/clickhouse/src/client/client.ts (2)

insert (231-310)

queryBuilder (218-229)

internal-packages/clickhouse/src/taskRuns.ts (2)

insertTaskRuns (51-65)

getTaskRunsQueryBuilder (97-104)

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam._index/route.tsx (2)

apps/webapp/app/presenters/v3/TaskListPresenter.server.ts (1)

taskListPresenter (100-100)

apps/webapp/app/v3/marqs/sharedQueueConsumer.server.ts (1)

environment (2169-2192)

apps/webapp/app/services/realtimeClientGlobal.server.ts (2)

apps/webapp/app/env.server.ts (1)

env (762-762)

apps/webapp/app/services/realtimeClient.server.ts (1)

RealtimeClient (69-526)

internal-packages/clickhouse/src/client/types.ts (1)

internal-packages/clickhouse/src/client/queryBuilder.ts (1)

ClickhouseQueryBuilder (7-93)

apps/webapp/test/runsRepository.test.ts (3)

internal-packages/testcontainers/src/index.ts (2)

containerTest (233-241)

postgresContainer (78-89)

apps/webapp/test/utils/replicationUtils.ts (1)

setupClickhouseReplication (7-54)

apps/webapp/app/services/runsRepository.server.ts (1)

RunsRepository (40-226)

apps/webapp/app/presenters/v3/UsagePresenter.server.ts (3)

internal-packages/clickhouse/src/taskRuns.ts (1)

getTaskUsageByOrganization (240-268)

apps/webapp/app/services/clickhouseInstance.server.ts (1)

clickhouseClient (5-5)

apps/webapp/app/db.server.ts (1)

sqlDatabaseSchema (252-252)

packages/core/test/duration.test.ts (1)

packages/core/src/v3/isomorphic/duration.ts (5)

parseNaturalLanguageDuration (1-63)

safeParseNaturalLanguageDuration (65-71)

parseNaturalLanguageDurationAgo (75-137)

safeParseNaturalLanguageDurationAgo (139-145)

stringifyDuration (147-167)

apps/webapp/app/presenters/v3/TaskListPresenter.server.ts (4)

apps/webapp/app/services/environmentMetricsRepository.server.ts (6)

DailyTaskActivity (7-7)

EnvironmentMetricsRepository (11-29)

CurrentRunningStats (8-8)

AverageDurations (9-9)

ClickHouseEnvironmentMetricsRepository (176-268)

PostgrestEnvironmentMetricsRepository (38-170)

apps/webapp/app/v3/models/workerDeployment.server.ts (1)

findCurrentWorkerFromEnvironment (197-223)

apps/webapp/app/services/clickhouseInstance.server.ts (1)

clickhouseClient (5-5)

apps/webapp/app/db.server.ts (1)

$replica (102-105)

packages/react-hooks/src/hooks/useRealtime.ts (3)

packages/core/src/v3/apiClient/runStream.ts (2)

RealtimeRunSkipColumns (58-77)

RealtimeRun (55-55)

packages/core/src/v3/apiClient/index.ts (3)

RealtimeRunSkipColumns (92-92)

ApiClient (138-1058)

RealtimeRun (126-126)

packages/core/src/v3/types/tasks.ts (2)

AnyTask (628-628)

InferRunTypes (904-914)

internal-packages/clickhouse/src/taskRuns.ts (1)

internal-packages/clickhouse/src/client/types.ts (1)

ClickhouseReader (20-75)

🪛 Biome (1.9.4)

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

[error] 166-166: Change to an optional chain.

Unsafe fix: Change to an optional chain.

(lint/complexity/useOptionalChain)

apps/webapp/app/services/environmentMetricsRepository.server.ts

[error] 67-67: Don't use 'BigInt' as a type.

Use lowercase primitives for consistency.
Safe fix: Use 'bigint' instead