Orchestrata Ultimate › Tests › Reference › kernel › test_pipeline_event_forwarder
Tests reference — tests/kernel/test_pipeline_event_forwarder.py
Module of tests/kernel, split out because the directory page would be too large.
Prose pending.
tests/kernel/test_pipeline_event_forwarder.py
source · 11 tests · 263 lines
Covers: gateway.server, kernel.pipeline_events
| Kind | Name | Line | Description |
|---|---|---|---|
| function | test_event_bus_init_and_on_are_type_hinted |
43 | |
| function | test_decode_pipeline_event_handles_bytes_and_json |
55 | |
| function | test_decode_pipeline_event_bad_json_falls_back_to_empty |
68 | |
| function | test_decode_pipeline_event_iteration_cast_to_int |
73 | G2 path-parity fix: the forwarder decoder casts iteration to int so |
| function | test_decode_pipeline_event_missing_iteration_falls_back_to_zero |
82 | |
| function | test_decode_pipeline_event_unparseable_iteration_falls_back_to_zero |
88 | |
| function | test_forward_writes_per_thread_and_global_streams |
99 | |
| function | test_forward_skips_per_thread_stream_when_no_thread_id |
122 | A boot event (empty thread_id) goes only to the global stream. |
| function | test_forward_includes_driver_field |
140 | VolkDriver Phase 0 (P0-A / A2 TRAP TEST, C1): an event emitted |
| function | test_pump_broadcasts_per_thread_topic |
192 | |
| function | test_pump_returns_zero_when_no_new_events |
241 |