Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
5 changes: 0 additions & 5 deletions .changeset/redis-worker-oldest-message-age.md

This file was deleted.

5 changes: 0 additions & 5 deletions .changeset/tidy-exec-arg-logging.md

This file was deleted.

2 changes: 1 addition & 1 deletion .github/workflows/code-quality.yml
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ permissions:

jobs:
code-quality:
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404

steps:
- name: ⬇️ Checkout repo
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/docs.yml
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ permissions:

jobs:
check-broken-links:
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404
defaults:
run:
working-directory: ./docs
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/e2e-webapp-auth-full.yml
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ on:
jobs:
e2eAuthFull:
name: "🛡️ E2E Auth Tests (full)"
runs-on: ubuntu-latest
runs-on: blacksmith-8vcpu-ubuntu-2404
timeout-minutes: 30
env:
DOCKERHUB_USERNAME: ${{ secrets.DOCKERHUB_USERNAME }}
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/e2e-webapp.yml
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ on:
jobs:
e2eTests:
name: "🧪 E2E Tests: Webapp"
runs-on: ubuntu-latest
runs-on: blacksmith-8vcpu-ubuntu-2404
timeout-minutes: 20
env:
DOCKERHUB_USERNAME: ${{ secrets.DOCKERHUB_USERNAME }}
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/e2e.yml
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ jobs:
strategy:
fail-fast: false
matrix:
os: [ubuntu-latest, windows-latest]
os: [blacksmith-4vcpu-ubuntu-2404, blacksmith-4vcpu-windows-2025]
package-manager: ["npm", "pnpm"]
steps:
- name: ⬇️ Checkout repo
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/helm-prerelease.yml
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ env:

jobs:
lint-and-test:
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404
permissions:
contents: read
steps:
Expand Down Expand Up @@ -77,7 +77,7 @@ jobs:
((github.event_name == 'pull_request' && github.event.pull_request.head.repo.full_name == github.repository) ||
github.event_name == 'push' ||
github.event_name == 'workflow_dispatch')
runs-on: ubuntu-latest
runs-on: blacksmith-4vcpu-ubuntu-2404
permissions:
contents: read
packages: write
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/publish-webapp.yml
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ on:

jobs:
publish:
runs-on: ubuntu-latest
runs-on: blacksmith-8vcpu-ubuntu-2404
env:
PRISMA_ENGINES_CHECKSUM_IGNORE_MISSING: 1
outputs:
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/publish-worker-v4.yml
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ jobs:
strategy:
matrix:
package: [supervisor]
runs-on: ubuntu-latest
runs-on: blacksmith-8vcpu-ubuntu-2404
env:
DOCKER_BUILDKIT: "1"
steps:
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/publish-worker.yml
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ jobs:
strategy:
matrix:
package: [coordinator, docker-provider, kubernetes-provider]
runs-on: ubuntu-latest
runs-on: blacksmith-8vcpu-ubuntu-2404
env:
DOCKER_BUILDKIT: "1"
DOCKERHUB_USERNAME: ${{ secrets.DOCKERHUB_USERNAME }}
Expand Down
8 changes: 4 additions & 4 deletions .github/workflows/sdk-compat.yml
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ jobs:
strategy:
fail-fast: false
matrix:
os: [ubuntu-latest]
os: [blacksmith-4vcpu-ubuntu-2404]
node: ["20.20", "22.12"]

steps:
Expand Down Expand Up @@ -54,7 +54,7 @@ jobs:

bun-compat:
name: "Bun Runtime"
runs-on: ubuntu-latest
runs-on: blacksmith-4vcpu-ubuntu-2404
steps:
- name: ⬇️ Checkout repo
uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
Expand Down Expand Up @@ -96,7 +96,7 @@ jobs:

deno-compat:
name: "Deno Runtime"
runs-on: ubuntu-latest
runs-on: blacksmith-4vcpu-ubuntu-2404
steps:
- name: ⬇️ Checkout repo
uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
Expand Down Expand Up @@ -142,7 +142,7 @@ jobs:

cloudflare-compat:
name: "Cloudflare Workers"
runs-on: ubuntu-latest
runs-on: blacksmith-4vcpu-ubuntu-2404
steps:
- name: ⬇️ Checkout repo
uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/trivy-image-webapp.yml
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ concurrency:
jobs:
scan:
name: Scan
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404
permissions:
contents: read
packages: read # pull the image from GHCR
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/typecheck.yml
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ permissions:

jobs:
typecheck:
runs-on: ubuntu-latest
runs-on: blacksmith-8vcpu-ubuntu-2404

steps:
- name: ⬇️ Checkout repo
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/unit-tests-internal.yml
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ on:
jobs:
unitTests:
name: "🧪 Unit Tests: Internal"
runs-on: ubuntu-latest
runs-on: blacksmith-8vcpu-ubuntu-2404
strategy:
# one flaky shard shouldn't cancel its siblings - lets us re-run only the failed shard
fail-fast: false
Expand Down Expand Up @@ -130,7 +130,7 @@ jobs:
name: "📊 Merge Reports"
if: ${{ !cancelled() }}
needs: [unitTests]
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404
steps:
- name: ⬇️ Checkout repo
uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/unit-tests-packages.yml
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ on:
jobs:
unitTests:
name: "🧪 Unit Tests: Packages"
runs-on: ubuntu-latest
runs-on: blacksmith-4vcpu-ubuntu-2404
strategy:
# one flaky shard shouldn't cancel its siblings - lets us re-run only the failed shard
fail-fast: false
Expand Down Expand Up @@ -130,7 +130,7 @@ jobs:
name: "📊 Merge Reports"
if: ${{ !cancelled() }}
needs: [unitTests]
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404
steps:
- name: ⬇️ Checkout repo
uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/unit-tests-webapp.yml
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ on:
jobs:
unitTests:
name: "🧪 Unit Tests: Webapp"
runs-on: ubuntu-latest
runs-on: blacksmith-8vcpu-ubuntu-2404
strategy:
# one flaky shard shouldn't cancel its siblings - lets us re-run only the failed shard
fail-fast: false
Expand Down Expand Up @@ -139,7 +139,7 @@ jobs:
name: "📊 Merge Reports"
if: ${{ !cancelled() }}
needs: [unitTests]
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404
steps:
- name: ⬇️ Checkout repo
uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/workflow-checks.yml
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ concurrency:
jobs:
actionlint:
name: Actionlint
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404
permissions:
contents: read
steps:
Expand All @@ -43,7 +43,7 @@ jobs:
# variable to 'false' to skip this job where code scanning isn't available;
# leave it unset (the default) to run the scan.
if: ${{ vars.ENABLE_WORKFLOW_SECURITY_SCAN != 'false' }}
runs-on: ubuntu-latest
runs-on: blacksmith-2vcpu-ubuntu-2404
permissions:
security-events: write # Upload SARIF to GitHub Security tab
contents: read # Read workflow files for analysis
Expand Down
16 changes: 13 additions & 3 deletions .oxlintrc.json
Original file line number Diff line number Diff line change
Expand Up @@ -11,13 +11,23 @@
"internal-packages/tsql/src/grammar/"
],
"rules": {
"no-unused-vars": "off",
"no-unused-vars": [
"error",
{
"args": "all",
"argsIgnorePattern": "^_",
"varsIgnorePattern": "^_",
"caughtErrors": "all",
"caughtErrorsIgnorePattern": "^_",
"destructuredArrayIgnorePattern": "^_"
}
],
"no-empty-pattern": "off",
"no-control-regex": "off",
"typescript/no-non-null-asserted-optional-chain": "off",
"no-unused-expressions": ["warn", { "allowShortCircuit": true, "allowTernary": true }],
"typescript/consistent-type-imports": "off",
"import/no-duplicates": "off",
"typescript/consistent-type-imports": "error",
"import/no-duplicates": "error",
"import/namespace": "off",
"react-hooks/exhaustive-deps": "off",
"react-hooks/rules-of-hooks": "off"
Expand Down
6 changes: 0 additions & 6 deletions .server-changes/conform-v1.md

This file was deleted.

4 changes: 2 additions & 2 deletions apps/coordinator/src/checkpointer.ts
Original file line number Diff line number Diff line change
Expand Up @@ -334,7 +334,7 @@ export class Checkpointer {

try {
await setTimeout(delayMs, undefined, { signal });
} catch (error) {
} catch (_error) {
this.#logger.log("Checkpoint canceled during initial delay", { runId });
return { success: false, reason: "CANCELED" };
}
Expand Down Expand Up @@ -364,7 +364,7 @@ export class Checkpointer {

try {
await setTimeout(delay.milliseconds, undefined, { signal });
} catch (error) {
} catch (_error) {
this.#logger.log("Checkpoint canceled during retry delay", { runId });
return { success: false, reason: "CANCELED" };
}
Expand Down
2 changes: 1 addition & 1 deletion apps/coordinator/src/exec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -208,7 +208,7 @@ export class Buildah {
try {
await x("buildah", ["login", "--get-login", registryHost], { throwOnError: true });
return true;
} catch (error) {
} catch (_error) {
return false;
}
}
Expand Down
10 changes: 5 additions & 5 deletions apps/coordinator/src/index.ts
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
import { createServer } from "node:http";
import { Server } from "socket.io";
import type { WaitReason } from "@trigger.dev/core/v3";
import {
CoordinatorToPlatformMessages,
CoordinatorToProdWorkerMessages,
omit,
PlatformToCoordinatorMessages,
ProdWorkerSocketData,
ProdWorkerToCoordinatorMessages,
WaitReason,
} from "@trigger.dev/core/v3";
import { ZodNamespace } from "@trigger.dev/core/v3/zodNamespace";
import { ZodSocketConnection } from "@trigger.dev/core/v3/zodSocket";
Expand Down Expand Up @@ -423,7 +423,7 @@ class TaskCoordinator {

next();
},
onConnection: async (socket, handler, sender) => {
onConnection: async (socket, _handler, _sender) => {
const logger = new SimpleStructuredLogger("ns-prod-worker", undefined, {
namespace: "prod-worker",
socketId: socket.id,
Expand Down Expand Up @@ -1456,7 +1456,7 @@ class TaskCoordinator {
}
});
},
onDisconnect: async (socket, handler, sender, logger) => {
onDisconnect: async (socket, _handler, _sender, logger) => {
try {
this.#platformSocket?.send("LOG", {
metadata: socket.data,
Expand Down Expand Up @@ -1529,7 +1529,7 @@ class TaskCoordinator {
}
});

httpServer.on("clientError", (err, socket) => {
httpServer.on("clientError", (_err, socket) => {
socket.end("HTTP/1.1 400 Bad Request\r\n\r\n");
});

Expand Down Expand Up @@ -1760,7 +1760,7 @@ class TaskCoordinator {
}
});

httpServer.on("clientError", (err, socket) => {
httpServer.on("clientError", (_err, socket) => {
socket.end("HTTP/1.1 400 Bad Request\r\n\r\n");
});

Expand Down
2 changes: 1 addition & 1 deletion apps/coordinator/src/util.ts
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ export function safeJsonParse(json?: string): unknown {

try {
return JSON.parse(json);
} catch (e) {
} catch (_e) {
return null;
}
}
10 changes: 4 additions & 6 deletions apps/docker-provider/src/index.ts
Original file line number Diff line number Diff line change
@@ -1,16 +1,14 @@
import { $, type ExecaChildProcess, execa } from "execa";
import {
ProviderShell,
import type {
TaskOperations,
TaskOperationsCreateOptions,
TaskOperationsIndexOptions,
TaskOperationsRestoreOptions,
} from "@trigger.dev/core/v3/apps";
import { SimpleLogger } from "@trigger.dev/core/v3/apps";
import { isExecaChildProcess } from "@trigger.dev/core/v3/apps";
import { ProviderShell, SimpleLogger, isExecaChildProcess } from "@trigger.dev/core/v3/apps";
import { testDockerCheckpoint } from "@trigger.dev/core/v3/serverOnly";
import { setTimeout } from "node:timers/promises";
import { PostStartCauses, PreStopCauses } from "@trigger.dev/core/v3";
import type { PostStartCauses, PreStopCauses } from "@trigger.dev/core/v3";

const MACHINE_NAME = process.env.MACHINE_NAME || "local";
const COORDINATOR_PORT = process.env.COORDINATOR_PORT || 8020;
Expand Down Expand Up @@ -192,7 +190,7 @@ class DockerTaskOperations implements TaskOperations {
logger.log("noop: delete");
}

async get(opts: { runId: string }) {
async get(_opts: { runId: string }) {
await this.init();

logger.log("noop: get");
Expand Down
Loading
Loading