Orchestrata Ultimate › Tests › Reference › kernel › test_pipeline_checkpoint
Tests reference — tests/kernel/test_pipeline_checkpoint.py
Module of tests/kernel, split out because the directory page would be too large.
Prose pending.
tests/kernel/test_pipeline_checkpoint.py
source · 23 tests · 415 lines
Covers: kernel.pipeline_artifacts, kernel.pipeline_checkpoint, kernel.pipeline_events, kernel.pipeline_session, core.packet/ (package)
| Kind | Name | Line | Description |
|---|---|---|---|
| function | test_save_and_get_stage_in_memory |
70 | |
| function | test_completed_stages_and_resume_state |
79 | |
| function | test_save_requires_thread_and_stage |
92 | |
| function | test_large_output_spills_to_disk |
100 | |
| function | test_clear_removes_thread |
112 | |
| function | test_save_and_get_via_real_redis |
126 | A fresh checkpoint with the same Redis reads back a prior save (resume). |
| function | test_large_output_via_redis_uses_pointer |
142 | |
| function | test_save_stage_survives_redis_failure |
168 | Redis write failure is logged and swallowed; memory mirror still works. |
| function | test_get_stage_via_broken_redis_returns_none |
182 | A fresh instance (no memory) with a failing Redis degrades to None. |
| function | test_completed_stages_with_broken_redis_falls_back_to_memory |
191 | hkeys() failure is swallowed; the memory-derived stage set still returns. |
| function | test_clear_survives_redis_delete_failure |
203 | delete() failure on Redis is logged; the memory mirror is cleared anyway. |
| function | test_get_stage_returns_none_when_never_checkpointed_via_redis |
214 | A missing hash field (hget -> None) is a clean miss, not an error. |
| function | test_get_stage_resolves_raw_bytes_from_redis |
223 | Some Redis clients return bytes (no decode_responses); handle both. |
| function | test_get_stage_returns_none_on_corrupt_json_in_redis |
249 | A hash field holding non-JSON garbage is treated as a miss, not a crash. |
| function | test_get_stage_returns_none_on_missing_blob_file |
260 | A pointer to a blob file that no longer exists degrades to None. |
| function | test_get_stage_returns_none_on_corrupt_blob_file |
272 | A blob file that exists but holds invalid JSON degrades to None. |
| function | test_clear_removes_disk_blob_files |
286 | clear() deletes the spilled blob file, not just the Redis/memory entry. |
| function | test_clear_ignores_unlink_errors_on_readonly_blob_dir |
299 | A blob file that cannot be unlinked (dir not writable) is skipped, not raised. |
| function | test_kernel_hook_checkpoints_transition |
326 | |
| function | test_stage_checkpoint_dataclass_defaults |
344 | |
| function | test_stored_work_type_returns_persisted_value |
352 | A stage checkpointed WITH a work_type is recoverable via |
| function | test_stored_work_type_returns_none_for_legacy_record_without_field |
367 | A checkpoint record persisted BEFORE work_type tracking existed has |
| function | test_stored_work_type_survives_fresh_instance_via_redis |
390 | stored_work_type() must resolve from the Redis-loaded record path |