tests/test_compute_task_centre.py

_Hub · class · L42-L47 — class _Hub
emitter · method · L43-L44 — def emitter(self, root_frame_id)
broadcast · method · L46-L47 — def broadcast(self, root_frame_id, event)
_Client · class · L50-L115 — class _Client
init · method · L51-L62 — def init(self, tmp_path)
session · method · L64-L65 — def session(self)
owner_key · method · L67-L68 — def owner_key(self, frame_id)
seed · method · L70-L88 — def seed(self, frame_id, , job_id, status, *fields)
get · method · L90-L91 — def get(self, path)
post · method · L93-L94 — def post(self, path, body=None)
_call · method · L96-L115 — def _call(self, method, path, body)
_send · function · L101-L103 — def _send(code, payload, ctype, extra=None)
client · function · L119-L120 — def client(tmp_path)
test_the_listing_has_no_way_to_reach_a_provider · function · L128-L160 — def test_the_listing_has_no_way_to_reach_a_provider()
test_opening_the_page_returns_the_record_and_says_it_did_not_poll · function · L163-L170 — def test_opening_the_page_returns_the_record_and_says_it_did_not_poll(client)
test_a_finished_job_is_still_listed · function · L173-L182 — def test_a_finished_job_is_still_listed(client)
test_one_session_cannot_enumerate_anothers_remote_work · function · L190-L199 — def test_one_session_cannot_enumerate_anothers_remote_work(client)
test_the_record_survives_a_restart · function · L202-L212 — def test_the_record_survives_a_restart(client, tmp_path)
test_unknown_is_not_rendered_as_a_failure · function · L220-L227 — def test_unknown_is_not_rendered_as_a_failure()
test_process_handles_and_cluster_paths_are_not_published · function · L230-L248 — def test_process_handles_and_cluster_paths_are_not_published()
test_a_harvest_is_summarised_rather_than_listed · function · L251-L265 — def test_a_harvest_is_summarised_rather_than_listed()
test_a_long_provider_message_is_clipped · function · L268-L272 — def test_a_long_provider_message_is_clipped()
test_refresh_is_a_post_because_it_harvests · function · L280-L290 — def test_refresh_is_a_post_because_it_harvests(client)
test_a_session_that_does_not_exist_is_not_a_blank_page · function · L293-L295 — def test_a_session_that_does_not_exist_is_not_a_blank_page(client)
_Proc · class · L303-L314 — class _Proc
init · method · L304-L308 — def init(self, returncode=0, stdout=b"", stderr=b"")
wait · method · L310-L311 — def wait(self, timeout=None)
kill · method · L313-L314 — def kill(self)
_submit_ssh_job · function · L317-L327 — def _submit_ssh_job(client, frame, monkeypatch)
test_cancel_is_a_post_because_it_signals_the_remote · function · L330-L337 — def test_cancel_is_a_post_because_it_signals_the_remote(client)
test_cancel_without_confirm_does_not_contact_the_remote · function · L341-L377 — def test_cancel_without_confirm_does_not_contact_the_remote(client, monkeypatch)
boom · function · L348-L350 — def boom(a, *k)
_Manager · class · L352-L355 — class _Manager
cancel · method · L353-L355 — def cancel(self, spec)
fake_build · function · L357-L359 — def fake_build(a, *k)
test_cancel_of_another_sessions_job_is_not_found_and_does_not_contact_the_remote · function · L380-L398 — def test_cancel_of_another_sessions_job_is_not_found_and_does_not_contact_the_remote( client, monkeypatch )
boom · function · L387-L389 — def boom(a, *k)
test_team_members_cannot_cancel_someone_elses_session · function · L401-L405 — def test_team_members_cannot_cancel_someone_elses_session()
test_confirmed_cancel_writes_cancelled_and_contacts_the_remote · function · L408-L429 — def test_confirmed_cancel_writes_cancelled_and_contacts_the_remote(client, monkeypatch)
fake_run · function · L413-L415 — def fake_run(argv, **kw)
test_unreachable_cancel_is_indeterminate_and_does_not_write_cancelled · function · L432-L454 — def test_unreachable_cancel_is_indeterminate_and_does_not_write_cancelled( client, monkeypatch )
boom · function · L439-L441 — def boom(a, *k)
test_unsupported_cancel_is_indeterminate · function · L458-L485 — def test_unsupported_cancel_is_indeterminate(client, monkeypatch)
_Manager · class · L463-L470 — class _Manager
cancel · method · L464-L470 — def cancel(self, spec)
test_a_natural_completion_race_returns_the_real_terminal_state · function · L489-L520 — def test_a_natural_completion_race_returns_the_real_terminal_state(client, monkeypatch)
_Manager · class · L494-L500 — class _Manager
cancel · method · L495-L500 — def cancel(self, spec)
test_cancel_after_restart_still_requires_an_explicit_confirm · function · L523-L564 — def test_cancel_after_restart_still_requires_an_explicit_confirm( client, tmp_path, monkeypatch )
boom · function · L537-L539 — def boom(a, *k)
fake_run · function · L551-L553 — def fake_run(argv, **kw)
test_page_load_and_ordinary_stop_never_post_cancel · function · L567-L605 — def test_page_load_and_ordinary_stop_never_post_cancel()
test_double_click_is_one_in_flight_request · function · L608-L619 — def test_double_click_is_one_in_flight_request()
test_a_confirmed_cancel_clears_the_earlier_unconfirmed_note · function · L622-L652 — def test_a_confirmed_cancel_clears_the_earlier_unconfirmed_note(client, monkeypatch)
unreachable · function · L629-L630 — def unreachable(a, *k)