Add native async streaming overrides for core operators#70

Merged

eywalker merged 16 commits intodevfrom

claude/native-async-operators-4Ed8f

Mar 5, 2026

Commits on Mar 5, 2026

feat(operators): implement native streaming async_execute for all operators
claude
committed
docs(design): add async operator strategy discussion with Kafka/Flink comparison
claude
committed
fix(operators): add strict validation to streaming async_execute paths
claude
committed
docs: add async_execute plan for Node classes
claude
committed
docs(plan): comprehensive plan for process_packet/async_process_packet unification
claude
committed
docs(plan): address concurrent paths — route through async_process_packet, remove _execute_concurrent
claude
committed
feat: add async_execute to Node classes, unify process_packet interface
claude
committed
test(channels): add async pipeline → sync DB retrieval examples
claude
committed
test(pipeline): add Pipeline + @function_pod + async orchestrator integration test
claude
committed
fix(function_pod): route FunctionNode.async_execute through async_process_packet
claude
committed
test(pipeline): rewrite async integration test as single cohesive example
claude
committed
refactor(orchestrator): run persistent nodes, return None
claude
committed
fix(operators): address Copilot review comments on async execution
claude
committed
feat(join): restore streaming symmetric hash join with correct system tags
claude
committed
test(system-tags): add sync vs async system-tag equivalence tests
claude
committed
refactor(join): pass pipeline hashes to async_execute instead of storing state
claude
committed