Method startWorker

src/python/worker.ts:46–106

()

  }

  private async startWorker(): Promise<void> {
    const wrapperPath = path.join(getWrapperDir('python'), 'persistent_wrapper.py');

    // Validate and resolve Python path using smart detection (tries python3, then python)
    const resolvedPythonPath = await validatePythonPath(
      this.pythonPath || 'python',
      typeof this.pythonPath === 'string',
    );

    this.process = new PythonShell(wrapperPath, {
      mode: 'text',
      pythonPath: resolvedPythonPath,
      args: [this.scriptPath, this.functionName],
      stdio: ['pipe', 'pipe', 'pipe'],
    });

    // Listen for READY signal
    return new Promise((resolve, reject) => {
      const readyTimeout = setTimeout(() => {
        // Kill the process to prevent orphaned Python processes
        // and avoid triggering handleCrash() which would retry
        this.shuttingDown = true;
        if (this.process) {
          this.process.kill('SIGTERM');
          this.process = null;
        }
        reject(new Error('Worker failed to become ready within timeout'));
      }, 30000);

      this.process!.on('message', (message: string) => {
        if (message.trim() === 'READY') {
          clearTimeout(readyTimeout);
          this.ready = true;
          logger.debug(`Python worker ready for ${this.scriptPath}`);
          // Notify pool that worker is ready (triggers queue processing)
          if (this.onReady) {
            this.onReady();
          }
          resolve();
        } else if (message.startsWith('DONE|')) {
          this.handleDone(message.slice('DONE|'.length));
        }
      });

      this.process!.on('error', (err) => {
        clearTimeout(readyTimeout);
        reject(err);
      });

      this.process!.on('close', () => {
        this.flushStderr();
        if (!this.shuttingDown) {
          this.handleCrash();
        }
      });

      this.process!.stderr?.on('data', (data) => {
        this.handleStderr(data);