LucaFrat commited on
Commit
bb4a4df
·
verified ·
1 Parent(s): 98b4e67

Delete files checkpoint-3* with huggingface_hub

Browse files
checkpoint-36/config.json DELETED
@@ -1,70 +0,0 @@
1
- {
2
- "action_horizon": 50,
3
- "add_pos_embed": true,
4
- "apply_sincos_state_encoding": true,
5
- "architectures": [
6
- "Gr00tN1d6"
7
- ],
8
- "attn_dropout": 0.2,
9
- "attn_implementation": null,
10
- "backbone_embedding_dim": 2048,
11
- "backbone_model_type": "eagle",
12
- "backbone_trainable_params_fp32": true,
13
- "collator_overwrite_image_inputs": false,
14
- "color_jitter_params": {
15
- "brightness": 0.1,
16
- "contrast": 0.1,
17
- "hue": 0.1,
18
- "saturation": 0.1
19
- },
20
- "crop_fraction": 0.95,
21
- "diffusion_model_cfg": {
22
- "attention_head_dim": 48,
23
- "dropout": 0.2,
24
- "final_dropout": true,
25
- "interleave_self_attention": true,
26
- "norm_type": "ada_norm",
27
- "num_attention_heads": 32,
28
- "num_layers": 32,
29
- "output_dim": 1024,
30
- "positional_embeddings": null
31
- },
32
- "eagle_collator": true,
33
- "formalize_language": true,
34
- "gemma_collator": false,
35
- "hidden_size": 1024,
36
- "image_crop_size": null,
37
- "image_target_size": null,
38
- "input_embedding_dim": 1536,
39
- "load_bf16": true,
40
- "max_action_dim": 128,
41
- "max_num_embodiments": 32,
42
- "max_seq_len": 1024,
43
- "max_state_dim": 128,
44
- "model_dtype": "bfloat16",
45
- "model_name": "nvidia/Eagle-Block2A-2B-v2",
46
- "model_type": "Gr00tN1d6",
47
- "noise_beta_alpha": 1.5,
48
- "noise_beta_beta": 1.0,
49
- "noise_s": 0.999,
50
- "num_inference_timesteps": 4,
51
- "num_timestep_buckets": 1000,
52
- "random_rotation_angle": null,
53
- "reproject_vision": false,
54
- "select_layer": 16,
55
- "shortest_image_edge": 256,
56
- "state_dropout_prob": 0.0,
57
- "torch_dtype": "bfloat16",
58
- "transformers_version": "4.51.3",
59
- "tune_diffusion_model": true,
60
- "tune_llm": false,
61
- "tune_projector": true,
62
- "tune_top_llm_layers": 4,
63
- "tune_visual": false,
64
- "tune_vlln": true,
65
- "use_albumentations_transforms": true,
66
- "use_alternate_vl_dit": true,
67
- "use_flash_attention": true,
68
- "use_relative_action": true,
69
- "use_vlln": true
70
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
checkpoint-36/embodiment_id.json DELETED
@@ -1,11 +0,0 @@
1
- {
2
- "robocasa_panda_omron": 13,
3
- "gr1": 20,
4
- "behavior_r1_pro": 24,
5
- "unitree_g1": 8,
6
- "oxe_google": 0,
7
- "oxe_widowx": 1,
8
- "libero_panda": 2,
9
- "oxe_droid": 16,
10
- "new_embodiment": 10
11
- }
 
 
 
 
 
 
 
 
 
 
 
 
checkpoint-36/experiment_cfg/conf.yaml DELETED
@@ -1,252 +0,0 @@
1
- load_config_path: null
2
- model:
3
- model_type: Gr00tN1d6
4
- model_dtype: bfloat16
5
- model_name: nvidia/Eagle-Block2A-2B-v2
6
- backbone_model_type: eagle
7
- model_revision: null
8
- tune_top_llm_layers: 4
9
- backbone_embedding_dim: 2048
10
- tune_llm: false
11
- tune_visual: false
12
- select_layer: 16
13
- reproject_vision: false
14
- use_flash_attention: true
15
- load_bf16: false
16
- collator_overwrite_image_inputs: false
17
- eagle_collator: true
18
- backbone_trainable_params_fp32: true
19
- image_crop_size: null
20
- image_target_size: null
21
- shortest_image_edge: 256
22
- crop_fraction: 0.95
23
- random_rotation_angle: null
24
- color_jitter_params:
25
- brightness: 0.3
26
- contrast: 0.4
27
- saturation: 0.5
28
- hue: 0.08
29
- use_albumentations_transforms: true
30
- formalize_language: true
31
- apply_sincos_state_encoding: false
32
- use_relative_action: true
33
- max_state_dim: 29
34
- max_action_dim: 29
35
- action_horizon: 16
36
- hidden_size: 1024
37
- input_embedding_dim: 1536
38
- add_pos_embed: true
39
- attn_dropout: 0.2
40
- use_vlln: true
41
- max_seq_len: 1024
42
- use_alternate_vl_dit: true
43
- attend_text_every_n_blocks: 2
44
- diffusion_model_cfg:
45
- positional_embeddings: null
46
- num_layers: 32
47
- num_attention_heads: 32
48
- attention_head_dim: 48
49
- norm_type: ada_norm
50
- dropout: 0.2
51
- final_dropout: true
52
- output_dim: 1024
53
- interleave_self_attention: true
54
- num_inference_timesteps: 4
55
- noise_beta_alpha: 1.5
56
- noise_beta_beta: 1.0
57
- noise_s: 0.999
58
- num_timestep_buckets: 1000
59
- tune_projector: true
60
- tune_diffusion_model: true
61
- tune_vlln: true
62
- state_dropout_prob: 0.0
63
- state_additive_noise_scale: 0.0
64
- max_num_embodiments: 32
65
- data:
66
- datasets:
67
- - dataset_paths:
68
- - /data/PnPCubeLine
69
- embodiment_tag: unitree_g1
70
- mix_ratio: 1.0
71
- dataset_type: physical_embodiment
72
- val_dataset_path: null
73
- modality_configs:
74
- unitree_g1:
75
- video:
76
- delta_indices:
77
- - 0
78
- modality_keys:
79
- - ego_view
80
- sin_cos_embedding_keys: null
81
- mean_std_embedding_keys: null
82
- action_configs: null
83
- state:
84
- delta_indices:
85
- - 0
86
- modality_keys:
87
- - left_leg
88
- - right_leg
89
- - waist
90
- - left_arm
91
- - right_arm
92
- - left_hand
93
- - right_hand
94
- sin_cos_embedding_keys: null
95
- mean_std_embedding_keys: null
96
- action_configs: null
97
- action:
98
- delta_indices:
99
- - 0
100
- - 1
101
- - 2
102
- - 3
103
- - 4
104
- - 5
105
- - 6
106
- - 7
107
- - 8
108
- - 9
109
- - 10
110
- - 11
111
- - 12
112
- - 13
113
- - 14
114
- - 15
115
- - 16
116
- - 17
117
- - 18
118
- - 19
119
- - 20
120
- - 21
121
- - 22
122
- - 23
123
- - 24
124
- - 25
125
- - 26
126
- - 27
127
- - 28
128
- - 29
129
- modality_keys:
130
- - left_arm
131
- - right_arm
132
- - left_hand
133
- - right_hand
134
- - waist
135
- - base_height_command
136
- - navigate_command
137
- sin_cos_embedding_keys: null
138
- mean_std_embedding_keys: null
139
- action_configs:
140
- - rep: RELATIVE
141
- type: NON_EEF
142
- format: DEFAULT
143
- state_key: null
144
- - rep: RELATIVE
145
- type: NON_EEF
146
- format: DEFAULT
147
- state_key: null
148
- - rep: ABSOLUTE
149
- type: NON_EEF
150
- format: DEFAULT
151
- state_key: null
152
- - rep: ABSOLUTE
153
- type: NON_EEF
154
- format: DEFAULT
155
- state_key: null
156
- - rep: ABSOLUTE
157
- type: NON_EEF
158
- format: DEFAULT
159
- state_key: null
160
- - rep: ABSOLUTE
161
- type: NON_EEF
162
- format: DEFAULT
163
- state_key: null
164
- - rep: ABSOLUTE
165
- type: NON_EEF
166
- format: DEFAULT
167
- state_key: null
168
- language:
169
- delta_indices:
170
- - 0
171
- modality_keys:
172
- - annotation.human.task_description
173
- sin_cos_embedding_keys: null
174
- mean_std_embedding_keys: null
175
- action_configs: null
176
- download_cache: false
177
- shard_size: 1024
178
- episode_sampling_rate: 0.1
179
- num_shards_per_epoch: 100000
180
- override_pretraining_statistics: false
181
- mode: single_turn
182
- random_chop: 0.0
183
- mock_dataset_mode: false
184
- shuffle: true
185
- seed: 42
186
- multiprocessing_context: fork
187
- allow_padding: false
188
- subsample_ratio: 1.0
189
- image_crop_size:
190
- - 244
191
- - 244
192
- image_target_size:
193
- - 224
194
- - 224
195
- video_backend: torchcodec
196
- training:
197
- output_dir: /checkpoints/g1_finetune
198
- experiment_name: null
199
- max_steps: 36
200
- global_batch_size: 512
201
- batch_size: null
202
- gradient_accumulation_steps: 1
203
- learning_rate: 0.0001
204
- lr_scheduler_type: cosine
205
- weight_decay: 1.0e-05
206
- warmup_ratio: 0.05
207
- warmup_steps: 0
208
- max_grad_norm: 1.0
209
- optim: adamw_torch
210
- start_from_checkpoint: nvidia/GR00T-N1.6-3B
211
- tf32: true
212
- fp16: false
213
- bf16: true
214
- eval_bf16: true
215
- logging_steps: 10
216
- save_steps: 12
217
- save_total_limit: 3
218
- save_vl_model: false
219
- upload_checkpoints: false
220
- upload_every: 1000
221
- upload_last_n_checkpoints: 5
222
- max_concurrent_uploads: 2
223
- eval_strategy: 'no'
224
- eval_steps: 500
225
- eval_set_split_ratio: 0.1
226
- eval_batch_size: 2
227
- save_best_eval_metric_name: ''
228
- save_best_eval_metric_greater_is_better: true
229
- deepspeed_stage: 2
230
- gradient_checkpointing: false
231
- transformers_trust_remote_code: true
232
- transformers_local_files_only: false
233
- transformers_cache_dir: null
234
- transformers_access_token: null
235
- use_ddp: false
236
- ddp_bucket_cap_mb: 100
237
- num_gpus: 4
238
- dataloader_num_workers: 6
239
- remove_unused_columns: false
240
- use_wandb: false
241
- wandb_project: finetune-gr00t-n1d6
242
- enable_profiling: false
243
- max_retries: 3
244
- assert_loss_less_than: null
245
- add_rl_callback: false
246
- enable_open_loop_eval: false
247
- open_loop_eval_traj_ids:
248
- - 0
249
- open_loop_eval_steps_per_traj: 100
250
- open_loop_eval_plot_indices: null
251
- max_steps: 36
252
- save_steps: 12
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
checkpoint-36/experiment_cfg/config.yaml DELETED
@@ -1,291 +0,0 @@
1
- !!python/object:gr00t.configs.base_config.Config
2
- data: !!python/object:gr00t.configs.data.data_config.DataConfig
3
- allow_padding: false
4
- datasets:
5
- - !!python/object:gr00t.configs.data.data_config.SingleDatasetConfig
6
- dataset_paths:
7
- - /data/PnPCubeLine
8
- dataset_type: physical_embodiment
9
- embodiment_tag: unitree_g1
10
- mix_ratio: 1.0
11
- val_dataset_path: null
12
- download_cache: false
13
- episode_sampling_rate: 0.1
14
- image_crop_size:
15
- - 244
16
- - 244
17
- image_target_size:
18
- - 224
19
- - 224
20
- mock_dataset_mode: false
21
- modality_configs:
22
- unitree_g1:
23
- action: !!python/object:gr00t.data.types.ModalityConfig
24
- action_configs:
25
- - !!python/object:gr00t.data.types.ActionConfig
26
- format: &id001 !!python/object/apply:gr00t.data.types.ActionFormat
27
- - default
28
- rep: &id002 !!python/object/apply:gr00t.data.types.ActionRepresentation
29
- - relative
30
- state_key: null
31
- type: &id003 !!python/object/apply:gr00t.data.types.ActionType
32
- - non_eef
33
- - !!python/object:gr00t.data.types.ActionConfig
34
- format: *id001
35
- rep: *id002
36
- state_key: null
37
- type: *id003
38
- - !!python/object:gr00t.data.types.ActionConfig
39
- format: *id001
40
- rep: &id004 !!python/object/apply:gr00t.data.types.ActionRepresentation
41
- - absolute
42
- state_key: null
43
- type: *id003
44
- - !!python/object:gr00t.data.types.ActionConfig
45
- format: *id001
46
- rep: *id004
47
- state_key: null
48
- type: *id003
49
- - !!python/object:gr00t.data.types.ActionConfig
50
- format: *id001
51
- rep: *id004
52
- state_key: null
53
- type: *id003
54
- - !!python/object:gr00t.data.types.ActionConfig
55
- format: *id001
56
- rep: *id004
57
- state_key: null
58
- type: *id003
59
- - !!python/object:gr00t.data.types.ActionConfig
60
- format: *id001
61
- rep: *id004
62
- state_key: null
63
- type: *id003
64
- delta_indices:
65
- - 0
66
- - 1
67
- - 2
68
- - 3
69
- - 4
70
- - 5
71
- - 6
72
- - 7
73
- - 8
74
- - 9
75
- - 10
76
- - 11
77
- - 12
78
- - 13
79
- - 14
80
- - 15
81
- - 16
82
- - 17
83
- - 18
84
- - 19
85
- - 20
86
- - 21
87
- - 22
88
- - 23
89
- - 24
90
- - 25
91
- - 26
92
- - 27
93
- - 28
94
- - 29
95
- mean_std_embedding_keys: null
96
- modality_keys:
97
- - left_arm
98
- - right_arm
99
- - left_hand
100
- - right_hand
101
- - waist
102
- - base_height_command
103
- - navigate_command
104
- sin_cos_embedding_keys: null
105
- language: !!python/object:gr00t.data.types.ModalityConfig
106
- action_configs: null
107
- delta_indices:
108
- - 0
109
- mean_std_embedding_keys: null
110
- modality_keys:
111
- - annotation.human.task_description
112
- sin_cos_embedding_keys: null
113
- state: !!python/object:gr00t.data.types.ModalityConfig
114
- action_configs: null
115
- delta_indices:
116
- - 0
117
- mean_std_embedding_keys: null
118
- modality_keys:
119
- - left_leg
120
- - right_leg
121
- - waist
122
- - left_arm
123
- - right_arm
124
- - left_hand
125
- - right_hand
126
- sin_cos_embedding_keys: null
127
- video: !!python/object:gr00t.data.types.ModalityConfig
128
- action_configs: null
129
- delta_indices:
130
- - 0
131
- mean_std_embedding_keys: null
132
- modality_keys:
133
- - ego_view
134
- sin_cos_embedding_keys: null
135
- mode: single_turn
136
- multiprocessing_context: fork
137
- num_shards_per_epoch: 100000
138
- override_pretraining_statistics: false
139
- random_chop: 0.0
140
- seed: 42
141
- shard_size: 1024
142
- shuffle: true
143
- subsample_ratio: 1.0
144
- video_backend: torchcodec
145
- load_config_path: null
146
- model: !!python/object:gr00t.configs.model.gr00t_n1d6.Gr00tN1d6Config
147
- _attn_implementation_autoset: false
148
- _attn_implementation_internal: null
149
- _commit_hash: null
150
- _name_or_path: ''
151
- add_cross_attention: false
152
- architectures: null
153
- backbone_model_type: eagle
154
- backbone_trainable_params_fp32: true
155
- bad_words_ids: null
156
- begin_suppress_tokens: null
157
- bos_token_id: null
158
- chunk_size_feed_forward: 0
159
- color_jitter_params:
160
- brightness: 0.3
161
- contrast: 0.4
162
- hue: 0.08
163
- saturation: 0.5
164
- cross_attention_hidden_size: null
165
- decoder_start_token_id: null
166
- diffusion_model_cfg:
167
- attention_head_dim: 48
168
- dropout: 0.2
169
- final_dropout: true
170
- interleave_self_attention: true
171
- norm_type: ada_norm
172
- num_attention_heads: 32
173
- num_layers: 32
174
- output_dim: 1024
175
- positional_embeddings: null
176
- diversity_penalty: 0.0
177
- do_sample: false
178
- eagle_collator: true
179
- early_stopping: false
180
- encoder_no_repeat_ngram_size: 0
181
- eos_token_id: null
182
- exponential_decay_length_penalty: null
183
- finetuning_task: null
184
- forced_bos_token_id: null
185
- forced_eos_token_id: null
186
- id2label:
187
- 0: LABEL_0
188
- 1: LABEL_1
189
- is_decoder: false
190
- is_encoder_decoder: false
191
- label2id:
192
- LABEL_0: 0
193
- LABEL_1: 1
194
- length_penalty: 1.0
195
- load_bf16: false
196
- max_length: 20
197
- min_length: 0
198
- model_name: nvidia/Eagle-Block2A-2B-v2
199
- no_repeat_ngram_size: 0
200
- num_beam_groups: 1
201
- num_beams: 1
202
- num_return_sequences: 1
203
- output_attentions: false
204
- output_hidden_states: false
205
- output_scores: false
206
- pad_token_id: null
207
- prefix: null
208
- problem_type: null
209
- pruned_heads: {}
210
- random_rotation_angle: null
211
- remove_invalid_values: false
212
- repetition_penalty: 1.0
213
- reproject_vision: false
214
- return_dict: true
215
- return_dict_in_generate: false
216
- sep_token_id: null
217
- state_dropout_prob: 0.0
218
- suppress_tokens: null
219
- task_specific_params: null
220
- temperature: 1.0
221
- tf_legacy_loss: false
222
- tie_encoder_decoder: false
223
- tie_word_embeddings: true
224
- tokenizer_class: null
225
- top_k: 50
226
- top_p: 1.0
227
- torch_dtype: null
228
- torchscript: false
229
- transformers_version: null
230
- tune_diffusion_model: true
231
- tune_llm: false
232
- tune_projector: true
233
- tune_visual: false
234
- typical_p: 1.0
235
- use_bfloat16: false
236
- use_relative_action: true
237
- training: !!python/object:gr00t.configs.training.training_config.TrainingConfig
238
- add_rl_callback: false
239
- assert_loss_less_than: null
240
- batch_size: null
241
- bf16: true
242
- dataloader_num_workers: 6
243
- ddp_bucket_cap_mb: 100
244
- deepspeed_stage: 2
245
- enable_open_loop_eval: false
246
- enable_profiling: false
247
- eval_batch_size: 2
248
- eval_bf16: true
249
- eval_set_split_ratio: 0.1
250
- eval_steps: 500
251
- eval_strategy: 'no'
252
- experiment_name: null
253
- fp16: false
254
- global_batch_size: 512
255
- gradient_accumulation_steps: 1
256
- gradient_checkpointing: false
257
- learning_rate: 0.0001
258
- logging_steps: 10
259
- lr_scheduler_type: cosine
260
- max_concurrent_uploads: 2
261
- max_grad_norm: 1.0
262
- max_retries: 3
263
- max_steps: 36
264
- num_gpus: 4
265
- open_loop_eval_plot_indices: null
266
- open_loop_eval_steps_per_traj: 100
267
- open_loop_eval_traj_ids:
268
- - 0
269
- optim: adamw_torch
270
- output_dir: /checkpoints/g1_finetune
271
- remove_unused_columns: false
272
- save_best_eval_metric_greater_is_better: true
273
- save_best_eval_metric_name: ''
274
- save_steps: 12
275
- save_total_limit: 3
276
- save_vl_model: false
277
- start_from_checkpoint: nvidia/GR00T-N1.6-3B
278
- tf32: true
279
- transformers_access_token: null
280
- transformers_cache_dir: null
281
- transformers_local_files_only: false
282
- transformers_trust_remote_code: true
283
- upload_checkpoints: false
284
- upload_every: 1000
285
- upload_last_n_checkpoints: 5
286
- use_ddp: false
287
- use_wandb: false
288
- wandb_project: finetune-gr00t-n1d6
289
- warmup_ratio: 0.05
290
- warmup_steps: 0
291
- weight_decay: 1.0e-05
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
checkpoint-36/experiment_cfg/dataset_statistics.json DELETED
The diff for this file is too large to render. See raw diff
 
checkpoint-36/experiment_cfg/final_model_config.json DELETED
@@ -1,53 +0,0 @@
1
- {
2
- "model_type": "Gr00tN1d6",
3
- "model_dtype": "bfloat16",
4
- "model_name": "nvidia/Eagle-Block2A-2B-v2",
5
- "backbone_model_type": "eagle",
6
- "model_revision": null,
7
- "tune_top_llm_layers": 4,
8
- "backbone_embedding_dim": 2048,
9
- "tune_llm": false,
10
- "tune_visual": false,
11
- "select_layer": 16,
12
- "reproject_vision": false,
13
- "use_flash_attention": true,
14
- "load_bf16": true,
15
- "collator_overwrite_image_inputs": false,
16
- "eagle_collator": true,
17
- "backbone_trainable_params_fp32": true,
18
- "apply_sincos_state_encoding": true,
19
- "use_relative_action": true,
20
- "max_state_dim": 128,
21
- "max_action_dim": 128,
22
- "action_horizon": 50,
23
- "hidden_size": 1024,
24
- "input_embedding_dim": 1536,
25
- "add_pos_embed": true,
26
- "attn_dropout": 0.2,
27
- "use_vlln": true,
28
- "max_seq_len": 1024,
29
- "use_alternate_vl_dit": true,
30
- "attend_text_every_n_blocks": 2,
31
- "diffusion_model_cfg": {
32
- "attention_head_dim": 48,
33
- "dropout": 0.2,
34
- "final_dropout": true,
35
- "interleave_self_attention": true,
36
- "norm_type": "ada_norm",
37
- "num_attention_heads": 32,
38
- "num_layers": 32,
39
- "output_dim": 1024,
40
- "positional_embeddings": null
41
- },
42
- "num_inference_timesteps": 4,
43
- "noise_beta_alpha": 1.5,
44
- "noise_beta_beta": 1.0,
45
- "noise_s": 0.999,
46
- "num_timestep_buckets": 1000,
47
- "tune_projector": true,
48
- "tune_diffusion_model": true,
49
- "tune_vlln": true,
50
- "state_dropout_prob": 0.0,
51
- "state_additive_noise_scale": 0.0,
52
- "max_num_embodiments": 32
53
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
checkpoint-36/experiment_cfg/final_processor_config.json DELETED
The diff for this file is too large to render. See raw diff
 
checkpoint-36/global_step36/bf16_zero_pp_rank_0_mp_rank_00_optim_states.pt DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:ca55f703ae97692e34abd4e024642219e49afa810febd780009fdf0252c97b4e
3
- size 4859923697
 
 
 
 
checkpoint-36/global_step36/bf16_zero_pp_rank_1_mp_rank_00_optim_states.pt DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:f3871c395b98977c6b4a1155d59be59ca302662e1f191e7b718560e0e1937141
3
- size 4859923761
 
 
 
 
checkpoint-36/global_step36/bf16_zero_pp_rank_2_mp_rank_00_optim_states.pt DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:2f6ed0d1086fcf449f6f2e224d7af5db59b5f1033f9681fbbf053f3f5293cb7c
3
- size 4859923569
 
 
 
 
checkpoint-36/global_step36/bf16_zero_pp_rank_3_mp_rank_00_optim_states.pt DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:7a9ca3f5b8c43f6646336fca3c0aaeda5cb78bbc55c42595704d46b1c313f1ec
3
- size 4859917873
 
 
 
 
checkpoint-36/global_step36/mp_rank_00_model_states.pt DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:d8d452eade3c9462306ebe09cca4f2bda7a964931c9995f88bb64f6d4e53520d
3
- size 9907202435
 
 
 
 
checkpoint-36/latest DELETED
@@ -1 +0,0 @@
1
- global_step36
 
 
checkpoint-36/model-00001-of-00002.safetensors DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:14f474658ff87dc1f65377ff3a2a405e82424ac238e09635ff9d2743bb9a4c19
3
- size 4991091456
 
 
 
 
checkpoint-36/model-00002-of-00002.safetensors DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:ca1958ec96af2b32f3eb12a2fc3936ae92711a829bdd408836dcb8ed324c0939
3
- size 1582283096
 
 
 
 
checkpoint-36/model.safetensors.index.json DELETED
The diff for this file is too large to render. See raw diff
 
checkpoint-36/processor_config.json DELETED
@@ -1,508 +0,0 @@
1
- {
2
- "processor_class": "Gr00tN1d6Processor",
3
- "processor_kwargs": {
4
- "modality_configs": {
5
- "behavior_r1_pro": {
6
- "video": {
7
- "delta_indices": [
8
- 0
9
- ],
10
- "modality_keys": [
11
- "observation.images.rgb.head_256_256",
12
- "observation.images.rgb.left_wrist_256_256",
13
- "observation.images.rgb.right_wrist_256_256"
14
- ],
15
- "sin_cos_embedding_keys": null,
16
- "mean_std_embedding_keys": null,
17
- "action_configs": null
18
- },
19
- "state": {
20
- "delta_indices": [
21
- 0
22
- ],
23
- "modality_keys": [
24
- "robot_pos",
25
- "robot_ori_cos",
26
- "robot_ori_sin",
27
- "robot_2d_ori",
28
- "robot_2d_ori_cos",
29
- "robot_2d_ori_sin",
30
- "robot_lin_vel",
31
- "robot_ang_vel",
32
- "arm_left_qpos",
33
- "arm_left_qpos_sin",
34
- "arm_left_qpos_cos",
35
- "eef_left_pos",
36
- "eef_left_quat",
37
- "gripper_left_qpos",
38
- "arm_right_qpos",
39
- "arm_right_qpos_sin",
40
- "arm_right_qpos_cos",
41
- "eef_right_pos",
42
- "eef_right_quat",
43
- "gripper_right_qpos",
44
- "trunk_qpos"
45
- ],
46
- "sin_cos_embedding_keys": null,
47
- "mean_std_embedding_keys": null,
48
- "action_configs": null
49
- },
50
- "action": {
51
- "delta_indices": [
52
- 0,
53
- 1,
54
- 2,
55
- 3,
56
- 4,
57
- 5,
58
- 6,
59
- 7,
60
- 8,
61
- 9,
62
- 10,
63
- 11,
64
- 12,
65
- 13,
66
- 14,
67
- 15,
68
- 16,
69
- 17,
70
- 18,
71
- 19,
72
- 20,
73
- 21,
74
- 22,
75
- 23,
76
- 24,
77
- 25,
78
- 26,
79
- 27,
80
- 28,
81
- 29,
82
- 30,
83
- 31
84
- ],
85
- "modality_keys": [
86
- "base",
87
- "torso",
88
- "left_arm",
89
- "left_gripper",
90
- "right_arm",
91
- "right_gripper"
92
- ],
93
- "sin_cos_embedding_keys": null,
94
- "mean_std_embedding_keys": null,
95
- "action_configs": [
96
- {
97
- "rep": "ABSOLUTE",
98
- "type": "NON_EEF",
99
- "format": "DEFAULT",
100
- "state_key": null
101
- },
102
- {
103
- "rep": "RELATIVE",
104
- "type": "NON_EEF",
105
- "format": "DEFAULT",
106
- "state_key": "trunk_qpos"
107
- },
108
- {
109
- "rep": "RELATIVE",
110
- "type": "NON_EEF",
111
- "format": "DEFAULT",
112
- "state_key": "arm_left_qpos"
113
- },
114
- {
115
- "rep": "ABSOLUTE",
116
- "type": "NON_EEF",
117
- "format": "DEFAULT",
118
- "state_key": null
119
- },
120
- {
121
- "rep": "RELATIVE",
122
- "type": "NON_EEF",
123
- "format": "DEFAULT",
124
- "state_key": "arm_right_qpos"
125
- },
126
- {
127
- "rep": "ABSOLUTE",
128
- "type": "NON_EEF",
129
- "format": "DEFAULT",
130
- "state_key": null
131
- }
132
- ]
133
- },
134
- "language": {
135
- "delta_indices": [
136
- 0
137
- ],
138
- "modality_keys": [
139
- "annotation.human.coarse_action"
140
- ],
141
- "sin_cos_embedding_keys": null,
142
- "mean_std_embedding_keys": null,
143
- "action_configs": null
144
- }
145
- },
146
- "gr1": {
147
- "video": {
148
- "delta_indices": [
149
- 0
150
- ],
151
- "modality_keys": [
152
- "ego_view_bg_crop_pad_res256_freq20"
153
- ],
154
- "sin_cos_embedding_keys": null,
155
- "mean_std_embedding_keys": null,
156
- "action_configs": null
157
- },
158
- "state": {
159
- "delta_indices": [
160
- 0
161
- ],
162
- "modality_keys": [
163
- "left_arm",
164
- "right_arm",
165
- "left_hand",
166
- "right_hand",
167
- "waist"
168
- ],
169
- "sin_cos_embedding_keys": [
170
- "left_arm",
171
- "right_arm",
172
- "left_hand",
173
- "right_hand",
174
- "waist"
175
- ],
176
- "mean_std_embedding_keys": null,
177
- "action_configs": null
178
- },
179
- "action": {
180
- "delta_indices": [
181
- 0,
182
- 1,
183
- 2,
184
- 3,
185
- 4,
186
- 5,
187
- 6,
188
- 7,
189
- 8,
190
- 9,
191
- 10,
192
- 11,
193
- 12,
194
- 13,
195
- 14,
196
- 15
197
- ],
198
- "modality_keys": [
199
- "left_arm",
200
- "right_arm",
201
- "left_hand",
202
- "right_hand",
203
- "waist"
204
- ],
205
- "sin_cos_embedding_keys": null,
206
- "mean_std_embedding_keys": null,
207
- "action_configs": [
208
- {
209
- "rep": "RELATIVE",
210
- "type": "NON_EEF",
211
- "format": "DEFAULT",
212
- "state_key": null
213
- },
214
- {
215
- "rep": "RELATIVE",
216
- "type": "NON_EEF",
217
- "format": "DEFAULT",
218
- "state_key": null
219
- },
220
- {
221
- "rep": "RELATIVE",
222
- "type": "NON_EEF",
223
- "format": "DEFAULT",
224
- "state_key": null
225
- },
226
- {
227
- "rep": "RELATIVE",
228
- "type": "NON_EEF",
229
- "format": "DEFAULT",
230
- "state_key": null
231
- },
232
- {
233
- "rep": "ABSOLUTE",
234
- "type": "NON_EEF",
235
- "format": "DEFAULT",
236
- "state_key": null
237
- }
238
- ]
239
- },
240
- "language": {
241
- "delta_indices": [
242
- 0
243
- ],
244
- "modality_keys": [
245
- "task"
246
- ],
247
- "sin_cos_embedding_keys": null,
248
- "mean_std_embedding_keys": null,
249
- "action_configs": null
250
- }
251
- },
252
- "robocasa_panda_omron": {
253
- "video": {
254
- "delta_indices": [
255
- 0
256
- ],
257
- "modality_keys": [
258
- "res256_image_side_0",
259
- "res256_image_side_1",
260
- "res256_image_wrist_0"
261
- ],
262
- "sin_cos_embedding_keys": null,
263
- "mean_std_embedding_keys": null,
264
- "action_configs": null
265
- },
266
- "state": {
267
- "delta_indices": [
268
- 0
269
- ],
270
- "modality_keys": [
271
- "end_effector_position_relative",
272
- "end_effector_rotation_relative",
273
- "gripper_qpos",
274
- "base_position",
275
- "base_rotation"
276
- ],
277
- "sin_cos_embedding_keys": null,
278
- "mean_std_embedding_keys": null,
279
- "action_configs": null
280
- },
281
- "action": {
282
- "delta_indices": [
283
- 0,
284
- 1,
285
- 2,
286
- 3,
287
- 4,
288
- 5,
289
- 6,
290
- 7,
291
- 8,
292
- 9,
293
- 10,
294
- 11,
295
- 12,
296
- 13,
297
- 14,
298
- 15
299
- ],
300
- "modality_keys": [
301
- "end_effector_position",
302
- "end_effector_rotation",
303
- "gripper_close",
304
- "base_motion",
305
- "control_mode"
306
- ],
307
- "sin_cos_embedding_keys": null,
308
- "mean_std_embedding_keys": null,
309
- "action_configs": [
310
- {
311
- "rep": "ABSOLUTE",
312
- "type": "NON_EEF",
313
- "format": "DEFAULT",
314
- "state_key": null
315
- },
316
- {
317
- "rep": "ABSOLUTE",
318
- "type": "NON_EEF",
319
- "format": "DEFAULT",
320
- "state_key": null
321
- },
322
- {
323
- "rep": "ABSOLUTE",
324
- "type": "NON_EEF",
325
- "format": "DEFAULT",
326
- "state_key": null
327
- },
328
- {
329
- "rep": "ABSOLUTE",
330
- "type": "NON_EEF",
331
- "format": "DEFAULT",
332
- "state_key": null
333
- },
334
- {
335
- "rep": "ABSOLUTE",
336
- "type": "NON_EEF",
337
- "format": "DEFAULT",
338
- "state_key": null
339
- }
340
- ]
341
- },
342
- "language": {
343
- "delta_indices": [
344
- 0
345
- ],
346
- "modality_keys": [
347
- "annotation.human.action.task_description"
348
- ],
349
- "sin_cos_embedding_keys": null,
350
- "mean_std_embedding_keys": null,
351
- "action_configs": null
352
- }
353
- },
354
- "unitree_g1": {
355
- "video": {
356
- "delta_indices": [
357
- 0
358
- ],
359
- "modality_keys": [
360
- "ego_view"
361
- ],
362
- "sin_cos_embedding_keys": null,
363
- "mean_std_embedding_keys": null,
364
- "action_configs": null
365
- },
366
- "state": {
367
- "delta_indices": [
368
- 0
369
- ],
370
- "modality_keys": [
371
- "left_leg",
372
- "right_leg",
373
- "waist",
374
- "left_arm",
375
- "right_arm",
376
- "left_hand",
377
- "right_hand"
378
- ],
379
- "sin_cos_embedding_keys": null,
380
- "mean_std_embedding_keys": null,
381
- "action_configs": null
382
- },
383
- "action": {
384
- "delta_indices": [
385
- 0,
386
- 1,
387
- 2,
388
- 3,
389
- 4,
390
- 5,
391
- 6,
392
- 7,
393
- 8,
394
- 9,
395
- 10,
396
- 11,
397
- 12,
398
- 13,
399
- 14,
400
- 15,
401
- 16,
402
- 17,
403
- 18,
404
- 19,
405
- 20,
406
- 21,
407
- 22,
408
- 23,
409
- 24,
410
- 25,
411
- 26,
412
- 27,
413
- 28,
414
- 29
415
- ],
416
- "modality_keys": [
417
- "left_arm",
418
- "right_arm",
419
- "left_hand",
420
- "right_hand",
421
- "waist",
422
- "base_height_command",
423
- "navigate_command"
424
- ],
425
- "sin_cos_embedding_keys": null,
426
- "mean_std_embedding_keys": null,
427
- "action_configs": [
428
- {
429
- "rep": "RELATIVE",
430
- "type": "NON_EEF",
431
- "format": "DEFAULT",
432
- "state_key": null
433
- },
434
- {
435
- "rep": "RELATIVE",
436
- "type": "NON_EEF",
437
- "format": "DEFAULT",
438
- "state_key": null
439
- },
440
- {
441
- "rep": "ABSOLUTE",
442
- "type": "NON_EEF",
443
- "format": "DEFAULT",
444
- "state_key": null
445
- },
446
- {
447
- "rep": "ABSOLUTE",
448
- "type": "NON_EEF",
449
- "format": "DEFAULT",
450
- "state_key": null
451
- },
452
- {
453
- "rep": "ABSOLUTE",
454
- "type": "NON_EEF",
455
- "format": "DEFAULT",
456
- "state_key": null
457
- },
458
- {
459
- "rep": "ABSOLUTE",
460
- "type": "NON_EEF",
461
- "format": "DEFAULT",
462
- "state_key": null
463
- },
464
- {
465
- "rep": "ABSOLUTE",
466
- "type": "NON_EEF",
467
- "format": "DEFAULT",
468
- "state_key": null
469
- }
470
- ]
471
- },
472
- "language": {
473
- "delta_indices": [
474
- 0
475
- ],
476
- "modality_keys": [
477
- "annotation.human.task_description"
478
- ],
479
- "sin_cos_embedding_keys": null,
480
- "mean_std_embedding_keys": null,
481
- "action_configs": null
482
- }
483
- }
484
- },
485
- "image_crop_size": null,
486
- "image_target_size": null,
487
- "use_albumentations": true,
488
- "random_rotation_angle": null,
489
- "color_jitter_params": {
490
- "brightness": 0.3,
491
- "contrast": 0.4,
492
- "saturation": 0.5,
493
- "hue": 0.08
494
- },
495
- "shortest_image_edge": 256,
496
- "crop_fraction": 0.95,
497
- "model_name": "nvidia/Eagle-Block2A-2B-v2",
498
- "model_type": "eagle",
499
- "formalize_language": true,
500
- "max_state_dim": 128,
501
- "max_action_dim": 128,
502
- "max_action_horizon": 50,
503
- "use_percentiles": false,
504
- "clip_outliers": true,
505
- "apply_sincos_state_encoding": true,
506
- "use_relative_action": true
507
- }
508
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
checkpoint-36/rng_state_0.pth DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:eca25c9b9a24c5837f8a22c33fde8997648df6eb1bb0f971ffe391d2d30e6820
3
- size 15429
 
 
 
 
checkpoint-36/rng_state_1.pth DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:3e101856b59e5aa370836c5e6eac0206a12923f40bdf8e719f59950a38f6dd19
3
- size 15429
 
 
 
 
checkpoint-36/rng_state_2.pth DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:c249e4ce60380fadd294f662ade9389f03fe543358c0c477ebbd67de4a673019
3
- size 15429
 
 
 
 
checkpoint-36/rng_state_3.pth DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:118e6034ce2076dd523cdcf1dc08a2fcd9e097fe9f42d202bae8e2449cfbf6f5
3
- size 15429
 
 
 
 
checkpoint-36/scheduler.pt DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:495e8e3c9b5dc21c8037525a0de1ab5f4a0c0c8813d522a6924cb66712cbc8d4
3
- size 1465
 
 
 
 
checkpoint-36/statistics.json DELETED
The diff for this file is too large to render. See raw diff
 
checkpoint-36/trainer_state.json DELETED
@@ -1,52 +0,0 @@
1
- {
2
- "best_global_step": null,
3
- "best_metric": null,
4
- "best_model_checkpoint": null,
5
- "epoch": 1.0,
6
- "eval_steps": 500,
7
- "global_step": 36,
8
- "is_hyper_param_search": false,
9
- "is_local_process_zero": true,
10
- "is_world_process_zero": true,
11
- "log_history": [
12
- {
13
- "grad_norm": 0.3049973249435425,
14
- "learning_rate": 8.9900861364012e-05,
15
- "loss": 1.3242,
16
- "step": 10
17
- },
18
- {
19
- "grad_norm": 0.43105757236480713,
20
- "learning_rate": 5e-05,
21
- "loss": 1.1547,
22
- "step": 20
23
- },
24
- {
25
- "grad_norm": 0.21635770797729492,
26
- "learning_rate": 1.0099138635988026e-05,
27
- "loss": 1.1113,
28
- "step": 30
29
- }
30
- ],
31
- "logging_steps": 10,
32
- "max_steps": 36,
33
- "num_input_tokens_seen": 0,
34
- "num_train_epochs": 9223372036854775807,
35
- "save_steps": 12,
36
- "stateful_callbacks": {
37
- "TrainerControl": {
38
- "args": {
39
- "should_epoch_stop": false,
40
- "should_evaluate": false,
41
- "should_log": false,
42
- "should_save": true,
43
- "should_training_stop": true
44
- },
45
- "attributes": {}
46
- }
47
- },
48
- "total_flos": 0.0,
49
- "train_batch_size": 128,
50
- "trial_name": null,
51
- "trial_params": null
52
- }
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
checkpoint-36/training_args.bin DELETED
@@ -1,3 +0,0 @@
1
- version https://git-lfs.github.com/spec/v1
2
- oid sha256:0e452e88d907f225ae7ff35acf6f7424dcd56675dd06a0150a7e565d7bf870ac
3
- size 7633
 
 
 
 
checkpoint-36/wandb_config.json DELETED
@@ -1 +0,0 @@
1
- {"project": "finetune-gr00t-n1d6", "run_id": "g1_finetune"}
 
 
checkpoint-36/zero_to_fp32.py DELETED
@@ -1,760 +0,0 @@
1
- #!/usr/bin/env python
2
-
3
- # Copyright (c) Microsoft Corporation.
4
- # SPDX-License-Identifier: Apache-2.0
5
-
6
- # DeepSpeed Team
7
-
8
- # This script extracts fp32 consolidated weights from a zero 1, 2 and 3 DeepSpeed checkpoints. It gets
9
- # copied into the top level checkpoint dir, so the user can easily do the conversion at any point in
10
- # the future. Once extracted, the weights don't require DeepSpeed and can be used in any
11
- # application.
12
- #
13
- # example:
14
- # python zero_to_fp32.py . output_dir/
15
- # or
16
- # python zero_to_fp32.py . output_dir/ --safe_serialization
17
-
18
- import argparse
19
- import torch
20
- import glob
21
- import math
22
- import os
23
- import re
24
- import gc
25
- import json
26
- import numpy as np
27
- from tqdm import tqdm
28
- from collections import OrderedDict
29
- from dataclasses import dataclass
30
-
31
- # while this script doesn't use deepspeed to recover data, since the checkpoints are pickled with
32
- # DeepSpeed data structures it has to be available in the current python environment.
33
- from deepspeed.utils import logger
34
- from deepspeed.checkpoint.constants import (DS_VERSION, OPTIMIZER_STATE_DICT, SINGLE_PARTITION_OF_FP32_GROUPS,
35
- FP32_FLAT_GROUPS, ZERO_STAGE, PARTITION_COUNT, PARAM_SHAPES, BUFFER_NAMES,
36
- FROZEN_PARAM_SHAPES, FROZEN_PARAM_FRAGMENTS)
37
-
38
-
39
- @dataclass
40
- class zero_model_state:
41
- buffers: dict()
42
- param_shapes: dict()
43
- shared_params: list
44
- ds_version: int
45
- frozen_param_shapes: dict()
46
- frozen_param_fragments: dict()
47
-
48
-
49
- debug = 0
50
-
51
- # load to cpu
52
- device = torch.device('cpu')
53
-
54
-
55
- def atoi(text):
56
- return int(text) if text.isdigit() else text
57
-
58
-
59
- def natural_keys(text):
60
- '''
61
- alist.sort(key=natural_keys) sorts in human order
62
- http://nedbatchelder.com/blog/200712/human_sorting.html
63
- (See Toothy's implementation in the comments)
64
- '''
65
- return [atoi(c) for c in re.split(r'(\d+)', text)]
66
-
67
-
68
- def get_model_state_file(checkpoint_dir, zero_stage):
69
- if not os.path.isdir(checkpoint_dir):
70
- raise FileNotFoundError(f"Directory '{checkpoint_dir}' doesn't exist")
71
-
72
- # there should be only one file
73
- if zero_stage <= 2:
74
- file = os.path.join(checkpoint_dir, "mp_rank_00_model_states.pt")
75
- elif zero_stage == 3:
76
- file = os.path.join(checkpoint_dir, "zero_pp_rank_0_mp_rank_00_model_states.pt")
77
-
78
- if not os.path.exists(file):
79
- raise FileNotFoundError(f"can't find model states file at '{file}'")
80
-
81
- return file
82
-
83
-
84
- def get_checkpoint_files(checkpoint_dir, glob_pattern):
85
- # XXX: need to test that this simple glob rule works for multi-node setup too
86
- ckpt_files = sorted(glob.glob(os.path.join(checkpoint_dir, glob_pattern)), key=natural_keys)
87
-
88
- if len(ckpt_files) == 0:
89
- raise FileNotFoundError(f"can't find {glob_pattern} files in directory '{checkpoint_dir}'")
90
-
91
- return ckpt_files
92
-
93
-
94
- def get_optim_files(checkpoint_dir):
95
- return get_checkpoint_files(checkpoint_dir, "*_optim_states.pt")
96
-
97
-
98
- def get_model_state_files(checkpoint_dir):
99
- return get_checkpoint_files(checkpoint_dir, "*_model_states.pt")
100
-
101
-
102
- def parse_model_states(files):
103
- zero_model_states = []
104
- for file in files:
105
- state_dict = torch.load(file, map_location=device, weights_only=False)
106
-
107
- if BUFFER_NAMES not in state_dict:
108
- raise ValueError(f"{file} is not a model state checkpoint")
109
- buffer_names = state_dict[BUFFER_NAMES]
110
- if debug:
111
- print("Found buffers:", buffer_names)
112
-
113
- # recover just the buffers while restoring them to fp32 if they were saved in fp16
114
- buffers = {k: v.float() for k, v in state_dict["module"].items() if k in buffer_names}
115
- param_shapes = state_dict[PARAM_SHAPES]
116
-
117
- # collect parameters that are included in param_shapes
118
- param_names = []
119
- for s in param_shapes:
120
- for name in s.keys():
121
- param_names.append(name)
122
-
123
- # update with frozen parameters
124
- frozen_param_shapes = state_dict.get(FROZEN_PARAM_SHAPES, None)
125
- if frozen_param_shapes is not None:
126
- if debug:
127
- print(f"Found frozen_param_shapes: {frozen_param_shapes}")
128
- param_names += list(frozen_param_shapes.keys())
129
-
130
- # handle shared params
131
- shared_params = [[k, v] for k, v in state_dict["shared_params"].items()]
132
-
133
- ds_version = state_dict.get(DS_VERSION, None)
134
-
135
- frozen_param_fragments = state_dict.get(FROZEN_PARAM_FRAGMENTS, None)
136
-
137
- z_model_state = zero_model_state(buffers=buffers,
138
- param_shapes=param_shapes,
139
- shared_params=shared_params,
140
- ds_version=ds_version,
141
- frozen_param_shapes=frozen_param_shapes,
142
- frozen_param_fragments=frozen_param_fragments)
143
- zero_model_states.append(z_model_state)
144
-
145
- return zero_model_states
146
-
147
-
148
- def parse_optim_states(files, ds_checkpoint_dir):
149
- total_files = len(files)
150
- state_dicts = []
151
- for f in tqdm(files, desc='Loading checkpoint shards'):
152
- state_dict = torch.load(f, map_location=device, mmap=True, weights_only=False)
153
- # immediately discard the potentially huge 2 optimizer states as we only care for fp32 master weights
154
- # and also handle the case where it was already removed by another helper script
155
- state_dict["optimizer_state_dict"].pop("optimizer_state_dict", None)
156
- state_dicts.append(state_dict)
157
-
158
- if ZERO_STAGE not in state_dicts[0][OPTIMIZER_STATE_DICT]:
159
- raise ValueError(f"{files[0]} is not a zero checkpoint")
160
- zero_stage = state_dicts[0][OPTIMIZER_STATE_DICT][ZERO_STAGE]
161
- world_size = state_dicts[0][OPTIMIZER_STATE_DICT][PARTITION_COUNT]
162
-
163
- # For ZeRO-2 each param group can have different partition_count as data parallelism for expert
164
- # parameters can be different from data parallelism for non-expert parameters. So we can just
165
- # use the max of the partition_count to get the dp world_size.
166
-
167
- if type(world_size) is list:
168
- world_size = max(world_size)
169
-
170
- if world_size != total_files:
171
- raise ValueError(
172
- f"Expected {world_size} of '*_optim_states.pt' under '{ds_checkpoint_dir}' but found {total_files} files. "
173
- "Possibly due to an overwrite of an old checkpoint, or a checkpoint didn't get saved by one or more processes."
174
- )
175
-
176
- # the groups are named differently in each stage
177
- if zero_stage <= 2:
178
- fp32_groups_key = SINGLE_PARTITION_OF_FP32_GROUPS
179
- elif zero_stage == 3:
180
- fp32_groups_key = FP32_FLAT_GROUPS
181
- else:
182
- raise ValueError(f"unknown zero stage {zero_stage}")
183
-
184
- fp32_flat_groups = [state_dicts[i][OPTIMIZER_STATE_DICT][fp32_groups_key] for i in range(len(state_dicts))]
185
- return zero_stage, world_size, fp32_flat_groups
186
-
187
-
188
- def _get_fp32_state_dict_from_zero_checkpoint(ds_checkpoint_dir, exclude_frozen_parameters):
189
- """
190
- Returns fp32 state_dict reconstructed from ds checkpoint
191
-
192
- Args:
193
- - ``ds_checkpoint_dir``: path to the deepspeed checkpoint folder (where the optimizer files are)
194
-
195
- """
196
- print(f"Processing zero checkpoint '{ds_checkpoint_dir}'")
197
-
198
- optim_files = get_optim_files(ds_checkpoint_dir)
199
- zero_stage, world_size, fp32_flat_groups = parse_optim_states(optim_files, ds_checkpoint_dir)
200
- print(f"Detected checkpoint of type zero stage {zero_stage}, world_size: {world_size}")
201
-
202
- model_files = get_model_state_files(ds_checkpoint_dir)
203
-
204
- zero_model_states = parse_model_states(model_files)
205
- print(f'Parsing checkpoint created by deepspeed=={zero_model_states[0].ds_version}')
206
-
207
- if zero_stage <= 2:
208
- return _get_fp32_state_dict_from_zero2_checkpoint(world_size, fp32_flat_groups, zero_model_states,
209
- exclude_frozen_parameters)
210
- elif zero_stage == 3:
211
- return _get_fp32_state_dict_from_zero3_checkpoint(world_size, fp32_flat_groups, zero_model_states,
212
- exclude_frozen_parameters)
213
-
214
-
215
- def _zero2_merge_frozen_params(state_dict, zero_model_states):
216
- if zero_model_states[0].frozen_param_shapes is None or len(zero_model_states[0].frozen_param_shapes) == 0:
217
- return
218
-
219
- frozen_param_shapes = zero_model_states[0].frozen_param_shapes
220
- frozen_param_fragments = zero_model_states[0].frozen_param_fragments
221
-
222
- if debug:
223
- num_elem = sum(s.numel() for s in frozen_param_shapes.values())
224
- print(f'rank 0: {FROZEN_PARAM_SHAPES}.numel = {num_elem}')
225
-
226
- wanted_params = len(frozen_param_shapes)
227
- wanted_numel = sum(s.numel() for s in frozen_param_shapes.values())
228
- avail_numel = sum([p.numel() for p in frozen_param_fragments.values()])
229
- print(f'Frozen params: Have {avail_numel} numels to process.')
230
- print(f'Frozen params: Need {wanted_numel} numels in {wanted_params} params')
231
-
232
- total_params = 0
233
- total_numel = 0
234
- for name, shape in frozen_param_shapes.items():
235
- total_params += 1
236
- unpartitioned_numel = shape.numel()
237
- total_numel += unpartitioned_numel
238
-
239
- state_dict[name] = frozen_param_fragments[name]
240
-
241
- if debug:
242
- print(f"{name} full shape: {shape} unpartitioned numel {unpartitioned_numel} ")
243
-
244
- print(f"Reconstructed Frozen fp32 state dict with {total_params} params {total_numel} elements")
245
-
246
-
247
- def _has_callable(obj, fn):
248
- attr = getattr(obj, fn, None)
249
- return callable(attr)
250
-
251
-
252
- def _zero2_merge_trainable_params(state_dict, world_size, fp32_flat_groups, zero_model_states):
253
- param_shapes = zero_model_states[0].param_shapes
254
-
255
- # Reconstruction protocol:
256
- #
257
- # XXX: document this
258
-
259
- if debug:
260
- for i in range(world_size):
261
- for j in range(len(fp32_flat_groups[0])):
262
- print(f"{FP32_FLAT_GROUPS}[{i}][{j}].shape={fp32_flat_groups[i][j].shape}")
263
-
264
- # XXX: memory usage doubles here (zero2)
265
- num_param_groups = len(fp32_flat_groups[0])
266
- merged_single_partition_of_fp32_groups = []
267
- for i in range(num_param_groups):
268
- merged_partitions = [sd[i] for sd in fp32_flat_groups]
269
- full_single_fp32_vector = torch.cat(merged_partitions, 0)
270
- merged_single_partition_of_fp32_groups.append(full_single_fp32_vector)
271
- avail_numel = sum(
272
- [full_single_fp32_vector.numel() for full_single_fp32_vector in merged_single_partition_of_fp32_groups])
273
-
274
- if debug:
275
- wanted_params = sum([len(shapes) for shapes in param_shapes])
276
- wanted_numel = sum([sum(shape.numel() for shape in shapes.values()) for shapes in param_shapes])
277
- # not asserting if there is a mismatch due to possible padding
278
- print(f"Have {avail_numel} numels to process.")
279
- print(f"Need {wanted_numel} numels in {wanted_params} params.")
280
-
281
- # params
282
- # XXX: for huge models that can't fit into the host's RAM we will have to recode this to support
283
- # out-of-core computing solution
284
- total_numel = 0
285
- total_params = 0
286
- for shapes, full_single_fp32_vector in zip(param_shapes, merged_single_partition_of_fp32_groups):
287
- offset = 0
288
- avail_numel = full_single_fp32_vector.numel()
289
- for name, shape in shapes.items():
290
-
291
- unpartitioned_numel = shape.numel() if _has_callable(shape, 'numel') else math.prod(shape)
292
- total_numel += unpartitioned_numel
293
- total_params += 1
294
-
295
- if debug:
296
- print(f"{name} full shape: {shape} unpartitioned numel {unpartitioned_numel} ")
297
- state_dict[name] = full_single_fp32_vector.narrow(0, offset, unpartitioned_numel).view(shape)
298
- offset += unpartitioned_numel
299
-
300
- # Z2 started to align to 2*world_size to improve nccl performance. Therefore both offset and
301
- # avail_numel can differ by anywhere between 0..2*world_size. Due to two unrelated complex
302
- # paddings performed in the code it's almost impossible to predict the exact numbers w/o the
303
- # live optimizer object, so we are checking that the numbers are within the right range
304
- align_to = 2 * world_size
305
-
306
- def zero2_align(x):
307
- return align_to * math.ceil(x / align_to)
308
-
309
- if debug:
310
- print(f"original offset={offset}, avail_numel={avail_numel}")
311
-
312
- offset = zero2_align(offset)
313
- avail_numel = zero2_align(avail_numel)
314
-
315
- if debug:
316
- print(f"aligned offset={offset}, avail_numel={avail_numel}")
317
-
318
- # Sanity check
319
- if offset != avail_numel:
320
- raise ValueError(f"consumed {offset} numels out of {avail_numel} - something is wrong")
321
-
322
- print(f"Reconstructed fp32 state dict with {total_params} params {total_numel} elements")
323
-
324
-
325
- def _get_fp32_state_dict_from_zero2_checkpoint(world_size, fp32_flat_groups, zero_model_states,
326
- exclude_frozen_parameters):
327
- state_dict = OrderedDict()
328
-
329
- # buffers
330
- buffers = zero_model_states[0].buffers
331
- state_dict.update(buffers)
332
- if debug:
333
- print(f"added {len(buffers)} buffers")
334
-
335
- if not exclude_frozen_parameters:
336
- _zero2_merge_frozen_params(state_dict, zero_model_states)
337
-
338
- _zero2_merge_trainable_params(state_dict, world_size, fp32_flat_groups, zero_model_states)
339
-
340
- # recover shared parameters
341
- for pair in zero_model_states[0].shared_params:
342
- if pair[1] in state_dict:
343
- state_dict[pair[0]] = state_dict[pair[1]]
344
-
345
- return state_dict
346
-
347
-
348
- def zero3_partitioned_param_info(unpartitioned_numel, world_size):
349
- remainder = unpartitioned_numel % world_size
350
- padding_numel = (world_size - remainder) if remainder else 0
351
- partitioned_numel = math.ceil(unpartitioned_numel / world_size)
352
- return partitioned_numel, padding_numel
353
-
354
-
355
- def _zero3_merge_frozen_params(state_dict, world_size, zero_model_states):
356
- if zero_model_states[0].frozen_param_shapes is None or len(zero_model_states[0].frozen_param_shapes) == 0:
357
- return
358
-
359
- if debug:
360
- for i in range(world_size):
361
- num_elem = sum(s.numel() for s in zero_model_states[i].frozen_param_fragments.values())
362
- print(f'rank {i}: {FROZEN_PARAM_SHAPES}.numel = {num_elem}')
363
-
364
- frozen_param_shapes = zero_model_states[0].frozen_param_shapes
365
- wanted_params = len(frozen_param_shapes)
366
- wanted_numel = sum(s.numel() for s in frozen_param_shapes.values())
367
- avail_numel = sum([p.numel() for p in zero_model_states[0].frozen_param_fragments.values()]) * world_size
368
- print(f'Frozen params: Have {avail_numel} numels to process.')
369
- print(f'Frozen params: Need {wanted_numel} numels in {wanted_params} params')
370
-
371
- total_params = 0
372
- total_numel = 0
373
- for name, shape in zero_model_states[0].frozen_param_shapes.items():
374
- total_params += 1
375
- unpartitioned_numel = shape.numel()
376
- total_numel += unpartitioned_numel
377
-
378
- param_frags = tuple(model_state.frozen_param_fragments[name] for model_state in zero_model_states)
379
- state_dict[name] = torch.cat(param_frags, 0).narrow(0, 0, unpartitioned_numel).view(shape)
380
-
381
- partitioned_numel, partitioned_padding_numel = zero3_partitioned_param_info(unpartitioned_numel, world_size)
382
-
383
- if debug:
384
- print(
385
- f"Frozen params: {total_params} {name} full shape: {shape} partition0 numel={partitioned_numel} partitioned_padding_numel={partitioned_padding_numel}"
386
- )
387
-
388
- print(f"Reconstructed Frozen fp32 state dict with {total_params} params {total_numel} elements")
389
-
390
-
391
- class GatheredTensor:
392
- """
393
- A pseudo tensor that collects partitioned weights.
394
- It is more memory efficient when there are multiple groups.
395
- """
396
-
397
- def __init__(self, flat_groups, flat_groups_offset, offset, partitioned_numel, shape):
398
- self.flat_groups = flat_groups
399
- self.flat_groups_offset = flat_groups_offset
400
- self.offset = offset
401
- self.partitioned_numel = partitioned_numel
402
- self.shape = shape
403
- self.dtype = self.flat_groups[0][0].dtype
404
-
405
- def contiguous(self):
406
- """
407
- Merge partitioned weights from flat_groups into a single tensor.
408
- """
409
- end_idx = self.offset + self.partitioned_numel
410
- world_size = len(self.flat_groups)
411
- pad_flat_param_chunks = []
412
-
413
- for rank_i in range(world_size):
414
- # for each rank, we need to collect weights from related group/groups
415
- flat_groups_at_rank_i = self.flat_groups[rank_i]
416
- start_group_id = None
417
- end_group_id = None
418
- for group_id in range(len(self.flat_groups_offset)):
419
- if self.flat_groups_offset[group_id] <= self.offset < self.flat_groups_offset[group_id + 1]:
420
- start_group_id = group_id
421
- if self.flat_groups_offset[group_id] < end_idx <= self.flat_groups_offset[group_id + 1]:
422
- end_group_id = group_id
423
- break
424
- # collect weights from related group/groups
425
- for group_id in range(start_group_id, end_group_id + 1):
426
- flat_tensor = flat_groups_at_rank_i[group_id]
427
- start_offset = self.offset - self.flat_groups_offset[group_id]
428
- end_offset = min(end_idx, self.flat_groups_offset[group_id + 1]) - self.flat_groups_offset[group_id]
429
- pad_flat_param_chunks.append(flat_tensor[start_offset:end_offset])
430
-
431
- # collect weights from all ranks
432
- pad_flat_param = torch.cat(pad_flat_param_chunks, dim=0)
433
- param = pad_flat_param[:self.shape.numel()].view(self.shape).contiguous()
434
- return param
435
-
436
-
437
- def _zero3_merge_trainable_params(state_dict, world_size, fp32_flat_groups, zero_model_states):
438
- param_shapes = zero_model_states[0].param_shapes
439
- avail_numel = sum([flat_group.numel() for flat_group in fp32_flat_groups[0]]) * world_size
440
-
441
- # Reconstruction protocol: For zero3 we need to zip the partitions together at boundary of each
442
- # param, re-consolidating each param, while dealing with padding if any
443
-
444
- # merge list of dicts, preserving order
445
- param_shapes = {k: v for d in param_shapes for k, v in d.items()}
446
-
447
- if debug:
448
- for i in range(world_size):
449
- print(f"{FP32_FLAT_GROUPS}[{i}].shape={fp32_flat_groups[i].shape}")
450
-
451
- wanted_params = len(param_shapes)
452
- wanted_numel = sum(shape.numel() for shape in param_shapes.values())
453
- # not asserting if there is a mismatch due to possible padding
454
- avail_numel = fp32_flat_groups[0].numel() * world_size
455
- print(f"Trainable params: Have {avail_numel} numels to process.")
456
- print(f"Trainable params: Need {wanted_numel} numels in {wanted_params} params.")
457
-
458
- # params
459
- # XXX: for huge models that can't fit into the host's RAM we will have to recode this to support
460
- # out-of-core computing solution
461
- offset = 0
462
- total_numel = 0
463
- total_params = 0
464
- flat_groups_offset = [0] + list(np.cumsum([flat_tensor.numel() for flat_tensor in fp32_flat_groups[0]]))
465
- for name, shape in tqdm(param_shapes.items(), desc='Gathering sharded weights'):
466
- unpartitioned_numel = shape.numel()
467
- total_numel += unpartitioned_numel
468
- total_params += 1
469
- partitioned_numel, partitioned_padding_numel = zero3_partitioned_param_info(unpartitioned_numel, world_size)
470
-
471
- if debug:
472
- print(
473
- f"Trainable params: {total_params} {name} full shape: {shape} partition0 numel={partitioned_numel} partitioned_padding_numel={partitioned_padding_numel}"
474
- )
475
-
476
- # memory efficient tensor
477
- tensor = GatheredTensor(fp32_flat_groups, flat_groups_offset, offset, partitioned_numel, shape)
478
- state_dict[name] = tensor
479
- offset += partitioned_numel
480
-
481
- offset *= world_size
482
-
483
- # Sanity check
484
- if offset != avail_numel:
485
- raise ValueError(f"consumed {offset} numels out of {avail_numel} - something is wrong")
486
-
487
- print(f"Reconstructed Trainable fp32 state dict with {total_params} params {total_numel} elements")
488
-
489
-
490
- def _get_fp32_state_dict_from_zero3_checkpoint(world_size, fp32_flat_groups, zero_model_states,
491
- exclude_frozen_parameters):
492
- state_dict = OrderedDict()
493
-
494
- # buffers
495
- buffers = zero_model_states[0].buffers
496
- state_dict.update(buffers)
497
- if debug:
498
- print(f"added {len(buffers)} buffers")
499
-
500
- if not exclude_frozen_parameters:
501
- _zero3_merge_frozen_params(state_dict, world_size, zero_model_states)
502
-
503
- _zero3_merge_trainable_params(state_dict, world_size, fp32_flat_groups, zero_model_states)
504
-
505
- # recover shared parameters
506
- for pair in zero_model_states[0].shared_params:
507
- if pair[1] in state_dict:
508
- state_dict[pair[0]] = state_dict[pair[1]]
509
-
510
- return state_dict
511
-
512
-
513
- def to_torch_tensor(state_dict, return_empty_tensor=False):
514
- """
515
- Convert state_dict of GatheredTensor to torch tensor
516
- """
517
- torch_state_dict = {}
518
- converted_tensors = {}
519
- for name, tensor in state_dict.items():
520
- tensor_id = id(tensor)
521
- if tensor_id in converted_tensors: # shared tensors
522
- shared_tensor = torch_state_dict[converted_tensors[tensor_id]]
523
- torch_state_dict[name] = shared_tensor
524
- else:
525
- converted_tensors[tensor_id] = name
526
- if return_empty_tensor:
527
- torch_state_dict[name] = torch.empty(tensor.shape, dtype=tensor.dtype)
528
- else:
529
- torch_state_dict[name] = tensor.contiguous()
530
- return torch_state_dict
531
-
532
-
533
- def get_fp32_state_dict_from_zero_checkpoint(checkpoint_dir,
534
- tag=None,
535
- exclude_frozen_parameters=False,
536
- lazy_mode=False):
537
- """
538
- Convert ZeRO 2 or 3 checkpoint into a single fp32 consolidated state_dict that can be loaded with
539
- ``load_state_dict()`` and used for training without DeepSpeed or shared with others, for example
540
- via a model hub.
541
-
542
- Args:
543
- - ``checkpoint_dir``: path to the desired checkpoint folder
544
- - ``tag``: checkpoint tag used as a unique identifier for checkpoint. If not provided will attempt to load tag in 'latest' file. e.g., ``global_step14``
545
- - ``exclude_frozen_parameters``: exclude frozen parameters
546
- - ``lazy_mode``: get state_dict in lazy mode. It returns a dict of pesduo tensor instead of torch tensor, which is more memory efficient.
547
- Convert the pesduo tensor to torch tensor by ``.contiguous()``
548
-
549
- Returns:
550
- - pytorch ``state_dict``
551
-
552
- A typical usage might be ::
553
-
554
- from deepspeed.utils.zero_to_fp32 import get_fp32_state_dict_from_zero_checkpoint
555
- # do the training and checkpoint saving
556
- state_dict = get_fp32_state_dict_from_zero_checkpoint(checkpoint_dir) # already on cpu
557
- model = model.cpu() # move to cpu
558
- model.load_state_dict(state_dict)
559
- # submit to model hub or save the model to share with others
560
-
561
- In this example the ``model`` will no longer be usable in the deepspeed context of the same
562
- application. i.e. you will need to re-initialize the deepspeed engine, since
563
- ``model.load_state_dict(state_dict)`` will remove all the deepspeed magic from it.
564
-
565
- If you want it all done for you, use ``load_state_dict_from_zero_checkpoint`` instead.
566
-
567
- Note: the above usage may not work if your application doesn't have sufficient free CPU memory.
568
- You may need to use the offline approach using the ``zero_to_fp32.py`` script that is saved with
569
- the checkpoint. Or you can load state_dict in lazy mode ::
570
-
571
- from deepspeed.utils.zero_to_fp32 import get_fp32_state_dict_from_zero_checkpoint
572
- state_dict = get_fp32_state_dict_from_zero_checkpoint(checkpoint_dir, lazy_mode=True) # not on cpu
573
- for name, lazy_tensor in state_dict.item():
574
- tensor = lazy_tensor.contiguous() # to cpu
575
- print(name, tensor)
576
- # del tensor to release memory if it no longer in use
577
- """
578
- if tag is None:
579
- latest_path = os.path.join(checkpoint_dir, 'latest')
580
- if os.path.isfile(latest_path):
581
- with open(latest_path, 'r') as fd:
582
- tag = fd.read().strip()
583
- else:
584
- raise ValueError(f"Unable to find 'latest' file at {latest_path}")
585
-
586
- ds_checkpoint_dir = os.path.join(checkpoint_dir, tag)
587
-
588
- if not os.path.isdir(ds_checkpoint_dir):
589
- raise FileNotFoundError(f"Directory '{ds_checkpoint_dir}' doesn't exist")
590
-
591
- state_dict = _get_fp32_state_dict_from_zero_checkpoint(ds_checkpoint_dir, exclude_frozen_parameters)
592
- if lazy_mode:
593
- return state_dict
594
- else:
595
- return to_torch_tensor(state_dict)
596
-
597
-
598
- def convert_zero_checkpoint_to_fp32_state_dict(checkpoint_dir,
599
- output_dir,
600
- max_shard_size="5GB",
601
- safe_serialization=False,
602
- tag=None,
603
- exclude_frozen_parameters=False):
604
- """
605
- Convert ZeRO 2 or 3 checkpoint into a single fp32 consolidated ``state_dict`` file that can be
606
- loaded with ``torch.load(file)`` + ``load_state_dict()`` and used for training without DeepSpeed.
607
-
608
- Args:
609
- - ``checkpoint_dir``: path to the desired checkpoint folder. (one that contains the tag-folder, like ``global_step14``)
610
- - ``output_dir``: directory to the pytorch fp32 state_dict output files
611
- - ``max_shard_size``: the maximum size for a checkpoint before being sharded, default value is 5GB
612
- - ``safe_serialization``: whether to save the model using `safetensors` or the traditional PyTorch way (that uses `pickle`).
613
- - ``tag``: checkpoint tag used as a unique identifier for checkpoint. If not provided will attempt to load tag in the file named ``latest`` in the checkpoint folder, e.g., ``global_step14``
614
- - ``exclude_frozen_parameters``: exclude frozen parameters
615
- """
616
-
617
- # Dependency pre-check
618
- if safe_serialization:
619
- try:
620
- from safetensors.torch import save_file
621
- except ImportError:
622
- print('If you want to use `safe_serialization`, please `pip install safetensors`')
623
- raise
624
- if max_shard_size is not None:
625
- try:
626
- from huggingface_hub import split_torch_state_dict_into_shards
627
- except ImportError:
628
- print('If you want to use `max_shard_size`, please `pip install huggingface_hub`')
629
- raise
630
-
631
- # Convert zero checkpoint to state_dict
632
- state_dict = get_fp32_state_dict_from_zero_checkpoint(checkpoint_dir,
633
- tag,
634
- exclude_frozen_parameters,
635
- lazy_mode=True)
636
-
637
- # Shard the model if it is too big.
638
- weights_name = "model.safetensors" if safe_serialization else "pytorch_model.bin"
639
- if max_shard_size is not None:
640
- filename_pattern = weights_name.replace(".bin", "{suffix}.bin").replace(".safetensors", "{suffix}.safetensors")
641
- # an memory-efficient approach for sharding
642
- empty_state_dict = to_torch_tensor(state_dict, return_empty_tensor=True)
643
- state_dict_split = split_torch_state_dict_into_shards(empty_state_dict,
644
- filename_pattern=filename_pattern,
645
- max_shard_size=max_shard_size)
646
- else:
647
- from collections import namedtuple
648
- StateDictSplit = namedtuple("StateDictSplit", ["is_sharded", "filename_to_tensors"])
649
- state_dict_split = StateDictSplit(is_sharded=False,
650
- filename_to_tensors={weights_name: list(state_dict.keys())})
651
-
652
- # Save the model by shard
653
- os.makedirs(output_dir, exist_ok=True)
654
- filename_to_tensors = state_dict_split.filename_to_tensors.items()
655
- for shard_file, tensors in tqdm(filename_to_tensors, desc="Saving checkpoint shards"):
656
- shard_state_dict = {tensor_name: state_dict[tensor_name] for tensor_name in tensors}
657
- shard_state_dict = to_torch_tensor(shard_state_dict)
658
- output_path = os.path.join(output_dir, shard_file)
659
- if safe_serialization:
660
- save_file(shard_state_dict, output_path, metadata={"format": "pt"})
661
- else:
662
- torch.save(shard_state_dict, output_path)
663
- # release the memory of current shard
664
- for tensor_name in list(shard_state_dict.keys()):
665
- del state_dict[tensor_name]
666
- del shard_state_dict[tensor_name]
667
- del shard_state_dict
668
- gc.collect()
669
-
670
- # Save index if sharded
671
- if state_dict_split.is_sharded:
672
- index = {
673
- "metadata": state_dict_split.metadata,
674
- "weight_map": state_dict_split.tensor_to_filename,
675
- }
676
- save_index_file = "model.safetensors.index.json" if safe_serialization else "pytorch_model.bin.index.json"
677
- save_index_file = os.path.join(output_dir, save_index_file)
678
- with open(save_index_file, "w", encoding="utf-8") as f:
679
- content = json.dumps(index, indent=2, sort_keys=True) + "\n"
680
- f.write(content)
681
-
682
-
683
- def load_state_dict_from_zero_checkpoint(model, checkpoint_dir, tag=None):
684
- """
685
- 1. Put the provided model to cpu
686
- 2. Convert ZeRO 2 or 3 checkpoint into a single fp32 consolidated ``state_dict``
687
- 3. Load it into the provided model
688
-
689
- Args:
690
- - ``model``: the model object to update
691
- - ``checkpoint_dir``: path to the desired checkpoint folder. (one that contains the tag-folder, like ``global_step14``)
692
- - ``tag``: checkpoint tag used as a unique identifier for checkpoint. If not provided will attempt to load tag in the file named ``latest`` in the checkpoint folder, e.g., ``global_step14``
693
-
694
- Returns:
695
- - ``model`: modified model
696
-
697
- Make sure you have plenty of CPU memory available before you call this function. If you don't
698
- have enough use the ``zero_to_fp32.py`` utility to do the conversion. You will find it
699
- conveniently placed for you in the checkpoint folder.
700
-
701
- A typical usage might be ::
702
-
703
- from deepspeed.utils.zero_to_fp32 import load_state_dict_from_zero_checkpoint
704
- model = load_state_dict_from_zero_checkpoint(trainer.model, checkpoint_dir)
705
- # submit to model hub or save the model to share with others
706
-
707
- Note, that once this was run, the ``model`` will no longer be usable in the deepspeed context
708
- of the same application. i.e. you will need to re-initialize the deepspeed engine, since
709
- ``model.load_state_dict(state_dict)`` will remove all the deepspeed magic from it.
710
-
711
- """
712
- logger.info("Extracting fp32 weights")
713
- state_dict = get_fp32_state_dict_from_zero_checkpoint(checkpoint_dir, tag)
714
-
715
- logger.info("Overwriting model with fp32 weights")
716
- model = model.cpu()
717
- model.load_state_dict(state_dict, strict=False)
718
-
719
- return model
720
-
721
-
722
- if __name__ == "__main__":
723
- parser = argparse.ArgumentParser()
724
- parser.add_argument("checkpoint_dir",
725
- type=str,
726
- help="path to the desired checkpoint folder, e.g., path/checkpoint-12")
727
- parser.add_argument("output_dir",
728
- type=str,
729
- help="directory to the pytorch fp32 state_dict output files"
730
- "(e.g. path/checkpoint-12-output/)")
731
- parser.add_argument(
732
- "--max_shard_size",
733
- type=str,
734
- default="5GB",
735
- help="The maximum size for a checkpoint before being sharded. Checkpoints shard will then be each of size"
736
- "lower than this size. If expressed as a string, needs to be digits followed by a unit (like `5MB`"
737
- "We default it to 5GB in order for models to be able to run easily on free-tier google colab instances"
738
- "without CPU OOM issues.")
739
- parser.add_argument(
740
- "--safe_serialization",
741
- default=False,
742
- action='store_true',
743
- help="Whether to save the model using `safetensors` or the traditional PyTorch way (that uses `pickle`).")
744
- parser.add_argument("-t",
745
- "--tag",
746
- type=str,
747
- default=None,
748
- help="checkpoint tag used as a unique identifier for checkpoint. e.g., global_step1")
749
- parser.add_argument("--exclude_frozen_parameters", action='store_true', help="exclude frozen parameters")
750
- parser.add_argument("-d", "--debug", action='store_true', help="enable debug")
751
- args = parser.parse_args()
752
-
753
- debug = args.debug
754
-
755
- convert_zero_checkpoint_to_fp32_state_dict(args.checkpoint_dir,
756
- args.output_dir,
757
- max_shard_size=args.max_shard_size,
758
- safe_serialization=args.safe_serialization,
759
- tag=args.tag,
760
- exclude_frozen_parameters=args.exclude_frozen_parameters)