File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 4545 pip install dist/*.whl --force-reinstall
4646 - name : Test with pytest (TQ_ZERO_COPY_SERIALIZATION=False)
4747 run : |
48- pytest
48+ pytest tests
4949 - name : Test with pytest (TQ_ZERO_COPY_SERIALIZATION=True)
5050 run : |
5151 ray stop --force
5252 export TQ_ZERO_COPY_SERIALIZATION=True
53- pytest
53+ pytest tests
Original file line number Diff line number Diff line change 44 </h2 >
55 <a href =" https://arxiv.org/abs/2507.01663 " target =" _blank " ><strong >Paper</strong ></a >
66| <a href =" https://zhuanlan.zhihu.com/p/1930244241625449814 " target =" _blank " ><strong >Zhihu</strong ></a >
7+ | <a href =" https://github.com/TransferQueue/community_doc/blob/main/other_assets/WeChatGroup.png?raw=true " target =" _blank " ><strong >WeChat</strong ></a >
78 <br />
89 <br />
910
Original file line number Diff line number Diff line change 3232
3333
3434from transfer_queue import ( # noqa: E402
35- AsyncTransferQueueClient ,
3635 SimpleStorageUnit ,
36+ TransferQueueClient ,
3737 TransferQueueController ,
3838 process_zmq_server_info ,
3939)
@@ -247,7 +247,7 @@ def _initialize_data_system(self):
247247 tq_config .storage_unit_infos = self .data_system_storage_unit_infos
248248 self .config = OmegaConf .merge (tq_config , self .config )
249249
250- self .data_system_client = AsyncTransferQueueClient (
250+ self .data_system_client = TransferQueueClient (
251251 client_id = "Trainer" , controller_info = self .data_system_controller_info
252252 )
253253 self .data_system_client .initialize_storage_manager (manager_type = "AsyncSimpleStorageManager" , config = self .config )
You can’t perform that action at this time.
0 commit comments