chore: bump version to 1.8.3

Author: igorls

package.json

@@ -1,6 +1,6 @@
 {
   "name": "comfyui-node",
-  "version": "1.8.2",
+  "version": "1.8.3",
   "description": "ComfyUI Node.js Client",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/multipool/job-state-registry.ts

@@ -155,7 +155,10 @@ export class JobStateRegistry {
   completeJob(prompt_id: string) {
     const jobState = this.jobs.get(this.promptIdToJobId.get(prompt_id) || "");
     if (!jobState || !jobState.prompt_id) {
-      throw new Error(`No job state found for prompt_id ${prompt_id} when completing job.`);
+      // Gracefully handle jobs not tracked by this registry (e.g., recovered jobs, external jobs)
+      // This can happen when jobs are recovered via JobRecoveryManager or submitted externally
+      console.warn(`No job state found for prompt_id ${prompt_id} when completing job - job may have been recovered externally or is an external job.`);
+      return;
     }
     if (jobState.prompt_id === prompt_id) {
       jobState.status = "completed";
@@ -224,7 +227,8 @@ export class JobStateRegistry {
   addJobImages(prompt_id: string, images: ImageInfo[]) {
     const state = this.jobs.get(this.promptIdToJobId.get(prompt_id) || "");
     if (!state) {
-      throw new Error(`No job state found for prompt_id ${prompt_id} when adding images.`);
+      console.warn(`No job state found for prompt_id ${prompt_id} when adding images.`);
+      return;
     }
     if (state.prompt_id === prompt_id) {
       state.images = [...images];

src/multipool/workflow.ts

@@ -121,15 +121,15 @@ type OutputMap = Record<string, any>;
 // These are intentionally minimal; users can still refine manually.
 type OutputShapeFor<C extends string> =
   C extends "SaveImage" | "SaveImageAdvanced" ? { images?: any[] } :
-    C extends "KSampler" ? { samples?: any } :
-      any;
+  C extends "KSampler" ? { samples?: any } :
+  any;
 
 type NodeOutputFor<T extends WorkflowJSON, K extends keyof T & string> =
   T[K] extends { class_type: infer C }
-    ? C extends string
-      ? OutputShapeFor<C>
-      : any
-    : any;
+  ? C extends string
+  ? OutputShapeFor<C>
+  : any
+  : any;
 
 export class Workflow<T extends WorkflowJSON = WorkflowJSON, O extends OutputMap = {}> {
   private json: T;
@@ -425,9 +425,9 @@ export class Workflow<T extends WorkflowJSON = WorkflowJSON, O extends OutputMap
         // Prefer just the filename; many LoadImage nodes look up by filename (subfolder managed server-side)
         this.input(it.nodeId as any, it.inputName as any, it.fileName as any);
       }
-      // Clear pending once applied
-      this._pendingFolderFiles = [];
-      this._pendingImageInputs = [];
+      // NOTE: We intentionally do NOT clear pending arrays here.
+      // This allows retries to a different host to still have assets to upload.
+      // The upload API uses override mode, so duplicate uploads are idempotent.
     }
   }
 }
@@ -440,7 +440,7 @@ export interface Workflow<T extends WorkflowJSON = WorkflowJSON, O extends Outpu
   // 2. output('alias:NODE_ID') -> alias key with inferred node output
   output<Spec extends `${string}:${keyof T & string}`>(spec: Spec): Workflow<T, O & (
     Spec extends `${infer Alias}:${infer Node}` ? (Node extends keyof T & string ? Record<Alias, NodeOutputFor<T, Node>> : Record<Alias, any>) : {}
-    )>;
+  )>;
 
   // 3. output('alias','NODE_ID') -> alias key
   output<Alias extends string, NodeId extends keyof T & string>(alias: Alias, nodeId: NodeId): Workflow<T, O & Record<Alias, NodeOutputFor<T, NodeId>>>;