We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 86fef46 commit fe8c9ccCopy full SHA for fe8c9cc
1 file changed
transfer_queue/__init__.py
@@ -27,7 +27,6 @@
27
from .sampler.rank_aware_sampler import RankAwareSampler
28
from .sampler.sequential_sampler import SequentialSampler
29
from .storage import SimpleStorageUnit
30
-from .streaming_dataloader import StreamDataLoader, StreamingDataset
31
from .utils.utils import get_placement_group
32
from .utils.zmq_utils import ZMQServerInfo
33
@@ -44,8 +43,6 @@
44
43
"GRPOGroupNSampler",
45
"SequentialSampler",
46
"RankAwareSampler",
47
- "StreamingDataset",
48
- "StreamDataLoader",
49
]
50
51
version_folder = os.path.dirname(os.path.join(os.path.abspath(__file__)))
0 commit comments