Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/hpcaitech/ColossalAI
/ wait
Method
wait
colossalai/quantization/fp8.py:26–30 ·
view source on GitHub ↗
(self)
Source
from the content-addressed store, hash-verified
24
self.remain_ops = remain_ops
25
26
def
wait(self):
27
for
handle in self.handles:
28
handle.wait()
29
if
self.remain_ops:
30
self.remain_ops()
31
32
33
def
process_group_is_intranode(pg):
Callers
15
_compute_table_c
Method · 0.45
forward
Method · 0.45
backward
Method · 0.45
wait_chunks
Method · 0.45
wait_async_reduce
Method · 0.45
wait_all_gather_handle
Function · 0.45
sum_and_allgather
Function · 0.45
decompress
Function · 0.45
all_gather_fp8_ring
Function · 0.45
forward
Method · 0.45
forward
Method · 0.45
wait_for_new_requests
Method · 0.45
Calls
no outgoing calls
Tested by
8
check_4gpu
Function · 0.36
check_4gpu
Function · 0.36
check_4gpu
Function · 0.36
check_all2all
Function · 0.36
check_all2all_uneven
Function · 0.36
check_all_gather
Function · 0.36
check_reduce_scatter
Function · 0.36
check_all_reduce
Function · 0.36