docs: Kommentar-Schreibweise wf_<runId>.json zu <runId>.json vereinheitlicht

Die runId ist bereits mit "wf_" praefixiert; der Code erzeugt
<proj>/workflows/<runId>.json. Die Kurz-Referenzen in den Code-Kommentaren
(WorkflowProgressTracker, ClaudeCliService, AnthropicService, SessionEndpoint)
nutzten faelschlich das doppelte "wf_"-Praefix.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
MelekiandClaude Opus 4.8 committed 2026-06-20 18:18:49 +02:00
1 parent 2b95161596
commit 418a22d18d
4 files changed
+7 -7

No files matched your search

+1 -1
View File
@@ -457,7 +457,7 @@ public static class SessionEndpoint
var streaming = streamingTracker.IsStreaming(sessionId); var streaming = streamingTracker.IsStreaming(sessionId);
// 1) Aktueller Lauf registriert: Telemetrie aus den Transcript-Dateien lesen – // 1) Aktueller Lauf registriert: Telemetrie aus den Transcript-Dateien lesen –
// live aus journal.jsonl (Counts), nach Abschluss aus wf_<runId>.json (reich). // live aus journal.jsonl (Counts), nach Abschluss aus <runId>.json (reich).
var run = workflowTracker.Get(sessionId); var run = workflowTracker.Get(sessionId);
if (run != null) if (run != null)
{ {
+1 -1
View File
@@ -331,7 +331,7 @@ public partial class AnthropicService
{ {
try try
{ {
// Reiche End-Telemetrie aus der wf_<runId>.json des Laufs lesen und persistieren // Reiche End-Telemetrie aus der <runId>.json des Laufs lesen und persistieren
// (Fallback: Live-Counts aus dem journal.jsonl, falls die json noch nicht da ist). // (Fallback: Live-Counts aus dem journal.jsonl, falls die json noch nicht da ist).
var wp = WorkflowTelemetryReader.Read(_workflowTracker.Get(chain.SessionId)); var wp = WorkflowTelemetryReader.Read(_workflowTracker.Get(chain.SessionId));
if (wp != null) if (wp != null)
+1 -1
View File
@@ -96,7 +96,7 @@ public class ClaudeCliService
/// Erkennt den tool_result des dynamischen Workflow-Tools ("Workflow launched in background … /// Erkennt den tool_result des dynamischen Workflow-Tools ("Workflow launched in background …
/// Transcript dir: …") und registriert den Lauf im WorkflowProgressTracker. Der Workflow läuft /// Transcript dir: …") und registriert den Lauf im WorkflowProgressTracker. Der Workflow läuft
/// als detachter Hintergrund-Task mit eigenem Transcript – seine Live-/End-Telemetrie wird /// als detachter Hintergrund-Task mit eigenem Transcript – seine Live-/End-Telemetrie wird
/// später aus den dort liegenden Dateien (journal.jsonl / wf_&lt;runId&gt;.json) gelesen, nicht aus /// später aus den dort liegenden Dateien (journal.jsonl / &lt;runId&gt;.json) gelesen, nicht aus
/// dem Stream. Rein additiv – wirft nie (Telemetrie darf den Stream-Parser nicht stören). /// dem Stream. Rein additiv – wirft nie (Telemetrie darf den Stream-Parser nicht stören).
/// </summary> /// </summary>
private void TapWorkflowLaunch(string sessionId, string chainId, string resultContent) private void TapWorkflowLaunch(string sessionId, string chainId, string resultContent)
+4 -4
View File
@@ -77,13 +77,13 @@ public class WorkflowRunRef
/// <summary> /// <summary>
/// Liest die Workflow-Telemetrie aus den CLI-Transcript-Dateien. Zwei Quellen, je nach Phase: /// Liest die Workflow-Telemetrie aus den CLI-Transcript-Dateien. Zwei Quellen, je nach Phase:
/// das append-only journal.jsonl (live, während des Laufs) und die reiche wf_&lt;runId&gt;.json /// das append-only journal.jsonl (live, während des Laufs) und die reiche &lt;runId&gt;.json
/// (erst bei Abschluss). Alle Methoden sind defensiv und liefern null statt zu werfen. /// (erst bei Abschluss). Alle Methoden sind defensiv und liefern null statt zu werfen.
/// </summary> /// </summary>
public static class WorkflowTelemetryReader public static class WorkflowTelemetryReader
{ {
/// <summary> /// <summary>
/// Bevorzugt die reiche, fertige wf_&lt;runId&gt;.json (existiert nur nach Abschluss); /// Bevorzugt die reiche, fertige &lt;runId&gt;.json (existiert nur nach Abschluss);
/// fällt sonst auf das live journal.jsonl zurück. Liefert null, wenn nichts lesbar ist. /// fällt sonst auf das live journal.jsonl zurück. Liefert null, wenn nichts lesbar ist.
/// </summary> /// </summary>
public static WorkflowProgress Read(WorkflowRunRef run) public static WorkflowProgress Read(WorkflowRunRef run)
@@ -96,7 +96,7 @@ public static class WorkflowTelemetryReader
return null; return null;
} }
/// <summary>Reiche Telemetrie aus der wf_&lt;runId&gt;.json (am Laufende geschrieben).</summary> /// <summary>Reiche Telemetrie aus der &lt;runId&gt;.json (am Laufende geschrieben).</summary>
public static WorkflowProgress ReadCompleted(string richJsonPath) public static WorkflowProgress ReadCompleted(string richJsonPath)
{ {
if (string.IsNullOrEmpty(richJsonPath) || !File.Exists(richJsonPath)) return null; if (string.IsNullOrEmpty(richJsonPath) || !File.Exists(richJsonPath)) return null;
@@ -207,7 +207,7 @@ public static class WorkflowTelemetryReader
/// <summary> /// <summary>
/// Telemetrie eines dynamischen Workflows. Live (aus journal.jsonl): nur Status + Subagent-Zähler. /// Telemetrie eines dynamischen Workflows. Live (aus journal.jsonl): nur Status + Subagent-Zähler.
/// Abgeschlossen (aus wf_&lt;runId&gt;.json): zusätzlich Phasen, Per-Agent-Details (Tokens, Tool-Calls, /// Abgeschlossen (aus &lt;runId&gt;.json): zusätzlich Phasen, Per-Agent-Details (Tokens, Tool-Calls,
/// Dauer, Label, Phase) und Summen. Wird beim Chain-Finalize als JSON in chains.workflow_info /// Dauer, Label, Phase) und Summen. Wird beim Chain-Finalize als JSON in chains.workflow_info
/// persistiert und vom /workflow-status-Endpoint ausgeliefert. /// persistiert und vom /workflow-status-Endpoint ausgeliefert.
/// </summary> /// </summary>