Method execute

src/python/workerPool.ts:66–84

(functionName: string, args: unknown[])

  // biome-ignore lint/suspicious/noExplicitAny: FIXME
  async execute(functionName: string, args: unknown[]): Promise<any> {
    if (!this.isInitialized) {
      throw new Error('Worker pool not initialized');
    }

    // Try to get available worker
    const worker = this.getAvailableWorker();

    if (worker) {
      // Worker available, execute immediately and trigger queue processing when done
      return worker.call(functionName, args).finally(() => this.processQueue());
    } else {
      // All workers busy, queue the request
      return new Promise<unknown>((resolve, reject) => {
        this.queue.push({ functionName, args, resolve, reject });
        logger.debug(`Request queued (queue size: ${this.queue.length})`);
      });
    }
  }

  private getAvailableWorker(): PythonWorker | null {
    for (const worker of this.workers) {