tests/test_local_jobs.py

_wait_for · function · L33-L39 — def _wait_for(predicate, timeout=10.0, interval=0.05)
manager · function · L43-L44 — def manager(tmp_path)
test_a_cancelled_job_really_stops · function · L47-L56 — def test_a_cancelled_job_really_stops(manager)
test_cancel_kills_the_child_the_shell_started · function · L59-L77 — def test_cancel_kills_the_child_the_shell_started(manager)
_is_alive · function · L80-L87 — def _is_alive(pid: int) -> bool
test_the_job_runs_in_its_own_process_group · function · L90-L98 — def test_the_job_runs_in_its_own_process_group(manager)
test_a_cancel_that_cannot_stop_the_job_reports_failure · function · L101-L131 — def test_a_cancel_that_cannot_stop_the_job_reports_failure(manager, monkeypatch)
test_cancelling_a_finished_job_is_a_no_op · function · L134-L139 — def test_cancelling_a_finished_job_is_a_no_op(manager)
test_cancel_confirms_a_child_that_ignores_sigterm · function · L147-L178 — def test_cancel_confirms_a_child_that_ignores_sigterm(manager, tmp_path)
test_cancel_reaches_the_group_when_the_leader_has_already_exited · function · L181-L210 — def test_cancel_reaches_the_group_when_the_leader_has_already_exited(manager, tmp_path)
test_cancelling_before_the_spawn_never_leaves_a_process_running · function · L213-L305 — def test_cancelling_before_the_spawn_never_leaves_a_process_running(manager, tmp_path)
gated_run · function · L225-L230 — def gated_run(self, job)
_SteppedLock · class · L249-L280 — class _SteppedLock
init · method · L256-L258 — def init(self)
acquire · method · L260-L261 — def acquire(self, a, *k)
release · method · L263-L264 — def release(self)
enter · method · L266-L268 — def enter(self)
exit · method · L270-L280 — def exit(self, *exc)
test_a_normal_job_still_completes_and_captures_output · function · L308-L314 — def test_a_normal_job_still_completes_and_captures_output(manager)
test_cancel_preserves_a_terminal_result_when_the_job_already_finished · function · L317-L349 — def test_cancel_preserves_a_terminal_result_when_the_job_already_finished( manager, tmp_path, monkeypatch )
already_exited · function · L330-L333 — def already_exited(proc, pgid=None)
test_cancel_does_not_mislabel_a_natural_finish_still_being_recorded · function · L352-L408 — def test_cancel_does_not_mislabel_a_natural_finish_still_being_recorded( manager, tmp_path, monkeypatch )
deferred_run · function · L381-L386 — def deferred_run()
test_a_truncated_job_log_says_so · function · L411-L438 — def test_a_truncated_job_log_says_so()
test_pruning_does_not_promote_a_running_job_to_newest · function · L450-L483 — def test_pruning_does_not_promote_a_running_job_to_newest()
test_a_cancel_cannot_rewrite_a_timeout_published_while_it_stopped · function · L502-L556 — def test_a_cancel_cannot_rewrite_a_timeout_published_while_it_stopped( tmp_path, monkeypatch )
_stop_then_publish · function · L539-L542 — def _stop_then_publish(proc, pgid=None)
test_an_ordinary_cancel_is_still_cancelled · function · L559-L580 — def test_an_ordinary_cancel_is_still_cancelled(tmp_path)
test_the_first_claim_wins_and_a_terminal_state_is_final · function · L583-L601 — def test_the_first_claim_wins_and_a_terminal_state_is_final(tmp_path)