Skip to content
Draft
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
test(execution): cover adapter to kernel capability flow
  • Loading branch information
JoTalbot committed Aug 25, 2026
commit f6eca0f33df9b41c5fa77776c7f4ac011b20f035
43 changes: 43 additions & 0 deletions tests/test_execution_kernel_e2e.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
from aios_core.execution.kernel import ExecutionKernel
from aios_core.execution.models import Observation
from aios_core.execution.orchestrator_adapter import execute_tool_step


class FakeCapabilities:
def __init__(self):
self.calls = []

def execute(self, *, capability_name, input_data, agent_id, authority):
self.calls.append(
{
"capability_name": capability_name,
"input_data": input_data,
"agent_id": agent_id,
"authority": authority,
}
)
return {"success": True, "result": {"echo": input_data["value"]}}


def test_tool_adapter_reaches_kernel_and_capability_engine():
capabilities = FakeCapabilities()
kernel = ExecutionKernel(capabilities)

observation = execute_tool_step(
kernel,
task_id="task-42",
agent_id="agent-7",
authority="system",
params={"capability": "echo", "arguments": {"value": "hello"}},
)

assert isinstance(observation, Observation)
assert observation.success is True
assert observation.result == {"echo": "hello"}
assert len(capabilities.calls) == 1
assert capabilities.calls[0] == {
"capability_name": "echo",
"input_data": {"value": "hello"},
"agent_id": "agent-7",
"authority": "system",
}
Loading