Status: IN
Pipeline execution is pull-based via nested Python generators; records flow only when the terminal consumer iterates, and stages interleave execution without threads
Source: entries/2026/05/29/batch-word-count-pipeline.md
JSON