Unused parameter workerId in TaskDispatcher.handleTaskError #164

New issue

Closed

opened 2026-01-24 10:13:35 +00:00 by jack · 0 comments

jack commented

2026-01-24 10:13:35 +00:00

Owner

Beschreibung

In packages/backend/src/websocket/task-dispatcher.ts wird der Parameter workerId in der Methode handleTaskError nicht verwendet:

private async handleTaskError(
  workerId: string,  // ← Wird nicht verwendet
  taskId: string,
  error: string
): Promise<void> {
  try {
    const task = await this.taskQueue.findById(taskId);
    if (!task) {
      logger.warn(`Task ${taskId} not found for error handling`);
      return;
    }

    const newRetryCount = task.retryCount + 1;
    // ... rest of method never uses workerId
  }
}

Die Methode wird als Callback registriert (Zeile 78):

this.hub.onTaskError = this.handleTaskError.bind(this);

Zu prüfen

Sollte workerId für Logging verwendet werden?
- Z.B. logger.warn(\Task ${taskId} from worker ${workerId} failed: ${error}`)`
Ist workerId für Retry-Logik relevant?
- Z.B. denselben Worker bei Retry vermeiden
Wird die Signatur vom Hub vorgegeben?
- Prüfen ob onTaskError Callback-Signatur den Parameter erwartet

Betroffene Datei

packages/backend/src/websocket/task-dispatcher.ts (Zeile 378-382)

⚠️ Hinweis

Nicht einfach löschen! Zuerst prüfen:

Ob die Callback-Signatur von WorkerHub.onTaskError den Parameter erwartet
Ob workerId für besseres Logging/Debugging verwendet werden sollte
Ob es eine fehlende Implementierung gibt (z.B. Worker-spezifische Fehlerbehandlung)

## Beschreibung In `packages/backend/src/websocket/task-dispatcher.ts` wird der Parameter `workerId` in der Methode `handleTaskError` nicht verwendet: ```typescript private async handleTaskError( workerId: string, // ← Wird nicht verwendet taskId: string, error: string ): Promise<void> { try { const task = await this.taskQueue.findById(taskId); if (!task) { logger.warn(`Task ${taskId} not found for error handling`); return; } const newRetryCount = task.retryCount + 1; // ... rest of method never uses workerId } } ``` Die Methode wird als Callback registriert (Zeile 78): ```typescript this.hub.onTaskError = this.handleTaskError.bind(this); ``` ## Zu prüfen 1. **Sollte `workerId` für Logging verwendet werden?** - Z.B. `logger.warn(\`Task ${taskId} from worker ${workerId} failed: ${error}\`)` 2. **Ist `workerId` für Retry-Logik relevant?** - Z.B. denselben Worker bei Retry vermeiden 3. **Wird die Signatur vom Hub vorgegeben?** - Prüfen ob `onTaskError` Callback-Signatur den Parameter erwartet ## Betroffene Datei - `packages/backend/src/websocket/task-dispatcher.ts` (Zeile 378-382) ## ⚠️ Hinweis Nicht einfach löschen! Zuerst prüfen: - Ob die Callback-Signatur von `WorkerHub.onTaskError` den Parameter erwartet - Ob `workerId` für besseres Logging/Debugging verwendet werden sollte - Ob es eine fehlende Implementierung gibt (z.B. Worker-spezifische Fehlerbehandlung)