test from exposed entrypoint

Author: ianmacartney

example/convex/example.ts

@@ -6,11 +6,7 @@ import { components } from "./_generated/api.js";
 import { vWorkflowId } from "@convex-dev/workflow";
 import { vResultValidator } from "@convex-dev/workpool";
 
-export const workflow = new WorkflowManager(components.workflow, {
-  workpoolOptions: {
-    maxParallelism: 2,
-  },
-});
+export const workflow = new WorkflowManager(components.workflow);
 
 export const exampleWorkflow = workflow.define({
   args: {
@@ -113,7 +109,8 @@ export const flowCompleted = internalMutation({
       .withIndex("workflowId", (q) => q.eq("workflowId", args.workflowId))
       .first();
     if (!flow) {
-      throw new Error(`Flow not found: ${args.workflowId}`);
+      console.error(`Flow not found: ${args.workflowId}`);
+      return;
     }
     await ctx.db.patch(flow._id, {
       out: args.result,

example/convex/setup.test.ts

@@ -2,19 +2,13 @@
 import { test } from "vitest";
 import { convexTest } from "convex-test";
 import schema from "./schema";
-export const modules = import.meta.glob("./**/*.*s");
+import workflow from "@convex-dev/workflow/test";
 
-// Sorry about everything
-import componentSchema from "../../node_modules/@convex-dev/workflow/src/component/schema";
-export { componentSchema };
-export const componentModules = import.meta.glob(
-  "../../node_modules/@convex-dev/workflow/src/component/**/*.ts",
-);
+export const modules = import.meta.glob("./**/*.*s");
 
 export function initConvexTest() {
   const t = convexTest(schema, modules);
-  t.registerComponent("bigPool", componentSchema, componentModules);
-  t.registerComponent("smallPool", componentSchema, componentModules);
+  t.registerComponent("workflow", workflow.schema, workflow.modules);
   return t;
 }
 

package-lock.json

@@ -43,6 +43,7 @@
       "types": "./dist/client/index.d.ts",
       "default": "./dist/client/index.js"
     },
+    "./test": "./src/test.ts",
     "./convex.config": {
       "@convex-dev/component-source": "./src/component/convex.config.ts",
       "types": "./dist/component/convex.config.d.ts",
@@ -58,14 +59,14 @@
     "async-channel": "^0.2.0"
   },
   "devDependencies": {
-    "@convex-dev/workflow": "file:.",
     "@edge-runtime/vm": "5.0.0",
     "@eslint/eslintrc": "3.3.1",
     "@eslint/js": "9.37.0",
     "@types/node": "22.18.8",
     "@typescript-eslint/eslint-plugin": "8.40.0",
     "@typescript-eslint/parser": "8.40.0",
     "chokidar-cli": "3.0.0",
+    "convex": "^1.27.3",
     "convex-test": "0.0.38",
     "cpy-cli": "6.0.0",
     "eslint": "9.37.0",

package.json

@@ -0,0 +1,3 @@
+import schema from "./component/schema.js";
+const modules = import.meta.glob("./**/*.ts");
+export default { schema, modules };

src/test.ts

@@ -1,7 +1,7 @@
 {
   "extends": "./tsconfig.json",
   "include": ["src/**/*.ts", "src/**/*.tsx", "src/**/*.js", "src/**/*.d.ts"],
-  "exclude": ["src/**/*.test.*", "src/vitest.config.ts"],
+  "exclude": ["src/**/*.test.*", "src/vitest.config.ts", "src/test.ts"],
   "compilerOptions": {
     "module": "ESNext",
     "moduleResolution": "Bundler",