Method add

verl/tests/single_controller/test_split_resource_pool.py:45–47 · view source on GitHub ↗

(self, data: DataProto)

Source from the content-addressed store, hash-verified

43
44	@register(dispatch_mode=Dispatch.DP_COMPUTE_PROTO)
45	def add(self, data: DataProto):
46	data.batch["a"] += self.rank + self.worker_id
47	return data
48
49
50	def test_split_resource_pool_with_split_size():

test_split_resource_pool_with_split_sizeFunction · 0.45

test_split_resource_pool_with_split_size_listFunction · 0.45

test_split_resource_pool_with_split_size_list_cross_nodesFunction · 0.45

test_split_resource_pool_with_split_twiceFunction · 0.45

no outgoing calls

no test coverage detected