Orchestrata Ultimate › Tests › Reference › orchestrator › test_pipeline_kernel
Tests reference — tests/orchestrator/test_pipeline_kernel.py
Module of tests/orchestrator, split out because the directory page would be too large.
Prose pending.
tests/orchestrator/test_pipeline_kernel.py
source · 21 tests · 699 lines
Tests for PipelineKernelClient (SPEC-003 US-004) — the in-process gateway
Covers: kernel.pipeline_events, orchestrator.pipeline_kernel, core.packet/ (package)
| Kind | Name | Line | Description |
|---|---|---|---|
| function | test_init_default_state |
35 | |
| function | test_connect_sets_connected_true |
46 | |
| function | test_close_cancels_pending_task |
58 | |
| function | test_close_leaves_completed_task_untouched |
72 | |
| function | test_send_packet_returns_false_when_not_connected |
88 | |
| function | test_send_packet_returns_false_for_unrelated_packet |
100 | |
| function | test_send_packet_dispatches_using_existing_thread_id |
124 | |
| function | test_send_packet_generates_thread_id_when_packet_has_none |
149 | |
| function | test_run_pipeline_emits_error_event_on_malformed_payload |
196 | Regression: the payload/runner setup used to run before the |
| function | test_run_pipeline_constructs_real_runner_and_emits_start_event |
231 | Real (non-LLM) coverage of the well-formed-payload path: a valid |
| function | test_run_pipeline_full_real_pipeline_emits_start_stage_complete_events |
280 | Full real pipeline run (real agents, real LLM calls — no doubles other |
| function | test_start_workflow_reports_failed_complete_event_on_exception |
357 | Regression: start_workflow used to spawn _execute_pipeline |
| function | test_emit_event_uses_broadcast_when_set |
406 | |
| function | test_emit_event_swallows_broadcast_exception |
431 | |
| function | test_emit_event_noop_when_no_broadcast |
442 | |
| function | test_emit_event_attributes_driver_when_unset |
452 | The defect: PipelineKernelClient is the SECOND production producer of |
| function | test_emit_event_preserves_explicit_driver |
477 | A caller-supplied driver (Phase 2 headless-harness producer) reaches |
| function | test_emit_event_does_not_mutate_caller_event |
498 | _emit_event resolves attribution on the OUTPUT payload only — |
| function | test_no_producer_emits_unattributed_driver_on_the_wire |
517 | Guard (item 5, behavioural half): every payload actually reaching a |
| function | test_cross_producer_driver_attribution_matches_for_same_event |
570 | Cross-producer invariant (item 6): both production producers resolve |
| function | test_every_production_payload_producer_resolves_driver |
636 | Structural guard (item 5, the half that actually generalizes): the set |