Skip to content

Bug fix for FSDP offload#233

Merged
pan-x-c merged 5 commits intoagentscope-ai:mainfrom
chenyushuo:fix/fsdp_offload
Aug 29, 2025
Merged

Bug fix for FSDP offload#233
pan-x-c merged 5 commits intoagentscope-ai:mainfrom
chenyushuo:fix/fsdp_offload

Conversation

@chenyushuo
Copy link
Collaborator

Description

As the title says.

Checklist

Please check the following items before code is ready to be reviewed.

  • Code has passed all tests
  • Docstrings have been added/updated in Google Style
  • Documentation has been updated
  • Code is ready for review

@chenyushuo chenyushuo requested a review from pan-x-c August 28, 2025 07:16
Copy link
Contributor

@gemini-code-assist gemini-code-assist bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Summary of Changes

Hello @chenyushuo, I'm Gemini Code Assist1! I'm currently reviewing this pull request and will post my feedback shortly. In the meantime, here's a summary to help you and other reviewers quickly get up to speed!

This pull request addresses a bug related to FSDP (Fully Sharded Data Parallel) model offloading. It ensures that the FSDP model is correctly loaded to the GPU before operations that require it, such as weight synchronization and state dict uploads. After these operations, the model is then offloaded back to the CPU, preventing potential issues and optimizing memory usage when offloading is active.

Highlights

  • Ensured FSDP models are loaded to GPU before critical operations: The actor_module_fsdp is now explicitly loaded to GPU before setup_weight_sync_group, sync_weight, and upload_state_dict routines if parameter offloading is active.
  • Implemented consistent model offloading: After these operations complete, the FSDP model is offloaded back to the CPU to free up GPU memory, specifically for actor modules when offloading is enabled.
  • Added synchronization and cache clearing: torch.distributed.barrier() and torch.cuda.empty_cache() calls are strategically placed after offloading operations to ensure proper distributed synchronization and GPU memory management.
Using Gemini Code Assist

The full guide for Gemini Code Assist can be found on our documentation page, here are some quick tips.

Invoking Gemini

You can request assistance from Gemini at any point in your pull request via creating an issue comment (i.e. comment on the pull request page) using either /gemini <command> or @gemini-code-assist <command>. Below is a summary of the supported commands.

Feature Command Description
Code Review /gemini review Performs a code review for the current pull request in its current state.
Pull Request Summary /gemini summary Provides a summary of the current pull request in its current state.
Comment @gemini-code-assist Responds in comments when explicitly tagged, both in issue comments and review comments.
Help /gemini help Displays a list of available commands.

Customization

To customize Gemini Code Assist for GitHub experience, repository maintainers can create a configuration file and/or provide a custom code review style guide (such as PEP-8 for Python) by creating and adding files to a .gemini/ folder in the base of the repository. Detailed instructions can be found here.

Limitations & Feedback

Gemini Code Assist may make mistakes. Please leave feedback on any instances where its feedback is incorrect or counter productive. You can react with 👍 and 👎 on @gemini-code-assist comments. If you're interested in giving your feedback about your experience with Gemini Code Assist for Github and other Google products, sign up here.

You can also get AI-powered code generation, chat, as well as code reviews directly in the IDE at no cost with the Gemini Code Assist IDE Extension.

Footnotes

  1. Review the Privacy Notices, Generative AI Prohibited Use Policy, Terms of Service, and learn how to configure Gemini Code Assist in GitHub here. Gemini can make mistakes, so double check it and use code with caution.

Copy link
Contributor

@gemini-code-assist gemini-code-assist bot left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Code Review

This pull request addresses a bug in FSDP offloading by ensuring the model is loaded onto the GPU before operations that require it and offloaded back to the CPU afterward to conserve GPU memory. The changes are applied to setup_weight_sync_group, sync_weight, and upload_state_dict methods. The logic appears correct. My main feedback is to refactor the repeated code for loading and offloading into a context manager to improve code maintainability and readability.

@chenyushuo
Copy link
Collaborator Author

/unittest-module-trainer

@github-actions
Copy link

Summary

Tests 📝 Passed ✅ Failed ❌ Skipped ⏭️ Other ❓ Flaky 🍂 Duration ⏱️
13 12 1 0 0 0 738ms

Failed Tests

Failed Tests ❌ Fail Message
❌ tests/trainer/trainer_test.py::TestTrainerGSM8K_3_fsdp2::test_trainer The test failed in the call phase due to an assertion error

Tests

Test Name Status Flaky Duration
tests/trainer/trainer_test.py::TestTrainerCountdown::test_trainer 148ms
tests/trainer/trainer_test.py::TestStepAheadAsyncRL::test_trainer 57ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_0_fsdp::test_trainer 44ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_1_fsdp2::test_trainer 45ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_2_fsdp::test_trainer 53ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_3_fsdp2::test_trainer 32ms
tests/trainer/trainer_test.py::TestTrainerSFTWarmupGSM8K::test_trainer 58ms
tests/trainer/trainer_test.py::TestTrainerDPO::test_trainer 34ms
tests/trainer/trainer_test.py::TestTrainerSFT::test_trainer 30ms
tests/trainer/trainer_test.py::TestTrainerToolsSFT::test_trainer_tools 30ms
tests/trainer/trainer_test.py::TestFullyAsyncMode::test_fully_async_mode_0_queue 71ms
tests/trainer/trainer_test.py::TestFullyAsyncMode::test_fully_async_mode_1_priority_queue 71ms
tests/trainer/trainer_test.py::TestTrainerMIX::test_trainer 56ms

Github Test Reporter by CTRF 💚

@chenyushuo
Copy link
Collaborator Author

/unittest-module-trainer

@github-actions
Copy link

Summary

Tests 📝 Passed ✅ Failed ❌ Skipped ⏭️ Other ❓ Flaky 🍂 Duration ⏱️
13 13 0 0 0 0 765ms

Tests

Test Name Status Flaky Duration
tests/trainer/trainer_test.py::TestTrainerCountdown::test_trainer 144ms
tests/trainer/trainer_test.py::TestStepAheadAsyncRL::test_trainer 66ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_0_fsdp::test_trainer 54ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_1_fsdp2::test_trainer 44ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_2_fsdp::test_trainer 47ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_3_fsdp2::test_trainer 56ms
tests/trainer/trainer_test.py::TestTrainerSFTWarmupGSM8K::test_trainer 65ms
tests/trainer/trainer_test.py::TestTrainerDPO::test_trainer 31ms
tests/trainer/trainer_test.py::TestTrainerSFT::test_trainer 29ms
tests/trainer/trainer_test.py::TestTrainerToolsSFT::test_trainer_tools 29ms
tests/trainer/trainer_test.py::TestFullyAsyncMode::test_fully_async_mode_0_queue 67ms
tests/trainer/trainer_test.py::TestFullyAsyncMode::test_fully_async_mode_1_priority_queue 65ms
tests/trainer/trainer_test.py::TestTrainerMIX::test_trainer 57ms

Github Test Reporter by CTRF 💚

@chenyushuo
Copy link
Collaborator Author

/unittest-module-trainer

@github-actions
Copy link

Summary

Tests 📝 Passed ✅ Failed ❌ Skipped ⏭️ Other ❓ Flaky 🍂 Duration ⏱️
13 13 0 0 0 0 727ms

Tests

Test Name Status Flaky Duration
tests/trainer/trainer_test.py::TestTrainerCountdown::test_trainer 125ms
tests/trainer/trainer_test.py::TestStepAheadAsyncRL::test_trainer 58ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_0_fsdp::test_trainer 44ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_1_fsdp2::test_trainer 45ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_2_fsdp::test_trainer 52ms
tests/trainer/trainer_test.py::TestTrainerGSM8K_3_fsdp2::test_trainer 58ms
tests/trainer/trainer_test.py::TestTrainerSFTWarmupGSM8K::test_trainer 53ms
tests/trainer/trainer_test.py::TestTrainerDPO::test_trainer 32ms
tests/trainer/trainer_test.py::TestTrainerSFT::test_trainer 30ms
tests/trainer/trainer_test.py::TestTrainerToolsSFT::test_trainer_tools 30ms
tests/trainer/trainer_test.py::TestFullyAsyncMode::test_fully_async_mode_0_queue 66ms
tests/trainer/trainer_test.py::TestFullyAsyncMode::test_fully_async_mode_1_priority_queue 71ms
tests/trainer/trainer_test.py::TestTrainerMIX::test_trainer 55ms

Github Test Reporter by CTRF 💚

@pan-x-c pan-x-c merged commit c5e6dd3 into agentscope-ai:main Aug 29, 2025
1 check passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants

Comments