.

Author: ldanilek

example/convex/_generated/api.d.ts

@@ -58,11 +58,8 @@ export declare const components: {
           fnName: string;
           fnType: "action" | "mutation";
           options: {
-            fastHeartbeatMs?: number;
             logLevel?: "DEBUG" | "INFO" | "WARN" | "ERROR";
             maxParallelism: number;
-            mutationTimeoutMs?: number;
-            slowHeartbeatMs?: number;
             ttl?: number;
           };
         },
@@ -81,7 +78,6 @@ export declare const components: {
           }
       >;
       stopCleanup: FunctionReference<"mutation", "internal", {}, any>;
-      stopMainLoop: FunctionReference<"mutation", "internal", {}, any>;
     };
   };
   lowpriWorkpool: {
@@ -102,11 +98,8 @@ export declare const components: {
           fnName: string;
           fnType: "action" | "mutation";
           options: {
-            fastHeartbeatMs?: number;
             logLevel?: "DEBUG" | "INFO" | "WARN" | "ERROR";
             maxParallelism: number;
-            mutationTimeoutMs?: number;
-            slowHeartbeatMs?: number;
             ttl?: number;
           };
         },
@@ -125,7 +118,46 @@ export declare const components: {
           }
       >;
       stopCleanup: FunctionReference<"mutation", "internal", {}, any>;
-      stopMainLoop: FunctionReference<"mutation", "internal", {}, any>;
+    };
+  };
+  highPriWorkpool: {
+    lib: {
+      cancel: FunctionReference<"mutation", "internal", { id: string }, any>;
+      cleanup: FunctionReference<
+        "mutation",
+        "internal",
+        { maxAgeMs: number },
+        any
+      >;
+      enqueue: FunctionReference<
+        "mutation",
+        "internal",
+        {
+          fnArgs: any;
+          fnHandle: string;
+          fnName: string;
+          fnType: "action" | "mutation";
+          options: {
+            logLevel?: "DEBUG" | "INFO" | "WARN" | "ERROR";
+            maxParallelism: number;
+            ttl?: number;
+          };
+        },
+        string
+      >;
+      startMainLoop: FunctionReference<"mutation", "internal", {}, any>;
+      status: FunctionReference<
+        "query",
+        "internal",
+        { id: string },
+        | { kind: "pending" }
+        | { kind: "inProgress" }
+        | {
+            completionStatus: "success" | "error" | "canceled" | "timeout";
+            kind: "completed";
+          }
+      >;
+      stopCleanup: FunctionReference<"mutation", "internal", {}, any>;
     };
   };
 };

example/convex/convex.config.ts

@@ -4,5 +4,6 @@ import workpool from "@convex-dev/workpool/convex.config";
 const app = defineApp();
 app.use(workpool);
 app.use(workpool, { name: "lowpriWorkpool" });
+app.use(workpool, { name: "highPriWorkpool" });
 
 export default app;

example/convex/example.ts

@@ -9,7 +9,7 @@ import { api, components, internal } from "./_generated/api";
 import { WorkPool } from "@convex-dev/workpool";
 import { v } from "convex/values";
 
-const highPriPool = new WorkPool(components.workpool, {
+const highPriPool = new WorkPool(components.highPriWorkpool, {
   maxParallelism: 20,
   // For tests, disable completed work cleanup.
   ttl: Number.POSITIVE_INFINITY,