gracefully bail onComplete when canceled

.github/workflows/node.js.yml

@@ -17,3 +17,4 @@ jobs:
       - run: npm run typecheck
       - run: cd example && npm run lint && cd ..
       - run: npm test
+      - run: npx pkg-pr-new publish

example/convex/_generated/api.d.ts

@@ -50,27 +50,6 @@ export declare const components: {
         "internal",
         { workflowId: string },
         {
-          inProgress: Array<{
-            _creationTime: number;
-            _id: string;
-            step: {
-              args: any;
-              argsSize: number;
-              completedAt?: number;
-              functionType: "query" | "mutation" | "action";
-              handle: string;
-              inProgress: boolean;
-              name: string;
-              runResult?:
-                | { kind: "success"; returnValue: any }
-                | { error: string; kind: "failed" }
-                | { kind: "canceled" };
-              startedAt: number;
-              workId?: string;
-            };
-            stepNumber: number;
-            workflowId: string;
-          }>;
           journalEntries: Array<{
             _creationTime: number;
             _id: string;
@@ -190,7 +169,6 @@ export declare const components: {
         "internal",
         {
           generationNumber: number;
-          now: number;
           runResult:
             | { kind: "success"; returnValue: any }
             | { error: string; kind: "failed" }

example/convex/example.ts

@@ -98,6 +98,7 @@ export const flowCompleted = internalMutation({
     await ctx.db.patch(flow._id, {
       out: args.result,
     });
+    await workflow.cleanup(ctx, args.workflowId);
   },
 });