-4

.tangled/workflows/workflow-amd64.yaml

··· 8 8 command: | 9 9 go mod download 10 10 11 11 - - name: run tests 12 12 - command: | 13 13 - make test 14 14 - 15 11 - name: build manager binary 16 12 command: | 17 13 make build

-4

.tangled/workflows/workflow-arm64.yaml

··· 8 8 command: | 9 9 go mod download 10 10 11 11 - - name: run tests 12 12 - command: | 13 13 - make test 14 14 - 15 11 - name: build manager binary 16 12 command: | 17 13 make build

+9 -9

cmd/runner/main.go

··· 15 15 16 16 // LogEvent represents a structured log event emitted by the runner. 17 17 type LogEvent struct { 18 18 - Kind string `json:"kind"` // "control" or "data" 19 19 - Event string `json:"event,omitempty"` // "start", "end" (for control events) 20 20 - StepID int `json:"step_id"` // 0-based step index 21 21 - StepName string `json:"step_name,omitempty"` // Step name 22 22 - WorkflowName string `json:"workflow_name"` // Workflow name for log separation 23 23 - Stream string `json:"stream,omitempty"` // "stdout" or "stderr" (for data events) 24 24 - Content string `json:"content,omitempty"` // Log line content (for data events) 25 25 - ExitCode *int `json:"exit_code,omitempty"` // Exit code (for control/end events) 26 26 - Timestamp string `json:"timestamp"` // ISO 8601 timestamp 18 18 + Kind string `json:"kind"` // "control" or "data" 19 19 + Event string `json:"event,omitempty"` // "start", "end" (for control events) 20 20 + StepID int `json:"step_id"` // 0-based step index 21 21 + StepName string `json:"step_name,omitempty"` // Step name 22 22 + WorkflowName string `json:"workflow_name"` // Workflow name for log separation 23 23 + Stream string `json:"stream,omitempty"` // "stdout" or "stderr" (for data events) 24 24 + Content string `json:"content,omitempty"` // Log line content (for data events) 25 25 + ExitCode *int `json:"exit_code,omitempty"` // Exit code (for control/end events) 26 26 + Timestamp string `json:"timestamp"` // ISO 8601 timestamp 27 27 } 28 28 29 29 func main() {

+9 -9

internal/engine/kubernetes_engine.go

··· 412 412 413 413 // LogEvent represents a structured log event from the runner binary 414 414 type LogEvent struct { 415 415 - Kind string `json:"kind"` // "control" or "data" 416 416 - Event string `json:"event,omitempty"` // "start", "end" (for control events) 417 417 - StepID int `json:"step_id"` // 0-based step index 418 418 - StepName string `json:"step_name,omitempty"` // Step name 419 419 - WorkflowName string `json:"workflow_name"` // Workflow name for log separation 420 420 - Stream string `json:"stream,omitempty"` // "stdout" or "stderr" (for data events) 421 421 - Content string `json:"content,omitempty"` // Log line content (for data events) 422 422 - ExitCode *int `json:"exit_code,omitempty"` // Exit code (for control/end events) 423 423 - Timestamp string `json:"timestamp"` // ISO 8601 timestamp 415 415 + Kind string `json:"kind"` // "control" or "data" 416 416 + Event string `json:"event,omitempty"` // "start", "end" (for control events) 417 417 + StepID int `json:"step_id"` // 0-based step index 418 418 + StepName string `json:"step_name,omitempty"` // Step name 419 419 + WorkflowName string `json:"workflow_name"` // Workflow name for log separation 420 420 + Stream string `json:"stream,omitempty"` // "stdout" or "stderr" (for data events) 421 421 + Content string `json:"content,omitempty"` // Log line content (for data events) 422 422 + ExitCode *int `json:"exit_code,omitempty"` // Exit code (for control/end events) 423 423 + Timestamp string `json:"timestamp"` // ISO 8601 timestamp 424 424 } 425 425 426 426 // parseLogs reads log lines as JSON events and sends them to WorkflowLogger