feat(function_pod): unify async_execute() concurrency paths (ITL-516)#224

Merged

eywalker merged 17 commits into

mainfrom

eywalker/itl-516-unify-functionpodasync_execute-and

Jul 11, 2026

Commits on Jul 9, 2026

docs(specs): add ITL-516 async_execute unification design spec

kurodo3[bot]
and
claude
committed

Commits on Jul 10, 2026

docs(specs): update ITL-516 spec with ephemeral path and _FunctionPodBase promotion

kurodo3[bot]
and
claude
committed
feat(function_pod): move async_execute to _FunctionPodBase with observer support

kurodo3[bot]
and
claude
committed
fix(function_pod): add pod_config to FunctionPodProtocol, clean up annotation quotes
kurodo3[bot]
committed
refactor(function_node): delegate no-DB async_execute to pod

kurodo3[bot]
and
claude
committed
fix(test_function_job_node): remove unused InMemoryArrowDatabase import

kurodo3[bot]
and
claude
committed
feat(function_node): redesign DB async_execute as 3-stage concurrent pipeline

kurodo3[bot]
and
claude
committed
fix(function_node): use ignore_missing=True in record_and_forward drop_meta_columns

kurodo3[bot]
and
claude
committed
docs(plans): add ITL-516 async_execute unification implementation plan

kurodo3[bot]
and
claude
committed
fix(function_node): strip correlation key from _NodeLabelObserver tag forwarding
kurodo3[bot]
committed
test(async_execute): remove orphan backpressure test, add dedicated pod-level coverage

kurodo3[bot]
and
claude
committed
fix(function_node): clean up input_store and cache filtered/crashed items in DB pipeline

kurodo3[bot]
and
claude
committed
Merge branch 'main' into eywalker/itl-516-unify-functionpodasync_execute-and
eywalker
authored
refactor(function_pod): use direct .pod_config access in WrappedFunctionPod

kurodo3[bot]
and
claude
committed

Commits on Jul 11, 2026