1.8.4

Author: igorls

dist/multipool/job-state-registry.d.ts.map

@@ -1,3 +1,4 @@
+import { PoolEventManager } from "./pool-event-manager.js";
 import { JobQueueProcessor } from "./job-queue-processor.js";
 import { Workflow } from "./workflow.js";
 import { MultiWorkflowPoolOptions, PoolEvent, JobResults, SubmitJobOptions } from "./interfaces.js";
@@ -7,7 +8,7 @@ import { MultiWorkflowPoolOptions, PoolEvent, JobResults, SubmitJobOptions } fro
  * Zero polling is used; all operations are event driven. Maximizes responsiveness and scalability.
  */
 export declare class MultiWorkflowPool {
-    private events;
+    protected events: PoolEventManager;
     private clientRegistry;
     private jobRegistry;
     queues: Map<string, JobQueueProcessor>;
@@ -26,6 +27,11 @@ export declare class MultiWorkflowPool {
     getJobStatus(jobId: string): import("./interfaces.js").JobStatus;
     cancelJob(jobId: string): Promise<void>;
     attachEventHook(event: string, listener: (e: PoolEvent) => void): void;
+    detachEventHook(event: string, listener: (e: PoolEvent) => void): void;
+    /**
+     * Emit a pool event (for internal components like registries)
+     */
+    emitEvent(event: PoolEvent): void;
     private assertQueue;
     private attachHandlersToClient;
     private printStatusSummary;

dist/multipool/job-state-registry.js

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

dist/multipool/job-state-registry.js.map

@@ -146,6 +146,16 @@ export class JobStateRegistry {
     jobState.prompt_id = prompt_id;
     this.promptIdToJobId.set(prompt_id, jobId);
 
+    // Emit event for external tracking (e.g., Redis-based multi-worker sync)
+    this.pool.emitEvent({
+      type: 'job:prompt_assigned',
+      payload: {
+        jobId,
+        promptId: prompt_id,
+        assignedClientUrl: jobState.assignedClientUrl,
+      },
+    });
+
     // Notify profiler of execution start
     if (jobState.profiler) {
       jobState.profiler.onExecutionStart(prompt_id);

dist/multipool/multi-workflow-pool.d.ts

@@ -11,8 +11,8 @@ import { MultiWorkflowPoolOptions, PoolEvent, ClientEventPayload, EnhancedClient
  * Zero polling is used; all operations are event driven. Maximizes responsiveness and scalability.
  */
 export class MultiWorkflowPool {
-  // Event manager for handling pool events
-  private events: PoolEventManager;
+  // Event manager for handling pool events (protected for internal access by registries)
+  protected events: PoolEventManager;
 
   // Registry for managing clients in the pool
   private clientRegistry: ClientRegistry;
@@ -200,6 +200,19 @@ export class MultiWorkflowPool {
     }
   }
 
+  detachEventHook(event: string, listener: (e: PoolEvent) => void) {
+    if (event && listener) {
+      this.events.detachHook(event, listener);
+    }
+  }
+
+  /**
+   * Emit a pool event (for internal components like registries)
+   */
+  emitEvent(event: PoolEvent) {
+    this.events.emitEvent(event);
+  }
+
   // PRIVATE METHODS
   private assertQueue(workflowHash: string | undefined): JobQueueProcessor | null {
     if (!workflowHash) {