tests/test_cell_execution_service.py

• Harness · class · L17-L102 — class Harness
• init · method · L18-L32 — def init(self) -> None
• ports · method · L34-L45 — def ports(self) -> CellExecutionPorts
• prepare_language · method · L47-L49 — def prepare_language(self, session, language)
• kernel_id · method · L51-L53 — def kernel_id(self, session, language)
• snapshot · method · L55-L57 — def snapshot(self, workspace)
• protect_versions · method · L59-L60 — def protect_versions(self, session)
• safety_refusal · method · L62-L68 — def safety_refusal(self, session, code, origin): # Takes the session as well as the cell: the biosecurity screener # judges a trajectory, not one cell, and a port that saw only the cell # could never run it — which is why the Web path ran the static # classifier alone while the CLI ran both.
• run · method · L70-L83 — def run(self, session, request, cell_id, on_chunk, lease)
• capture · method · L85-L92 — def capture( self, session, index, cell_id, before, emit, language, artifact_receipts )
• emit_artifact_step · method · L94-L98 — def emit_artifact_step( self, session, title, artifacts, emit, environment, language )
• record_cell · method · L100-L102 — def record_cell(self, **record)
• _session · function · L105-L112 — def _session(tmp_path)
• test_readiness_admission_precedes_cell_revision_attempt_and_runtime · function · L116-L164 — def test_readiness_admission_precedes_cell_revision_attempt_and_runtime( tmp_path, origin )
• refuse · function · L123-L130 — def refuse(_session, request)
• allocate · function · L132-L134 — def allocate(*_args)
• cell_id · function · L136-L138 — def cell_id()
• test_malformed_capture_lease_fails_before_cell_identity_or_admission · function · L167-L199 — def test_malformed_capture_lease_fails_before_cell_identity_or_admission(tmp_path)
• admit · function · L173-L174 — def admit(_session, _request)
• cell_id · function · L176-L178 — def cell_id()
• test_skill_network_admission_runs_before_kernel_run · function · L202-L226 — def test_skill_network_admission_runs_before_kernel_run(tmp_path, monkeypatch)
• _admit · function · L206-L215 — def _admit(**kwargs)
• test_submit_output_does_not_skip_capture_or_execution_log · function · L229-L302 — def test_submit_output_does_not_skip_capture_or_execution_log(tmp_path)
• test_the_saving_step_names_the_cell_s_own_runtime · function · L309-L327 — def test_the_saving_step_names_the_cell_s_own_runtime(tmp_path, language, expected)
• test_bind_lineage_records_host_side_reads · function · L330-L355 — def test_bind_lineage_records_host_side_reads(tmp_path)
• bind · function · L339-L343 — def bind(session, request, before, capture, cell_id)
• test_missing_runtime_read_observation_never_falls_back_to_source · function · L358-L376 — def test_missing_runtime_read_observation_never_falls_back_to_source(tmp_path)
• bind · function · L362-L364 — def bind(_session, _request, _before, capture, _cell_id)
• test_lineage_binding_failure_refuses_to_publish_a_successful_cell · function · L379-L400 — def test_lineage_binding_failure_refuses_to_publish_a_successful_cell(tmp_path)
• fail_binding · function · L386-L387 — def fail_binding(*_args)
• test_live_and_finished_events_use_the_exact_persistent_generation · function · L403-L440 — def test_live_and_finished_events_use_the_exact_persistent_generation(tmp_path)
• Kernel · class · L408-L413 — class Kernel
• is_alive · method · L409-L410 — def is_alive(self)
• shutdown · method · L412-L413 — def shutdown(self)
• test_live_cell_output_is_bounded_once_for_notebook_and_activity · function · L443-L482 — def test_live_cell_output_is_bounded_once_for_notebook_and_activity( monkeypatch, tmp_path )
• run · function · L449-L457 — def run(session, request, cell_id, on_chunk, lease)
• test_finished_event_is_bounded_without_mutating_result_or_record · function · L485-L513 — def test_finished_event_is_bounded_without_mutating_result_or_record( monkeypatch, tmp_path )
• test_interrupted_result_wins_over_its_error_text_in_notebook_event · function · L516-L538 — def test_interrupted_result_wins_over_its_error_text_in_notebook_event(tmp_path)
• test_protocol_only_submit_is_audited_without_streaming_a_notebook_cell · function · L541-L571 — def test_protocol_only_submit_is_audited_without_streaming_a_notebook_cell(tmp_path)
• test_cell_projection_labels_are_forwarded_to_the_immutable_record · function · L574-L594 — def test_cell_projection_labels_are_forwarded_to_the_immutable_record(tmp_path)
• test_safety_refusal_is_a_logged_soft_error_without_runtime_or_capture · function · L597-L625 — def test_safety_refusal_is_a_logged_soft_error_without_runtime_or_capture(tmp_path)
• test_missing_r_runtime_is_a_logged_soft_error · function · L628-L643 — def test_missing_r_runtime_is_a_logged_soft_error(tmp_path)
• test_r_protocol_exception_shuts_down_only_the_executing_lease · function · L646-L693 — def test_r_protocol_exception_shuts_down_only_the_executing_lease(tmp_path)
• RKernel · class · L651-L661 — class RKernel
• init · method · L652-L654 — def init(self)
• is_alive · method · L656-L657 — def is_alive(self)
• shutdown · method · L659-L661 — def shutdown(self)
• test_r_exception_from_stale_lease_does_not_close_replacement · function · L696-L735 — def test_r_exception_from_stale_lease_does_not_close_replacement(tmp_path)
• RKernel · class · L701-L712 — class RKernel
• init · method · L702-L705 — def init(self, name)
• is_alive · method · L707-L708 — def is_alive(self)
• shutdown · method · L710-L712 — def shutdown(self)
• replace_during_run · function · L718-L719 — def replace_during_run(active_session, request, lease)
• test_non_streaming_cell_still_captures_and_records_without_activity_step · function · L738-L754 — def test_non_streaming_cell_still_captures_and_records_without_activity_step(tmp_path)
• test_attempt_is_allocated_before_prepare_and_completes_all_milestones · function · L757-L799 — def test_attempt_is_allocated_before_prepare_and_completes_all_milestones(tmp_path)
• test_worker_exception_still_finishes_allocated_attempt · function · L802-L850 — def test_worker_exception_still_finishes_allocated_attempt(tmp_path)
• test_watchdog_hard_cancel_is_durably_classified_as_cancelled · function · L853-L894 — def test_watchdog_hard_cancel_is_durably_classified_as_cancelled(tmp_path)
• test_a_cancellation_during_preparation_finishes_the_cell_without_running_it · function · L897-L950 — def test_a_cancellation_during_preparation_finishes_the_cell_without_running_it( tmp_path, )
• prepare_during_which_shutdown_lands · function · L909-L912 — def prepare_during_which_shutdown_lands(session, language)
• test_attempt_milestone_write_failure_still_finalizes_attempt · function · L953-L993 — def test_attempt_milestone_write_failure_still_finalizes_attempt(tmp_path)
• _boom · function · L960-L961 — def _boom(_attempt_id)
• test_worker_failure_is_recorded_once_and_retry_uses_a_new_cell_id · function · L996-L1030 — def test_worker_failure_is_recorded_once_and_retry_uses_a_new_cell_id(tmp_path)
• test_record_failure_is_not_misclassified_as_capture_failure · function · L1033-L1074 — def test_record_failure_is_not_misclassified_as_capture_failure(tmp_path)
• fail_record · function · L1037-L1040 — def fail_record(**record)
• test_a_dead_worker_does_not_publish_its_stderr · function · L1077-L1104 — def test_a_dead_worker_does_not_publish_its_stderr()
• test_a_timeout_still_says_the_kernel_was_reset · function · L1107-L1119 — def test_a_timeout_still_says_the_kernel_was_reset()
• test_a_watchdog_hard_cancel_is_projected_as_cancellation_not_timeout · function · L1122-L1136 — def test_a_watchdog_hard_cancel_is_projected_as_cancellation_not_timeout()
• test_a_bootstrap_failure_after_reset_does_not_claim_cluster_work_continues · function · L1139-L1152 — def test_a_bootstrap_failure_after_reset_does_not_claim_cluster_work_continues()