refactor: slim node protocols, observer injection, async orchestrator alignment (PLT-922)#86

Merged

eywalker merged 23 commits intodevfrom

eywalker/plt-922-refactor-asyncpipelineorchestrator-to-use-node-protocols-and

Mar 15, 2026

Commits on Mar 15, 2026

docs(specs): add async orchestrator refactor design spec (PLT-922)

eywalker
and
claude
committed
docs(specs): address spec review feedback for PLT-922

eywalker
and
claude
committed
docs(plans): add async orchestrator refactor implementation plan (PLT-922)

eywalker
and
claude
committed
refactor(protocols): slim node protocols to execute + async_execute with observer (PLT-922)

eywalker
and
claude
committed
refactor(protocols): remove AsyncExecutableProtocol (PLT-922)

eywalker
and
claude
committed
feat(source-node): add execute() with observer injection (PLT-922)

eywalker
and
claude
committed
refactor(source-node): tighten async_execute signature + observer (PLT-922)

eywalker
and
claude
committed
feat(function-node): add observer injection to execute() (PLT-922)

eywalker
and
claude
committed
refactor(function-node): tighten async_execute signature + observer (PLT-922)

eywalker
and
claude
committed
feat(operator-node): add observer + cache check to execute() (PLT-922)

eywalker
and
claude
committed
feat(operator-node): add observer to async_execute() (PLT-922)

eywalker
and
claude
committed
fix(tests): update callers for tightened FunctionNode.async_execute signature (PLT-922)

eywalker
and
claude
committed
refactor(sync-orchestrator): delegate to node.execute(), remove per-packet logic (PLT-922)

eywalker
and
claude
committed
refactor(async-orchestrator): use node protocols, graph interface, OrchestratorResult (PLT-922)

eywalker
and
claude
committed
refactor(pipeline): update run() to pass graph to orchestrators, remove _run_async (PLT-922)

eywalker
and
claude
committed
test(orchestrator): add materialize_results tests (PLT-922)

eywalker
and
claude
committed
test(async-orchestrator): add fan-out, terminal, and error propagation tests (PLT-922)

eywalker
and
claude
committed
fix(review): type-safe observer, robust writer, terminal drain, operator ordering (PLT-922)

eywalker
and
claude
committed
test(observer): add observer injection tests for both orchestrators (PLT-922)

eywalker
and
claude
committed
fix(review): address Copilot PR review feedback (PLT-922)

eywalker
and
claude
committed
docs: add PR review response workflow to CLAUDE.md and .zed/rules

eywalker
and
claude
committed
docs: require Linear issue linking for all work

eywalker
and
claude
committed
docs: add branch naming and multi-issue PR tracking guidelines

eywalker
and
claude
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

refactor: slim node protocols, observer injection, async orchestrator alignment (PLT-922)#86

refactor: slim node protocols, observer injection, async orchestrator alignment (PLT-922)#86
eywalker merged 23 commits intodevfrom
eywalker/plt-922-refactor-asyncpipelineorchestrator-to-use-node-protocols-and

Commits on Mar 15, 2026

docs(specs): add async orchestrator refactor design spec (PLT-922)

docs(specs): address spec review feedback for PLT-922

docs(plans): add async orchestrator refactor implementation plan (PLT-922)

refactor(protocols): slim node protocols to execute + async_execute with observer (PLT-922)

refactor(protocols): remove AsyncExecutableProtocol (PLT-922)

feat(source-node): add execute() with observer injection (PLT-922)

refactor(source-node): tighten async_execute signature + observer (PLT-922)

feat(function-node): add observer injection to execute() (PLT-922)

refactor(function-node): tighten async_execute signature + observer (PLT-922)

feat(operator-node): add observer + cache check to execute() (PLT-922)

feat(operator-node): add observer to async_execute() (PLT-922)

fix(tests): update callers for tightened FunctionNode.async_execute signature (PLT-922)

refactor(sync-orchestrator): delegate to node.execute(), remove per-packet logic (PLT-922)

refactor(async-orchestrator): use node protocols, graph interface, OrchestratorResult (PLT-922)

refactor(pipeline): update run() to pass graph to orchestrators, remove _run_async (PLT-922)

test(orchestrator): add materialize_results tests (PLT-922)

test(async-orchestrator): add fan-out, terminal, and error propagation tests (PLT-922)

fix(review): type-safe observer, robust writer, terminal drain, operator ordering (PLT-922)

test(observer): add observer injection tests for both orchestrators (PLT-922)

fix(review): address Copilot PR review feedback (PLT-922)

docs: add PR review response workflow to CLAUDE.md and .zed/rules

docs: require Linear issue linking for all work

docs: add branch naming and multi-issue PR tracking guidelines