Coverage for src / pipeline / __init__.py: 100%

1"""Pipeline stage modules for MalaOrchestrator decomposition. 

2 

3This package contains extracted pipeline stages that were previously inline 

4in the orchestrator. Each module represents a stage with explicit inputs/outputs 

5and can be tested in isolation. 

6 

7Modules: 

8 agent_session_runner: Agent session execution with SDK streaming 

9 epic_verification_coordinator: Epic closure verification with retry loop 

10 gate_runner: Quality gate checking with retry/fixer logic 

11 issue_execution_coordinator: Main loop coordination for issue processing 

12 run_coordinator: Run-level coordination and validation 

13""" 

14 

15from src.pipeline.agent_session_runner import ( 

16 AgentSessionConfig, 

17 AgentSessionInput, 

18 AgentSessionOutput, 

19 AgentSessionRunner, 

20 SessionCallbacks, 

21) 

22from src.pipeline.epic_verification_coordinator import ( 

23 EpicVerificationCallbacks, 

24 EpicVerificationConfig, 

25 EpicVerificationCoordinator, 

26) 

27from src.pipeline.gate_runner import ( 

28 GateRunner, 

29 GateRunnerConfig, 

30 PerIssueGateInput, 

31 PerIssueGateOutput, 

32) 

33from src.pipeline.issue_execution_coordinator import ( 

34 CoordinatorConfig, 

35 IssueExecutionCoordinator, 

36) 

37from src.pipeline.issue_finalizer import ( 

38 IssueFinalizeCallbacks, 

39 IssueFinalizeConfig, 

40 IssueFinalizeInput, 

41 IssueFinalizeOutput, 

42 IssueFinalizer, 

43) 

44from src.pipeline.run_coordinator import ( 

45 RunCoordinator, 

46 RunCoordinatorConfig, 

47 RunLevelValidationInput, 

48 RunLevelValidationOutput, 

49 SpecResultBuilder, 

50) 

51from src.pipeline.session_callback_factory import SessionCallbackFactory 

52 

53__all__ = [ 

54 "AgentSessionConfig", 

55 "AgentSessionInput", 

56 "AgentSessionOutput", 

57 "AgentSessionRunner", 

58 "CoordinatorConfig", 

59 "EpicVerificationCallbacks", 

60 "EpicVerificationConfig", 

61 "EpicVerificationCoordinator", 

62 "GateRunner", 

63 "GateRunnerConfig", 

64 "IssueExecutionCoordinator", 

65 "IssueFinalizeCallbacks", 

66 "IssueFinalizeConfig", 

67 "IssueFinalizeInput", 

68 "IssueFinalizeOutput", 

69 "IssueFinalizer", 

70 "PerIssueGateInput", 

71 "PerIssueGateOutput", 

72 "RunCoordinator", 

73 "RunCoordinatorConfig", 

74 "RunLevelValidationInput", 

75 "RunLevelValidationOutput", 

76 "SessionCallbackFactory", 

77 "SessionCallbacks", 

78 "SpecResultBuilder", 

79]