Orchestrata Ultimate › Tests › Reference › kernel › test_pipeline
Tests reference — tests/kernel/test_pipeline.py
Module of tests/kernel, split out because the directory page would be too large.
Prose pending.
tests/kernel/test_pipeline.py
source · 33 tests · 541 lines
Tests for kernel.pipeline.
Covers: kernel.pipeline, plugin.registries, core.graph/ (package), core.packet/ (package)
| Kind | Name | Line | Description |
|---|---|---|---|
| class | TestPipelineRunnerConstruction |
43 | |
| method | TestPipelineRunnerConstruction.test_init |
44 | |
| method | TestPipelineRunnerConstruction.test_get_graph_client |
50 | |
| class | TestPipelineRunnerInterface |
57 | Structural tests merged from the deleted test_pipeline_runner.py. |
| method | TestPipelineRunnerInterface.test_methods_exist |
60 | |
| method | TestPipelineRunnerInterface.test_boot_registers_volks |
70 | boot() registers all 11 volks (RUL-023 / backlog 501: senior_dev |
| method | TestPipelineRunnerInterface.test_get_status_returns_lines |
93 | get_status() returns a bracketed status line per volk. |
| method | TestPipelineRunnerInterface.test_status_report_structured |
102 | status_report() returns one structured dict per volk for the orchestrator. |
| method | TestPipelineRunnerInterface.test_status_report_reflects_busy_thread |
123 | A volk holding a current_thread is reported busy. |
| method | TestPipelineRunnerInterface.test_human_handler_appends_and_returns_none |
132 | _human_handler stores the packet in the inbox and returns None. |
| class | TestPluginVolkStatusSurface |
152 | A plugin-registered volk must not crash the roster/status paths. |
| method | TestPluginVolkStatusSurface.test_status_report_includes_plugin_volk |
176 | |
| method | TestPluginVolkStatusSurface.test_get_status_lines_include_plugin_volk |
187 | |
| method | TestPluginVolkStatusSurface.test_review_plugin_volk_does_not_crash |
193 | |
| class | TestCapabilityRouting |
203 | Capability-routed volk mesh (PipelineEscalationMixin.resolve_capability / |
| method | TestCapabilityRouting.test_resolve_builtin_capabilities |
208 | |
| method | TestCapabilityRouting.test_resolve_plugin_declared_capability |
219 | |
| method | TestCapabilityRouting.test_apply_capability_routing_rewrites_to_agent |
235 | |
| method | TestCapabilityRouting.test_apply_capability_routing_noop_without_capability |
248 | |
| method | TestCapabilityRouting.test_apply_capability_routing_unknown_capability_preserves_target |
256 | |
| class | TestDecisionCapture |
270 | The kernel _collect_decisions hook persists a packet's decisions to |
| method | TestDecisionCapture.test_collect_decisions_persists_made_decision |
274 | |
| class | TestPluginVolkAdapterProcess |
308 | _PluginVolkAdapter.process bridges sync AND async plugin handlers. |
| method | TestPluginVolkAdapterProcess.test_process_returns_sync_handler_result_directly |
316 | |
| method | TestPluginVolkAdapterProcess.test_process_awaits_async_handler_result |
331 | |
| method | TestPluginVolkAdapterProcess.test_get_output_display_placeholder |
350 | |
| method | TestPluginVolkAdapterProcess.test_set_postman_stores_reference |
354 | |
| class | TestRegisterPluginVolksStaleAlias |
378 | |
| method | TestRegisterPluginVolksStaleAlias.test_stale_alias_is_skipped_without_crashing |
379 | |
| class | TestReviewVolkNoDisplay |
387 | review_volk() for a volk lacking a callable get_output_display. |
| method | TestReviewVolkNoDisplay.test_review_volk_without_output_display |
390 | |
| class | TestPipelineRunnerResume |
400 | resume() reuses checkpointed stage outputs to re-dispatch after the |
| method | TestPipelineRunnerResume.test_resume_with_no_checkpoint_returns_none |
405 | |
| method | TestPipelineRunnerResume.test_resume_already_complete_pipeline_returns_thread_id_without_dispatch |
410 | U:Cp is the last stage in _RESUME_ORDER — nothing left downstream. |
| method | TestPipelineRunnerResume.test_resume_next_target_not_registered_returns_thread_id_without_dispatch |
429 | An unbooted runner has no volks; the mesh order still names U:BA as |
| method | TestPipelineRunnerResume.test_resume_dispatches_prior_output_to_next_stage |
443 | A checkpointed U:Cx output is carried forward and routed to U:BA |
| class | TestLatestCheckpointHelper |
468 | _latest_checkpoint picks the furthest-along completed stage. |
| method | TestLatestCheckpointHelper.test_picks_furthest_along_known_stage |
471 | |
| method | TestLatestCheckpointHelper.test_falls_back_to_first_entry_for_unknown_stage |
481 | |
| class | TestResumeNextTargetHelper |
489 | _resume_next_target maps a completed stage to its successor. |
| method | TestResumeNextTargetHelper.test_returns_the_following_stage |
492 | |
| method | TestResumeNextTargetHelper.test_unknown_stage_returns_none |
497 | |
| method | TestResumeNextTargetHelper.test_last_stage_in_order_returns_none |
501 | |
| class | TestArtifactSyncCapture |
506 | The kernel _collect_artifacts hook writes provenance to the semantic |
| method | TestArtifactSyncCapture.test_collect_artifacts_syncs_provenance_to_kg |
510 |