Function _build_connector

tests/splitwise/test_splitwise_connector.py:88–92 · view source on GitHub ↗

()

Source from the content-addressed store, hash-verified

86
87
88	def _build_connector() -> SplitwiseConnector:
89	connector = SplitwiseConnector(cfg=DummyCfg(), worker_queue=DummyWorkerQueue(), resource_manager=None)
90	if not hasattr(connector, "push_sockets"):
91	connector.push_sockets = {}
92	return connector
93
94
95	def test_serialize_deserialize_prefill_roundtrip_uses_paddle_tensor():

test_serialize_deserialize_prefill_roundtrip_uses_paddle_tensorFunction · 0.85

test_deserialize_message_rejects_short_framesFunction · 0.85

test_process_message_cache_sync_updates_state_and_cache_queueFunction · 0.85

test_check_decode_allocated_handles_finished_and_error_statesFunction · 0.85

test_send_cache_info_to_prefill_groups_by_addr_and_skips_errorFunction · 0.85

test_init_network_configures_router_and_pollerFunction · 0.85

test_get_push_socket_reuses_existing_and_handles_zmq_errorFunction · 0.85

test_get_push_socket_creates_and_configures_socketFunction · 0.85

test_send_message_serializes_and_sends_payloadFunction · 0.85

test_send_message_handles_missing_addr_and_errorsFunction · 0.85

test_send_splitwise_tasks_updates_roles_and_tracks_idsFunction · 0.85

test_send_splitwise_tasks_skips_missing_disaggregate_infoFunction · 0.85

SplitwiseConnectorClass · 0.90

DummyWorkerQueueClass · 0.85

DummyCfgClass · 0.70

no test coverage detected