Skip to content

Commit 09e6512

Browse files
cardernecarderne
committed
format
1 parent 27d34b7 commit 09e6512

381 files changed

Lines changed: 3066 additions & 2541 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎apps/coordinator/src/index.ts‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,13 @@
11
import { createServer } from "node:http";
22
import { Server } from "socket.io";
3-
import type {
4-
WaitReason} from "@trigger.dev/core/v3";
3+
import type { WaitReason } from "@trigger.dev/core/v3";
54
import {
65
CoordinatorToPlatformMessages,
76
CoordinatorToProdWorkerMessages,
87
omit,
98
PlatformToCoordinatorMessages,
109
ProdWorkerSocketData,
11-
ProdWorkerToCoordinatorMessages
10+
ProdWorkerToCoordinatorMessages,
1211
} from "@trigger.dev/core/v3";
1312
import { ZodNamespace } from "@trigger.dev/core/v3/zodNamespace";
1413
import { ZodSocketConnection } from "@trigger.dev/core/v3/zodSocket";

‎apps/docker-provider/src/index.ts‎

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,13 @@
1-
import type { PostStartCauses,PreStopCauses } from "@trigger.dev/core/v3";
1+
import type { PostStartCauses, PreStopCauses } from "@trigger.dev/core/v3";
22
import type {
3-
TaskOperations,
4-
TaskOperationsCreateOptions,
5-
TaskOperationsIndexOptions,
6-
TaskOperationsRestoreOptions} from "@trigger.dev/core/v3/apps";
7-
import {
8-
ProviderShell,
9-
SimpleLogger,
10-
isExecaChildProcess,
3+
TaskOperations,
4+
TaskOperationsCreateOptions,
5+
TaskOperationsIndexOptions,
6+
TaskOperationsRestoreOptions,
117
} from "@trigger.dev/core/v3/apps";
8+
import { ProviderShell, SimpleLogger, isExecaChildProcess } from "@trigger.dev/core/v3/apps";
129
import { testDockerCheckpoint } from "@trigger.dev/core/v3/serverOnly";
13-
import { $,type ExecaChildProcess,execa } from "execa";
10+
import { $, type ExecaChildProcess, execa } from "execa";
1411
import { setTimeout } from "node:timers/promises";
1512

1613
const MACHINE_NAME = process.env.MACHINE_NAME || "local";

‎apps/kubernetes-provider/src/index.ts‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,11 +10,9 @@ import type {
1010
TaskOperationsCreateOptions,
1111
TaskOperationsIndexOptions,
1212
TaskOperationsPrePullDeploymentOptions,
13-
TaskOperationsRestoreOptions} from "@trigger.dev/core/v3/apps";
14-
import {
15-
ProviderShell,
16-
SimpleLogger
13+
TaskOperationsRestoreOptions,
1714
} from "@trigger.dev/core/v3/apps";
15+
import { ProviderShell, SimpleLogger } from "@trigger.dev/core/v3/apps";
1816
import { PodCleaner } from "./podCleaner";
1917
import { TaskMonitor } from "./taskMonitor";
2018
import { UptimeHeartbeat } from "./uptimeHeartbeat";

‎apps/kubernetes-provider/src/taskMonitor.ts‎

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,10 @@
11
import * as k8s from "@kubernetes/client-node";
2-
import { TaskRunErrorCodes,type Prettify,type TaskRunInternalError } from "@trigger.dev/core/v3";
3-
import { EXIT_CODE_ALREADY_HANDLED,EXIT_CODE_CHILD_NONZERO,SimpleLogger } from "@trigger.dev/core/v3/apps";
2+
import { TaskRunErrorCodes, type Prettify, type TaskRunInternalError } from "@trigger.dev/core/v3";
3+
import {
4+
EXIT_CODE_ALREADY_HANDLED,
5+
EXIT_CODE_CHILD_NONZERO,
6+
SimpleLogger,
7+
} from "@trigger.dev/core/v3/apps";
48
import PQueue from "p-queue";
59
import { setTimeout } from "timers/promises";
610

‎apps/supervisor/src/clients/kubernetes.ts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import * as k8s from "@kubernetes/client-node";
2-
import type { Informer,KubernetesObject,ListPromise } from "@kubernetes/client-node";
2+
import type { Informer, KubernetesObject, ListPromise } from "@kubernetes/client-node";
33
import { assertExhaustive } from "@trigger.dev/core/utils";
44
import { SimpleStructuredLogger } from "@trigger.dev/core/v3/utils/structuredLogger";
55
import * as https from "node:https";

‎apps/supervisor/src/services/failedPodHandler.ts‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
import type { Informer,V1Pod } from "@kubernetes/client-node";
2-
import { LogLevel,SimpleStructuredLogger } from "@trigger.dev/core/v3/utils/structuredLogger";
3-
import type {Registry } from "prom-client";
4-
import { Counter,Histogram } from "prom-client";
1+
import type { Informer, V1Pod } from "@kubernetes/client-node";
2+
import { LogLevel, SimpleStructuredLogger } from "@trigger.dev/core/v3/utils/structuredLogger";
3+
import type { Registry } from "prom-client";
4+
import { Counter, Histogram } from "prom-client";
55
import { setTimeout } from "timers/promises";
6-
import type {K8sApi } from "../clients/kubernetes.js";
6+
import type { K8sApi } from "../clients/kubernetes.js";
77
import { createK8sApi } from "../clients/kubernetes.js";
88
import { register } from "../metrics.js";
99

‎apps/supervisor/src/services/podCleaner.ts‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
import { IntervalService } from "@trigger.dev/core/v3";
22
import { SimpleStructuredLogger } from "@trigger.dev/core/v3/utils/structuredLogger";
3-
import type {Registry } from "prom-client";
4-
import { Counter,Gauge } from "prom-client";
5-
import type {K8sApi } from "../clients/kubernetes.js";
3+
import type { Registry } from "prom-client";
4+
import { Counter, Gauge } from "prom-client";
5+
import type { K8sApi } from "../clients/kubernetes.js";
66
import { createK8sApi } from "../clients/kubernetes.js";
77
import { register } from "../metrics.js";
88

‎apps/supervisor/src/workloadServer/index.ts‎

Lines changed: 28 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,24 +1,41 @@
11
import { SnapshotCallbackPayloadSchema } from "@internal/compute";
2-
import { type CheckpointClient,HttpServer } from "@trigger.dev/core/v3/serverOnly";
2+
import { type CheckpointClient, HttpServer } from "@trigger.dev/core/v3/serverOnly";
33
import { SimpleStructuredLogger } from "@trigger.dev/core/v3/utils/structuredLogger";
4-
import { type WorkloadRunSnapshotsSinceResponseBody, type SupervisorHttpClient, WORKLOAD_HEADERS, type WorkloadClientSocketData, type WorkloadClientToServerEvents, type WorkloadContinueRunExecutionResponseBody, WorkloadDebugLogRequestBody, type WorkloadDequeueFromVersionResponseBody, WorkloadHeartbeatRequestBody, type WorkloadHeartbeatResponseBody, WorkloadRunAttemptCompleteRequestBody, type WorkloadRunAttemptCompleteResponseBody, WorkloadRunAttemptStartRequestBody, type WorkloadRunAttemptStartResponseBody, type WorkloadServerToClientEvents, type WorkloadSuspendRunResponseBody } from "@trigger.dev/core/v3/workers";
4+
import {
5+
type WorkloadRunSnapshotsSinceResponseBody,
6+
type SupervisorHttpClient,
7+
WORKLOAD_HEADERS,
8+
type WorkloadClientSocketData,
9+
type WorkloadClientToServerEvents,
10+
type WorkloadContinueRunExecutionResponseBody,
11+
WorkloadDebugLogRequestBody,
12+
type WorkloadDequeueFromVersionResponseBody,
13+
WorkloadHeartbeatRequestBody,
14+
type WorkloadHeartbeatResponseBody,
15+
WorkloadRunAttemptCompleteRequestBody,
16+
type WorkloadRunAttemptCompleteResponseBody,
17+
WorkloadRunAttemptStartRequestBody,
18+
type WorkloadRunAttemptStartResponseBody,
19+
type WorkloadServerToClientEvents,
20+
type WorkloadSuspendRunResponseBody,
21+
} from "@trigger.dev/core/v3/workers";
522
import EventEmitter from "node:events";
6-
import type { IncomingMessage,ServerResponse } from "node:http";
7-
import { type Namespace,Server,type Socket } from "socket.io";
23+
import type { IncomingMessage, ServerResponse } from "node:http";
24+
import { type Namespace, Server, type Socket } from "socket.io";
825
import { z } from "zod";
926
import { env } from "../env.js";
1027
import { register } from "../metrics.js";
1128
import {
12-
ComputeSnapshotService,
13-
type RunTraceContext,
29+
ComputeSnapshotService,
30+
type RunTraceContext,
1431
} from "../services/computeSnapshotService.js";
1532
import type { OtlpTraceService } from "../services/otlpTraceService.js";
1633
import {
17-
emitOneShot,
18-
runWideEvent,
19-
setMeta,
20-
type State,
21-
type WideEventOptions,
34+
emitOneShot,
35+
runWideEvent,
36+
setMeta,
37+
type State,
38+
type WideEventOptions,
2239
} from "../wideEvents/index.js";
2340
import type { ComputeWorkloadManager } from "../workloadManager/compute.js";
2441

‎apps/webapp/app/components/BulkActionFilterSummary.tsx‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,11 @@ export function BulkActionFilterSummary({
4444
</Paragraph>
4545
);
4646
case "filter": {
47-
const { label, valueLabel, rangeType: _rangeType } = timeFilterRenderValues({
47+
const {
48+
label,
49+
valueLabel,
50+
rangeType: _rangeType,
51+
} = timeFilterRenderValues({
4852
from: filters.from ? dateFromString(`${filters.from}`) : undefined,
4953
to: filters.to ? dateFromString(`${filters.to}`) : undefined,
5054
period: filters.period,

‎apps/webapp/app/components/admin/debugRun.tsx‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import { Button } from "../primitives/Buttons";
44
import { Dialog, DialogContent, DialogHeader, DialogTrigger } from "../primitives/Dialog";
55
import { Cog6ToothIcon } from "@heroicons/react/20/solid";
66
import { type loader } from "~/routes/resources.taskruns.$runParam.debug";
7-
import type { UseDataFunctionReturn} from "remix-typedjson";
7+
import type { UseDataFunctionReturn } from "remix-typedjson";
88
import { useTypedFetcher } from "remix-typedjson";
99
import { useEffect } from "react";
1010
import { Spinner } from "../primitives/Spinner";

0 commit comments

Comments
 (0)