fogfish / iq / 20697924022

39%

main: 31%

Pull #87

github

Fix emit context propagation using EmitContextCapture pattern

Issue: Emit context set in workflow steps wasn't reaching StorageSink because Go contexts are immutable - workflow execution creates new contexts that don't propagate back.

Solution: Implemented EmitContextCapture pattern - a mutable struct passed via context that workflow steps can write to during execution.

Changes:
- Added EmitContextCapture struct and helpers (WithEmitCapture, GetEmitCapture) to compiler/context.go
- Updated all workflow steps (AgentStep, RouterStep, ForeachStep, RunStep) to capture emit in EmitContextCapture
- Modified Agent processor to create emit capture before workflow execution and store captured emit in document metadata
- Fixed Agent processor to preserve document Key from input to output
- Added workflow detection (workflowUsesEmit) and conditional sink selection (buildWithEmit) in agent command
- StorageSink reads emit from document metadata and applies prefix/counters to output path

Result: emit attribute now correctly controls output directory structure (e.g., emit: processed → output/processed/file.txt)

73 of 198 new or added lines in 9 files covered. (36.87%)

1655 of 4214 relevant lines covered (39.27%)

0.43 hits per line