Coverage for src / agent_contracts / runtime / __init__.py: 100%

1"""Runtime package - Agent execution and session management. 

2 

3This package provides: 

4- AgentRuntime: Unified execution engine for agent graphs 

5- StreamingRuntime: Node-by-node streaming execution 

6- RuntimeHooks: Customization points for app-specific logic 

7- SessionStore: Session persistence abstraction 

8- RequestContext / ExecutionResult: Typed I/O containers 

9- State operations: Helpers for immutable state manipulation 

10""" 

11from agent_contracts.runtime.context import RequestContext, ExecutionResult 

12from agent_contracts.runtime.hooks import RuntimeHooks, DefaultHooks 

13from agent_contracts.runtime.session import SessionStore, InMemorySessionStore 

14from agent_contracts.runtime.executor import AgentRuntime 

15from agent_contracts.runtime.state_ops import ( 

16 ensure_slices, 

17 merge_session, 

18 reset_internal_flags, 

19 create_base_state, 

20 copy_slice, 

21 update_slice, 

22 get_nested, 

23) 

24from agent_contracts.runtime.streaming import ( 

25 StreamEvent, 

26 StreamEventType, 

27 NodeExecutor, 

28 StreamingRuntime, 

29 create_status_event, 

30 create_progress_event, 

31 create_data_event, 

32) 

33 

34__all__ = [ 

35 # Context 

36 "RequestContext", 

37 "ExecutionResult", 

38 # Hooks 

39 "RuntimeHooks", 

40 "DefaultHooks", 

41 # Session 

42 "SessionStore", 

43 "InMemorySessionStore", 

44 # Executor 

45 "AgentRuntime", 

46 # Streaming 

47 "StreamEvent", 

48 "StreamEventType", 

49 "NodeExecutor", 

50 "StreamingRuntime", 

51 "create_status_event", 

52 "create_progress_event", 

53 "create_data_event", 

54 # State Operations 

55 "ensure_slices", 

56 "merge_session", 

57 "reset_internal_flags", 

58 "create_base_state", 

59 "copy_slice", 

60 "update_slice", 

61 "get_nested", 

62]