[fix] Use non-detached Ray actor for SimpleStorageUnit (#68)

0oshowero0 · web-flow · commit 4e9ae22cec54 · 2026-03-30T15:07:00.000+08:00
Follow PR #43 to use non-detached Ray actor for `SimpleStorageUnit` Signed-off-by: 0oshowero0 <o0shower0o@outlook.com>
diff --git a/transfer_queue/interface.py b/transfer_queue/interface.py
@@ -86,7 +86,6 @@ def _maybe_create_transferqueue_storage(conf: DictConfig) -> DictConfig:
                     placement_group=storage_placement_group,
                     placement_group_bundle_index=storage_unit_rank,
                     name=f"TransferQueueStorageUnit#{storage_unit_rank}",
-                    lifetime="detached",
                 ).remote(
                     storage_unit_size=math.ceil(total_storage_size / num_data_storage_units),
                 )

Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,6 @@ def _maybe_create_transferqueue_storage(conf: DictConfig) -> DictConfig:`
`86`	`86`	`placement_group=storage_placement_group,`
`87`	`87`	`placement_group_bundle_index=storage_unit_rank,`
`88`	`88`	`name=f"TransferQueueStorageUnit#{storage_unit_rank}",`
`89`		`- lifetime="detached",`
`90`	`89`	`).remote(`
`91`	`90`	`storage_unit_size=math.ceil(total_storage_size / num_data_storage_units),`
`92`	`91`	`)`