Name	Size	Mode	Actions
backward_compatibility.cpython-36.pyc	474	0644	editdlrm
dataloader.cpython-36.pyc	24145	0644	editdlrm
dataloader_experimental.cpython-36.pyc	4284	0644	editdlrm
dataset.cpython-36.pyc	17051	0644	editdlrm
distributed.cpython-36.pyc	4851	0644	editdlrm
graph.cpython-36.pyc	1266	0644	editdlrm
sampler.cpython-36.pyc	9012	0644	editdlrm
sharding.cpython-36.pyc	1011	0644	editdlrm
_decorator.cpython-36.pyc	6031	0644	editdlrm
_typing.cpython-36.pyc	9852	0644	editdlrm
__init__.cpython-36.pyc	1477	0644	editdlrm

3 úEg7ã@sdd
lZ
dd„Zd
S)éNcs~tj
jjj|ƒ
}‡f
d
d„‰ˆ|ƒ
}d}xP|D]H}t|dƒr.|jƒr.t|dƒr.|dk rftdd|d|ƒ‚
|j|
|ƒ
|}q.WdS)Nc
sJtƒ}
x>|j
ƒD]2\}}|
j|ƒ

ˆ|ƒ
}x|D]}|
j|ƒ

q0WqW|
S)
N)ÚsetÚitemsÚadd)ÚgraphÚresultsÚdatapipeZ sub_graphZ sub_itemsÚitem)
Útraverse_graph©úE/usr/local/lib64/python3.6/site-packages/torch/utils/data/sharding.pyr s






z&apply_sharding..traverse_graphÚis_shardableÚapply_shardingzVThis implementation of sharding can be only applied once per instance of DataPipeline.zAlready applied tozwhile trying to apply to) ÚtorchÚutilsÚdatarZtraverseÚhasattrrÚRuntimeErrorr )rZnum_of_instancesZinstance_idrZ all_pipesZalready_applied_toÚpiper )
r rr s
 









r )Ztorch.utils.data.graphrr r r r rÚ
s