Skip to content

Commit 48184ad

Browse files
committed
fix(sc): preserve cancellation during replay buffer rollback
Signed-off-by: ruit <ruit@nvidia.com>
1 parent fce9ad5 commit 48184ad

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

nemo_rl/algorithms/async_utils/replay_buffer.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -755,6 +755,8 @@ async def commit(
755755
partition_id=self._partition_id,
756756
)
757757
except BaseException as rollback_error:
758+
if isinstance(commit_error, asyncio.CancelledError):
759+
raise commit_error from rollback_error
758760
raise BaseExceptionGroup(
759761
f"commit and rollback both failed for group_id={group_id!r}",
760762
[commit_error, rollback_error],

0 commit comments

Comments
 (0)