Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
ff68a69
feat: executor mode with query/mutation routing and per-step retries
sethconvex Feb 24, 2026
f0bd00a
Remove unreleased BatchWorkpool code path
sethconvex Feb 24, 2026
a229c69
Address CodeRabbit review findings
sethconvex Feb 24, 2026
de4a686
Fix: rescue queue for failed replay candidates
sethconvex Feb 24, 2026
a45882e
Fix executor straggler bug, rate limiting, and performance tuning
sethconvex Feb 25, 2026
c0f6a4b
[checkpoint] Manual: Sharded task queue + executor-driven chaining im…
sethconvex Feb 24, 2026
03161f6
[checkpoint] Best perf run: 19989/20000 completed (bypass coordinator…
sethconvex Feb 24, 2026
fea0dcc
Batched replay mutations + incremental viz loading
sethconvex Feb 24, 2026
7ad00a9
Fix viz flicker: keep previous frame until new data exceeds it
sethconvex Feb 24, 2026
465da4a
Inline replay into recordResultBatch + tune flush params
sethconvex Feb 24, 2026
ad02b17
Serialized flush→replay: eliminate OCC conflicts at scale
sethconvex Feb 25, 2026
43e7990
Add stacked phase concurrency graph to benchmark viz
sethconvex Feb 25, 2026
ec191f2
Add executor performance tuning doc
sethconvex Feb 25, 2026
cd24785
[checkpoint] Manual: Before per-workflow mutation restructure
sethconvex Feb 25, 2026
27f7c26
Fix executor straggler bug + viz improvements
sethconvex Feb 25, 2026
9a716bf
Add WorkflowRateLimitError + per-step-type rate-limit gates
sethconvex Feb 25, 2026
3175381
Remove docs, benchmarks, scripts, and temp files from core PR
sethconvex Feb 25, 2026
fc3fa22
Fix silent replay swallowing + address review feedback
sethconvex Feb 25, 2026
bafddef
Eliminate permanently stuck workflows with durable replay safety net
sethconvex Feb 25, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions example/convex/_generated/api.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,9 @@
*/

import type * as admin from "../admin.js";
import type * as benchmark from "../benchmark.js";
import type * as example from "../example.js";
import type * as http from "../http.js";
import type * as nestedWorkflow from "../nestedWorkflow.js";
import type * as passingSignals from "../passingSignals.js";
import type * as transcription from "../transcription.js";
Expand All @@ -23,7 +25,9 @@ import type {

declare const fullApi: ApiFromModules<{
admin: typeof admin;
benchmark: typeof benchmark;
example: typeof example;
http: typeof http;
nestedWorkflow: typeof nestedWorkflow;
passingSignals: typeof passingSignals;
transcription: typeof transcription;
Expand Down Expand Up @@ -58,4 +62,5 @@ export declare const internal: FilterApi<

export declare const components: {
workflow: import("@convex-dev/workflow/_generated/component.js").ComponentApi<"workflow">;
workpool: import("@convex-dev/workpool/_generated/component.js").ComponentApi<"workpool">;
};
2 changes: 2 additions & 0 deletions example/convex/convex.config.ts
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
import { defineApp } from "convex/server";
import workflow from "@convex-dev/workflow/convex.config";
import workpool from "@convex-dev/workpool/convex.config";

const app = defineApp();
app.use(workflow);
app.use(workpool);
export default app;
5 changes: 5 additions & 0 deletions example/convex/schema.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,4 +8,9 @@ export default defineSchema({
workflowId: vWorkflowId,
out: v.any(),
}).index("workflowId", ["workflowId"]),
benchmarkResults: defineTable({
workflowId: vWorkflowId,
result: v.any(),
completedAt: v.number(),
}).index("workflowId", ["workflowId"]),
});
98 changes: 74 additions & 24 deletions package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,7 @@
"convex-helpers": "^0.1.99"
},
"dependencies": {
"@anthropic-ai/sdk": "^0.78.0",
"async-channel": "^0.2.0"
},
"devDependencies": {
Expand All @@ -74,7 +75,7 @@
"@typescript-eslint/eslint-plugin": "8.54.0",
"@typescript-eslint/parser": "8.54.0",
"chokidar-cli": "3.0.0",
"convex": "1.31.7",
"convex": "^1.32.0",
"convex-helpers": "0.1.111",
"convex-test": "0.0.41",
"cpy-cli": "7.0.0",
Expand Down
Loading