From 6b99422010c5d437775e2bc07a676e5b48db994a Mon Sep 17 00:00:00 2001 From: Lennart Gulikers Date: Tue, 18 Aug 2026 15:54:24 +0200 Subject: [PATCH 1/3] fix(runtime): forward config as kwarg in ingress evaluate path Signed-off-by: Lennart Gulikers --- .../src/mas/library/standard/plugins/design_patterns/linear.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/library-standard/src/mas/library/standard/plugins/design_patterns/linear.py b/library-standard/src/mas/library/standard/plugins/design_patterns/linear.py index 6f43087f..2aaa8381 100644 --- a/library-standard/src/mas/library/standard/plugins/design_patterns/linear.py +++ b/library-standard/src/mas/library/standard/plugins/design_patterns/linear.py @@ -18,7 +18,7 @@ class DeterministicLinearPlugin(_DeterministicBase): plugin_id = "deterministic_linear@v1" mode = "linear" - def evaluate_next(self, q: QProduct, run: RunLedger, *, config: KernelConfig) -> list[EgressSymbol]: + def evaluate_next(self, q: QProduct, run: RunLedger, config: KernelConfig) -> list[EgressSymbol]: st = self._state() if not st.participants: return self._no_participants(q) From ce58e3ca38bc29455ded9f0020b11ed56f0e7266 Mon Sep 17 00:00:00 2001 From: Lennart Gulikers Date: Tue, 18 Aug 2026 16:00:23 +0200 Subject: [PATCH 2/3] fix(runtime): forward config as kwarg in ingress evaluate path Signed-off-by: Lennart Gulikers --- runtime/src/mas/runtime/kernel/ingress_step.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/runtime/src/mas/runtime/kernel/ingress_step.py b/runtime/src/mas/runtime/kernel/ingress_step.py index 52398451..266e9c56 100644 --- a/runtime/src/mas/runtime/kernel/ingress_step.py +++ b/runtime/src/mas/runtime/kernel/ingress_step.py @@ -94,7 +94,7 @@ def commit_engine_io_return( q.dp = DpState.EVALUATING apply_control_valid(q) coord_after_ingress(q) - return evaluate(q, run, config) + return evaluate(q, run, config=config) def apply_engine_io_return( @@ -203,6 +203,6 @@ def apply_engine_io_return( ) q.inflight_kind = "NONE" q.dp = DpState.EVALUATING - return evaluate(q, run, config) + return evaluate(q, run, config=config) return commit_engine_io_return(q, run, event, config=config, evaluate=evaluate) From 9d8d1360a7a7f04212077f93df42553267ce4a45 Mon Sep 17 00:00:00 2001 From: Lennart Gulikers Date: Tue, 18 Aug 2026 17:05:14 +0200 Subject: [PATCH 3/3] test(runtime): accept config kwarg in ingress evaluate stub Signed-off-by: Lennart Gulikers --- runtime/tests/test_parallel_tools.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/runtime/tests/test_parallel_tools.py b/runtime/tests/test_parallel_tools.py index 7bbeab41..80d9933c 100644 --- a/runtime/tests/test_parallel_tools.py +++ b/runtime/tests/test_parallel_tools.py @@ -102,7 +102,7 @@ def test_schedule_parallel_tools_egress_siblings_share_one_parent() -> None: text="ok", ) with runtime_binding(None, op): - apply_engine_io_return(q, run, event, config=config, evaluate=lambda *_: []) + apply_engine_io_return(q, run, event, config=config, evaluate=lambda *_, **__: []) ends = [ e