libmuscle.test.conftest module

libmuscle.test.conftest.connected_port_manager(port_manager, declared_ports, mock_ports)[source]
libmuscle.test.conftest.core(hwthread_id: int) Core[source]

Helper that defines a core with the given core and hwthread id.

libmuscle.test.conftest.declared_ports()[source]
libmuscle.test.conftest.guard() APIGuard[source]
libmuscle.test.conftest.message() Message[source]
libmuscle.test.conftest.message2() Message[source]
libmuscle.test.conftest.mock_ports()[source]
libmuscle.test.conftest.mocked_mmp_client()[source]
libmuscle.test.conftest.mocked_profiler()[source]
libmuscle.test.conftest.on_node_resources(node_name: str, cores: int | Set[int]) OnNodeResources[source]

Helper that defines resources on a node from the name and a CPU core.

libmuscle.test.conftest.profile_data() Tuple[ProfileTimestamp, ProfileTimestamp, ProfileTimestamp][source]
libmuscle.test.conftest.profiler_comm_int_10ms()[source]
libmuscle.test.conftest.resources(node_resources: Dict[str, List[Core]]) Resources[source]

Helper that defines a Resources from a dict.