@@ -100,7 +100,7 @@ export function logPhase(params) {
100100 } ;
101101
102102 // Append optional secondary-mode telemetry fields when present (integers/boolean, DEC-65)
103- const TELEMETRY_FIELDS = [ 'context_size_at_spawn' , 'compact_events_count' , 'retry_429_count' , 'nested_session_completed' , 'pipeline' ] ;
103+ const TELEMETRY_FIELDS = [ 'context_size_at_spawn' , 'compact_events_count' , 'retry_429_count' , 'nested_session_completed' ] ;
104104 for ( const f of TELEMETRY_FIELDS ) {
105105 if ( f in params ) entry [ f ] = params [ f ] ;
106106 }
@@ -134,7 +134,6 @@ if (import.meta.url === pathToFileURL(process.argv[1]).href) {
134134 const durationRaw = argValue ( '--duration-ms' ) ;
135135 const fallbackRaw = argValue ( '--fallback-reason' ) ;
136136 const implModelTag = argValue ( '--impl-model-tag' ) ;
137- const pipelineArg = argValue ( '--pipeline' ) ;
138137 const logPathArg = argValue ( '--log-path' ) ;
139138
140139 // --log-path overrides default log path (useful for testing without internal _setLogPath)
@@ -144,7 +143,7 @@ if (import.meta.url === pathToFileURL(process.argv[1]).href) {
144143 const fallbackReason = ( fallbackRaw === '' || fallbackRaw === 'null' ) ? null : fallbackRaw ;
145144
146145 try {
147- const phaseParams = {
146+ logPhase ( {
148147 trace_id : traceId ,
149148 story_id : storyId ,
150149 phase,
@@ -153,9 +152,7 @@ if (import.meta.url === pathToFileURL(process.argv[1]).href) {
153152 duration_ms : Number ( durationRaw ) ,
154153 fallback_reason : fallbackReason ,
155154 impl_model_tag : implModelTag ,
156- } ;
157- if ( pipelineArg !== undefined ) phaseParams . pipeline = pipelineArg ;
158- logPhase ( phaseParams ) ;
155+ } ) ;
159156 process . stdout . write ( formatPhaseStdout ( phase , provider , model , fallbackReason ) ) ;
160157 } catch ( err ) {
161158 process . stderr . write ( `runtime-routing-logger: ${ err . message } \n` ) ;
0 commit comments