Orchestrata Ultimate › Tests › Reference › orchestrator › test_pipeline_runner_checkpoint
Tests reference — tests/orchestrator/test_pipeline_runner_checkpoint.py
Module of tests/orchestrator, split out because the directory page would be too large.
Prose pending.
tests/orchestrator/test_pipeline_runner_checkpoint.py
source · 16 tests · 519 lines
Tests for the W3.1 checkpoint + KG absorption into orchestrator.PipelineRunner
Covers: core.redis_factory, kernel.pipeline_checkpoint, kernel.pipeline_kg, orchestrator.pipeline_router, orchestrator.pipeline_runner, core.packet/ (package)
| Kind | Name | Line | Description |
|---|---|---|---|
| function | test_pipeline_runner_is_a_pipeline_kg_mixin |
39 | W3.1 Part 2: PipelineKGMixin is mixed into the class bases. |
| function | test_artifacts_attribute_aliases_artifact_store |
50 | PipelineKGMixin.sync_artifacts_to_kg reads self.artifacts (the |
| function | test_create_checkpoint_returns_real_store_when_redis_available |
61 | |
| function | test_create_checkpoint_degrades_to_none_on_bad_redis_config |
67 | A misconfigured REDIS_PORT makes create_sync_redis() raise ValueError |
| function | test_run_stage_checkpoint_readable_via_independent_cli_style_store |
80 | After a stage RESOLVES, the checkpoint it saves must be readable |
| function | test_run_stage_checkpoint_save_is_noop_when_checkpoint_unavailable |
119 | When the checkpoint store failed to construct (checkpoint is None), |
| function | test_resume_with_no_checkpoint_reports_failed_with_no_stages |
150 | |
| function | test_resume_picks_up_mid_pipeline_only_remaining_stage_runs |
161 | Seed a checkpoint for the "review" work type's first stage (U:Qa), |
| function | test_resume_stops_and_reports_failed_when_remaining_stage_fails |
215 | If the stage that follows the last checkpointed one fails to |
| function | test_resume_when_all_stages_already_checkpointed_runs_nothing |
251 | Every stage in the derived order is already checkpointed — resume() |
| function | test_resume_without_explicit_work_type_uses_stored_value |
284 | A resume() call with NO work_type argument must recover the |
| function | test_resume_falls_back_to_feature_default_when_work_type_not_persisted |
330 | Checkpoints written before work_type tracking existed simply never |
| function | test_run_stage_injects_kg_context_for_inject_subject_not_for_other |
367 | The inject_for_subject adapter fires at the exact _run_stage call |
| function | test_inject_for_subject_direct_no_injection_for_unlisted_subject |
444 | Direct unit coverage of the shared adapter: a subject outside |
| function | test_run_completes_and_syncs_kg_without_raising |
461 | run() calls _sync_run_to_kg at completion — this must never raise |
| function | test_sync_run_to_kg_direct_call_swallows_and_handles_decisions |
484 | Directly exercises _sync_run_to_kg with a synthetic PipelineResult |