FutureMa commited on
Commit
c74eb66
·
verified ·
1 Parent(s): 0b696f4

Upload final model: 100% trained (406/406 steps) on ms-swift analysis dataset

Browse files
Files changed (37) hide show
  1. .gitattributes +1 -0
  2. args.json +378 -0
  3. chat_template.jinja +61 -0
  4. config.json +71 -0
  5. generation_config.json +13 -0
  6. global_step406/bf16_zero_pp_rank_0_mp_rank_00_optim_states.pt +3 -0
  7. global_step406/bf16_zero_pp_rank_1_mp_rank_00_optim_states.pt +3 -0
  8. global_step406/bf16_zero_pp_rank_2_mp_rank_00_optim_states.pt +3 -0
  9. global_step406/bf16_zero_pp_rank_3_mp_rank_00_optim_states.pt +3 -0
  10. global_step406/bf16_zero_pp_rank_4_mp_rank_00_optim_states.pt +3 -0
  11. global_step406/bf16_zero_pp_rank_5_mp_rank_00_optim_states.pt +3 -0
  12. global_step406/bf16_zero_pp_rank_6_mp_rank_00_optim_states.pt +3 -0
  13. global_step406/bf16_zero_pp_rank_7_mp_rank_00_optim_states.pt +3 -0
  14. global_step406/zero_pp_rank_0_mp_rank_00_model_states.pt +3 -0
  15. global_step406/zero_pp_rank_1_mp_rank_00_model_states.pt +3 -0
  16. global_step406/zero_pp_rank_2_mp_rank_00_model_states.pt +3 -0
  17. global_step406/zero_pp_rank_3_mp_rank_00_model_states.pt +3 -0
  18. global_step406/zero_pp_rank_4_mp_rank_00_model_states.pt +3 -0
  19. global_step406/zero_pp_rank_5_mp_rank_00_model_states.pt +3 -0
  20. global_step406/zero_pp_rank_6_mp_rank_00_model_states.pt +3 -0
  21. global_step406/zero_pp_rank_7_mp_rank_00_model_states.pt +3 -0
  22. latest +1 -0
  23. model.safetensors +3 -0
  24. rng_state_0.pth +3 -0
  25. rng_state_1.pth +3 -0
  26. rng_state_2.pth +3 -0
  27. rng_state_3.pth +3 -0
  28. rng_state_4.pth +3 -0
  29. rng_state_5.pth +3 -0
  30. rng_state_6.pth +3 -0
  31. rng_state_7.pth +3 -0
  32. scheduler.pt +3 -0
  33. tokenizer.json +3 -0
  34. tokenizer_config.json +14 -0
  35. trainer_state.json +362 -0
  36. training_args.bin +3 -0
  37. zero_to_fp32.py +760 -0
.gitattributes CHANGED
@@ -33,3 +33,4 @@ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
33
  *.zip filter=lfs diff=lfs merge=lfs -text
34
  *.zst filter=lfs diff=lfs merge=lfs -text
35
  *tfevents* filter=lfs diff=lfs merge=lfs -text
 
 
33
  *.zip filter=lfs diff=lfs merge=lfs -text
34
  *.zst filter=lfs diff=lfs merge=lfs -text
35
  *tfevents* filter=lfs diff=lfs merge=lfs -text
36
+ tokenizer.json filter=lfs diff=lfs merge=lfs -text
args.json ADDED
@@ -0,0 +1,378 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ {
2
+ "output_dir": "/ephemeral/ms-swift/output/locooperator-4b-msswift-analysis-8xh100-65k/v2-20260303-195906",
3
+ "per_device_train_batch_size": 1,
4
+ "num_train_epochs": 1.0,
5
+ "max_steps": -1,
6
+ "learning_rate": 2e-05,
7
+ "lr_scheduler_type": "cosine",
8
+ "lr_scheduler_kwargs": null,
9
+ "warmup_steps": 0,
10
+ "optim": "adamw_torch_fused",
11
+ "optim_args": null,
12
+ "weight_decay": 0.1,
13
+ "adam_beta1": 0.9,
14
+ "adam_beta2": 0.95,
15
+ "adam_epsilon": 1e-08,
16
+ "optim_target_modules": null,
17
+ "gradient_accumulation_steps": 4,
18
+ "average_tokens_across_devices": true,
19
+ "max_grad_norm": 1.0,
20
+ "label_smoothing_factor": 0.0,
21
+ "bf16": true,
22
+ "fp16": false,
23
+ "bf16_full_eval": false,
24
+ "fp16_full_eval": false,
25
+ "tf32": null,
26
+ "gradient_checkpointing": true,
27
+ "gradient_checkpointing_kwargs": "{\"use_reentrant\": false}",
28
+ "torch_compile": false,
29
+ "torch_compile_backend": null,
30
+ "torch_compile_mode": null,
31
+ "use_liger_kernel": false,
32
+ "liger_kernel_config": null,
33
+ "use_cache": false,
34
+ "neftune_noise_alpha": null,
35
+ "torch_empty_cache_steps": null,
36
+ "auto_find_batch_size": false,
37
+ "logging_strategy": "steps",
38
+ "logging_steps": 10,
39
+ "logging_first_step": true,
40
+ "log_on_each_node": true,
41
+ "logging_nan_inf_filter": true,
42
+ "include_num_input_tokens_seen": false,
43
+ "log_level": "passive",
44
+ "log_level_replica": "warning",
45
+ "disable_tqdm": null,
46
+ "report_to": [
47
+ "tensorboard"
48
+ ],
49
+ "run_name": "/ephemeral/ms-swift/output/locooperator-4b-msswift-analysis-8xh100-65k/v2-20260303-195906",
50
+ "project": "huggingface",
51
+ "trackio_space_id": "trackio",
52
+ "eval_strategy": "no",
53
+ "eval_steps": 200.0,
54
+ "eval_delay": 0,
55
+ "per_device_eval_batch_size": 1,
56
+ "prediction_loss_only": false,
57
+ "eval_on_start": false,
58
+ "eval_do_concat_batches": true,
59
+ "eval_use_gather_object": false,
60
+ "eval_accumulation_steps": null,
61
+ "include_for_metrics": [],
62
+ "batch_eval_metrics": false,
63
+ "save_only_model": false,
64
+ "save_strategy": "steps",
65
+ "save_steps": 200.0,
66
+ "save_on_each_node": false,
67
+ "save_total_limit": 2,
68
+ "enable_jit_checkpoint": false,
69
+ "push_to_hub": false,
70
+ "hub_token": null,
71
+ "hub_private_repo": null,
72
+ "hub_model_id": null,
73
+ "hub_strategy": "every_save",
74
+ "hub_always_push": false,
75
+ "hub_revision": null,
76
+ "load_best_model_at_end": false,
77
+ "metric_for_best_model": "loss",
78
+ "greater_is_better": false,
79
+ "ignore_data_skip": false,
80
+ "restore_callback_states_from_checkpoint": false,
81
+ "full_determinism": false,
82
+ "seed": 42,
83
+ "data_seed": 42,
84
+ "use_cpu": false,
85
+ "accelerator_config": {
86
+ "dispatch_batches": false
87
+ },
88
+ "parallelism_config": null,
89
+ "dataloader_drop_last": false,
90
+ "dataloader_num_workers": 32,
91
+ "dataloader_pin_memory": true,
92
+ "dataloader_persistent_workers": false,
93
+ "dataloader_prefetch_factor": null,
94
+ "remove_unused_columns": true,
95
+ "label_names": null,
96
+ "train_sampling_strategy": "random",
97
+ "length_column_name": "length",
98
+ "ddp_find_unused_parameters": null,
99
+ "ddp_bucket_cap_mb": null,
100
+ "ddp_broadcast_buffers": null,
101
+ "ddp_backend": null,
102
+ "ddp_timeout": 18000000,
103
+ "fsdp": [],
104
+ "fsdp_config": null,
105
+ "deepspeed": {
106
+ "fp16": {
107
+ "enabled": "auto",
108
+ "loss_scale": 0,
109
+ "loss_scale_window": 1000,
110
+ "initial_scale_power": 16,
111
+ "hysteresis": 2,
112
+ "min_loss_scale": 1
113
+ },
114
+ "bf16": {
115
+ "enabled": "auto"
116
+ },
117
+ "zero_optimization": {
118
+ "stage": 3,
119
+ "offload_optimizer": {
120
+ "device": "cpu",
121
+ "pin_memory": true
122
+ },
123
+ "offload_param": {
124
+ "device": "cpu",
125
+ "pin_memory": true
126
+ },
127
+ "overlap_comm": false,
128
+ "contiguous_gradients": true,
129
+ "sub_group_size": 1000000000.0,
130
+ "reduce_bucket_size": "auto",
131
+ "stage3_prefetch_bucket_size": "auto",
132
+ "stage3_param_persistence_threshold": "auto",
133
+ "stage3_max_live_parameters": 1000000000.0,
134
+ "stage3_max_reuse_distance": 1000000000.0,
135
+ "stage3_gather_16bit_weights_on_model_save": true
136
+ },
137
+ "gradient_accumulation_steps": "auto",
138
+ "gradient_clipping": "auto",
139
+ "steps_per_print": 2000,
140
+ "train_batch_size": "auto",
141
+ "train_micro_batch_size_per_gpu": "auto",
142
+ "wall_clock_breakdown": false
143
+ },
144
+ "debug": null,
145
+ "skip_memory_metrics": true,
146
+ "do_train": false,
147
+ "do_eval": false,
148
+ "do_predict": false,
149
+ "resume_from_checkpoint": "/ephemeral/ms-swift/output/locooperator-4b-msswift-analysis-8xh100-65k/v0-20260303-141105/checkpoint-100",
150
+ "warmup_ratio": 0.03,
151
+ "logging_dir": "/ephemeral/ms-swift/output/locooperator-4b-msswift-analysis-8xh100-65k/v2-20260303-195906/runs",
152
+ "local_rank": 0,
153
+ "sortish_sampler": false,
154
+ "predict_with_generate": false,
155
+ "generation_max_length": null,
156
+ "generation_num_beams": null,
157
+ "generation_config": null,
158
+ "tuner_backend": "peft",
159
+ "vit_gradient_checkpointing": null,
160
+ "router_aux_loss_coef": 0.0,
161
+ "enable_dft_loss": false,
162
+ "enable_channel_loss": false,
163
+ "check_model": true,
164
+ "acc_strategy": "token",
165
+ "train_dataloader_shuffle": true,
166
+ "group_by_length": false,
167
+ "max_epochs": null,
168
+ "aligner_lr": null,
169
+ "vit_lr": null,
170
+ "use_logits_to_keep": null,
171
+ "ds3_gather_for_generation": true,
172
+ "resume_only_model": false,
173
+ "optimizer": null,
174
+ "loss_type": null,
175
+ "eval_metric": null,
176
+ "callbacks": [],
177
+ "early_stop_interval": null,
178
+ "eval_use_evalscope": false,
179
+ "eval_dataset": [],
180
+ "eval_dataset_args": null,
181
+ "eval_limit": null,
182
+ "eval_generation_config": null,
183
+ "extra_eval_args": null,
184
+ "tuner_type": "full",
185
+ "use_galore": false,
186
+ "galore_target_modules": null,
187
+ "galore_rank": 128,
188
+ "galore_update_proj_gap": 50,
189
+ "galore_scale": 1.0,
190
+ "galore_proj_type": "std",
191
+ "galore_optim_per_parameter": false,
192
+ "galore_with_embedding": false,
193
+ "galore_quantization": false,
194
+ "galore_proj_quant": false,
195
+ "galore_proj_bits": 4,
196
+ "galore_proj_group_size": 256,
197
+ "galore_cos_threshold": 0.4,
198
+ "galore_gamma_proj": 2,
199
+ "galore_queue_size": 5,
200
+ "lisa_activated_layers": 0,
201
+ "lisa_step_interval": 20,
202
+ "use_flash_ckpt": false,
203
+ "use_ray": false,
204
+ "ray_exp_name": null,
205
+ "device_groups": null,
206
+ "model": "LocoreMind/LocoOperator-4B",
207
+ "model_type": "qwen3",
208
+ "model_revision": null,
209
+ "task_type": "causal_lm",
210
+ "torch_dtype": "bfloat16",
211
+ "attn_impl": null,
212
+ "experts_impl": null,
213
+ "new_special_tokens": [],
214
+ "num_labels": null,
215
+ "problem_type": null,
216
+ "rope_scaling": null,
217
+ "device_map": null,
218
+ "max_memory": {},
219
+ "max_model_len": null,
220
+ "local_repo_path": null,
221
+ "init_strategy": null,
222
+ "template": "qwen3_nothinking",
223
+ "system": null,
224
+ "max_length": 65536,
225
+ "truncation_strategy": "delete",
226
+ "max_pixels": null,
227
+ "agent_template": null,
228
+ "norm_bbox": null,
229
+ "use_chat_template": true,
230
+ "padding_side": "right",
231
+ "padding_free": false,
232
+ "loss_scale": "default",
233
+ "sequence_parallel_size": 1,
234
+ "template_backend": "swift",
235
+ "response_prefix": null,
236
+ "enable_thinking": null,
237
+ "add_non_thinking_prefix": true,
238
+ "dataset": [
239
+ "/home/shadeform/ms-swift/data/ms/msswift-msswift-analysis-train.jsonl"
240
+ ],
241
+ "val_dataset": [],
242
+ "cached_dataset": [],
243
+ "cached_val_dataset": [],
244
+ "split_dataset_ratio": 0.0,
245
+ "dataset_num_proc": 64,
246
+ "load_from_cache_file": false,
247
+ "dataset_shuffle": true,
248
+ "val_dataset_shuffle": false,
249
+ "streaming": false,
250
+ "interleave_prob": null,
251
+ "stopping_strategy": "first_exhausted",
252
+ "shuffle_buffer_size": 1000,
253
+ "download_mode": "reuse_dataset_if_exists",
254
+ "columns": {},
255
+ "strict": false,
256
+ "model_name": null,
257
+ "model_author": null,
258
+ "custom_dataset_info": [],
259
+ "quant_method": null,
260
+ "quant_bits": null,
261
+ "hqq_axis": null,
262
+ "bnb_4bit_compute_dtype": "bfloat16",
263
+ "bnb_4bit_quant_type": "nf4",
264
+ "bnb_4bit_use_double_quant": true,
265
+ "bnb_4bit_quant_storage": null,
266
+ "max_new_tokens": 64,
267
+ "temperature": 0.0,
268
+ "top_k": null,
269
+ "top_p": null,
270
+ "repetition_penalty": null,
271
+ "num_beams": 1,
272
+ "stream": false,
273
+ "stop_words": [],
274
+ "logprobs": false,
275
+ "top_logprobs": null,
276
+ "structured_outputs_regex": null,
277
+ "train_type": null,
278
+ "adapters": [],
279
+ "external_plugins": [],
280
+ "custom_register_path": [],
281
+ "model_kwargs": {},
282
+ "load_args": false,
283
+ "load_data_args": false,
284
+ "packing": false,
285
+ "packing_length": null,
286
+ "packing_num_proc": 1,
287
+ "lazy_tokenize": false,
288
+ "use_hf": true,
289
+ "ignore_args_error": false,
290
+ "use_swift_lora": false,
291
+ "freeze_parameters": [],
292
+ "freeze_parameters_regex": null,
293
+ "freeze_parameters_ratio": 0.0,
294
+ "trainable_parameters": [],
295
+ "trainable_parameters_regex": null,
296
+ "freeze_llm": false,
297
+ "freeze_vit": true,
298
+ "freeze_aligner": true,
299
+ "target_modules": [
300
+ "all-linear"
301
+ ],
302
+ "target_regex": null,
303
+ "target_parameters": null,
304
+ "modules_to_save": [],
305
+ "lora_rank": 8,
306
+ "lora_alpha": 32,
307
+ "lora_dropout": 0.05,
308
+ "lora_bias": "none",
309
+ "lora_dtype": null,
310
+ "lorap_lr_ratio": null,
311
+ "use_rslora": false,
312
+ "use_dora": false,
313
+ "lora_ga_batch_size": 2,
314
+ "lora_ga_iters": 2,
315
+ "lora_ga_max_length": 1024,
316
+ "lora_ga_direction": "ArB2r",
317
+ "lora_ga_scale": "stable",
318
+ "lora_ga_stable_gamma": 16,
319
+ "init_weights": true,
320
+ "fourier_n_frequency": 2000,
321
+ "fourier_scaling": 300.0,
322
+ "boft_block_size": 4,
323
+ "boft_block_num": 0,
324
+ "boft_n_butterfly_factor": 1,
325
+ "boft_dropout": 0.0,
326
+ "vera_rank": 256,
327
+ "vera_projection_prng_key": 0,
328
+ "vera_dropout": 0.0,
329
+ "vera_d_initial": 0.1,
330
+ "adapter_act": "gelu",
331
+ "adapter_length": 128,
332
+ "adalora_target_r": 8,
333
+ "adalora_init_r": 12,
334
+ "adalora_tinit": 0,
335
+ "adalora_tfinal": 0,
336
+ "adalora_deltaT": 1,
337
+ "adalora_beta1": 0.85,
338
+ "adalora_beta2": 0.85,
339
+ "adalora_orth_reg_weight": 0.5,
340
+ "llamapro_num_new_blocks": 4,
341
+ "llamapro_num_groups": null,
342
+ "reft_layer_key": null,
343
+ "reft_layers": null,
344
+ "reft_rank": 4,
345
+ "reft_intervention_type": "LoreftIntervention",
346
+ "reft_args": null,
347
+ "swanlab_token": null,
348
+ "swanlab_project": "ms-swift",
349
+ "swanlab_workspace": null,
350
+ "swanlab_exp_name": null,
351
+ "swanlab_notification_method": null,
352
+ "swanlab_webhook_url": null,
353
+ "swanlab_secret": null,
354
+ "swanlab_sender_email": null,
355
+ "swanlab_receiver_email": null,
356
+ "swanlab_smtp_server": null,
357
+ "swanlab_smtp_port": null,
358
+ "swanlab_email_language": "zh",
359
+ "swanlab_mode": "cloud",
360
+ "add_version": true,
361
+ "create_checkpoint_symlink": false,
362
+ "zero_hpz_partition_size": null,
363
+ "deepspeed_autotp_size": null,
364
+ "swift_version": "4.0.0.dev0",
365
+ "ckpt_dir": null,
366
+ "rank": 0,
367
+ "global_world_size": 8,
368
+ "local_world_size": 8,
369
+ "model_suffix": "LocoOperator-4B",
370
+ "model_info": "ModelInfo(model_type='qwen3', model_dir='/home/shadeform/.cache/huggingface/hub/models--LocoreMind--LocoOperator-4B/snapshots/7224ae265a69ec46e5142d29130412073a8b6173', torch_dtype=torch.bfloat16, max_model_len=262144, quant_method=None, quant_bits=None, rope_scaling={'rope_theta': 5000000, 'rope_type': 'default'}, is_moe_model=False, is_multimodal=False, config=None, task_type='causal_lm', num_labels=None)",
371
+ "model_meta": "ModelMeta(model_type='qwen3', model_groups=[ModelGroup(models=[Model(ms_model_id='Qwen/Qwen3-0.6B-Base', hf_model_id='Qwen/Qwen3-0.6B-Base', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-1.7B-Base', hf_model_id='Qwen/Qwen3-1.7B-Base', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-4B-Base', hf_model_id='Qwen/Qwen3-4B-Base', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-8B-Base', hf_model_id='Qwen/Qwen3-8B-Base', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-14B-Base', hf_model_id='Qwen/Qwen3-14B-Base', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-0.6B', hf_model_id='Qwen/Qwen3-0.6B', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-1.7B', hf_model_id='Qwen/Qwen3-1.7B', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-4B', hf_model_id='Qwen/Qwen3-4B', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-8B', hf_model_id='Qwen/Qwen3-8B', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-14B', hf_model_id='Qwen/Qwen3-14B', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-32B', hf_model_id='Qwen/Qwen3-32B', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-0.6B-FP8', hf_model_id='Qwen/Qwen3-0.6B-FP8', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-1.7B-FP8', hf_model_id='Qwen/Qwen3-1.7B-FP8', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-4B-FP8', hf_model_id='Qwen/Qwen3-4B-FP8', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-8B-FP8', hf_model_id='Qwen/Qwen3-8B-FP8', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-14B-FP8', hf_model_id='Qwen/Qwen3-14B-FP8', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-32B-FP8', hf_model_id='Qwen/Qwen3-32B-FP8', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-4B-AWQ', hf_model_id='Qwen/Qwen3-4B-AWQ', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-8B-AWQ', hf_model_id='Qwen/Qwen3-8B-AWQ', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-14B-AWQ', hf_model_id='Qwen/Qwen3-14B-AWQ', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-32B-AWQ', hf_model_id='Qwen/Qwen3-32B-AWQ', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='swift/Qwen3-32B-AWQ', hf_model_id=None, model_path=None, ms_revision=None, hf_revision=None)], template='qwen3', ignore_patterns=None, requires=None, tags=[]), ModelGroup(models=[Model(ms_model_id='deepseek-ai/DeepSeek-R1-0528-Qwen3-8B', hf_model_id='deepseek-ai/DeepSeek-R1-0528-Qwen3-8B', model_path=None, ms_revision=None, hf_revision=None)], template='deepseek_r1', ignore_patterns=None, requires=None, tags=[]), ModelGroup(models=[Model(ms_model_id='Qwen/Qwen3Guard-Gen-0.6B', hf_model_id='Qwen/Qwen3Guard-Gen-0.6B', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3Guard-Gen-4B', hf_model_id='Qwen/Qwen3Guard-Gen-4B', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3Guard-Gen-8B', hf_model_id='Qwen/Qwen3Guard-Gen-8B', model_path=None, ms_revision=None, hf_revision=None)], template='qwen3_guard', ignore_patterns=None, requires=None, tags=[]), ModelGroup(models=[Model(ms_model_id='Qwen/Qwen3-4B-Thinking-2507', hf_model_id='Qwen/Qwen3-4B-Thinking-2507', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-4B-Thinking-2507-FP8', hf_model_id='Qwen/Qwen3-4B-Thinking-2507-FP8', model_path=None, ms_revision=None, hf_revision=None)], template='qwen3_thinking', ignore_patterns=None, requires=None, tags=[]), ModelGroup(models=[Model(ms_model_id='Qwen/Qwen3-4B-Instruct-2507', hf_model_id='Qwen/Qwen3-4B-Instruct-2507', model_path=None, ms_revision=None, hf_revision=None), Model(ms_model_id='Qwen/Qwen3-4B-Instruct-2507-FP8', hf_model_id='Qwen/Qwen3-4B-Instruct-2507-FP8', model_path=None, ms_revision=None, hf_revision=None)], template='qwen3_nothinking', ignore_patterns=None, requires=None, tags=[])], loader=<class 'swift.model.register.ModelLoader'>, template=None, model_arch=ModelKeys(arch_name='llama', embedding='model.embed_tokens', module_list='model.layers', lm_head='lm_head', q_proj='model.layers.{}.self_attn.q_proj', k_proj='model.layers.{}.self_attn.k_proj', v_proj='model.layers.{}.self_attn.v_proj', o_proj='model.layers.{}.self_attn.o_proj', attention='model.layers.{}.self_attn', mlp='model.layers.{}.mlp', down_proj='model.layers.{}.mlp.down_proj', qkv_proj=None, qk_proj=None, qa_proj=None, qb_proj=None, kv_proj=None, kva_proj=None, kvb_proj=None), architectures=['Qwen3ForCausalLM'], additional_saved_files=[], torch_dtype=None, is_multimodal=False, is_reward=False, task_type=None, ignore_patterns=None, requires=['transformers>=4.51'], tags=[])",
372
+ "model_dir": "/home/shadeform/.cache/huggingface/hub/models--LocoreMind--LocoOperator-4B/snapshots/7224ae265a69ec46e5142d29130412073a8b6173",
373
+ "template_meta": "QwenTemplateMeta(template_type='qwen3_nothinking', prefix=[], prompt=['<|im_start|>user\\n{{QUERY}}<|im_end|>\\n<|im_start|>assistant\\n'], chat_sep=['<|im_end|>\\n'], suffix=['<|im_end|>\\n'], template_cls=<class 'swift.template.base.Template'>, system_prefix=['<|im_start|>system\\n{{SYSTEM}}<|im_end|>\\n'], default_system=None, auto_add_bos=False, stop_words=['<|endoftext|>'], agent_template='hermes', is_thinking=False, thinking_prefix='', non_thinking_prefix='', history_thinking_prefix='')",
374
+ "_val_dataset_exists": false,
375
+ "hub": "<class 'swift.hub.hub.HFHub'>",
376
+ "evaluation_strategy": "steps",
377
+ "training_args": "Seq2SeqTrainingArguments(output_dir='/ephemeral/ms-swift/output/locooperator-4b-msswift-analysis-8xh100-65k/v2-20260303-195906', per_device_train_batch_size=1, num_train_epochs=1.0, max_steps=-1, learning_rate=2e-05, lr_scheduler_type=<SchedulerType.COSINE: 'cosine'>, lr_scheduler_kwargs=None, warmup_steps=0.03, optim=<OptimizerNames.ADAMW_TORCH_FUSED: 'adamw_torch_fused'>, optim_args=None, weight_decay=0.1, adam_beta1=0.9, adam_beta2=0.95, adam_epsilon=1e-08, optim_target_modules=None, gradient_accumulation_steps=4, average_tokens_across_devices=None, max_grad_norm=1.0, label_smoothing_factor=0.0, bf16=True, fp16=False, bf16_full_eval=False, fp16_full_eval=False, tf32=None, gradient_checkpointing=True, gradient_checkpointing_kwargs={'use_reentrant': False}, torch_compile=False, torch_compile_backend=None, torch_compile_mode=None, use_liger_kernel=False, liger_kernel_config=None, use_cache=False, neftune_noise_alpha=None, torch_empty_cache_steps=None, auto_find_batch_size=False, logging_strategy=<IntervalStrategy.STEPS: 'steps'>, logging_steps=10, logging_first_step=True, log_on_each_node=True, logging_nan_inf_filter=True, include_num_input_tokens_seen=None, log_level='passive', log_level_replica='warning', disable_tqdm=False, report_to=['tensorboard'], run_name='/ephemeral/ms-swift/output/locooperator-4b-msswift-analysis-8xh100-65k/v2-20260303-195906', project='huggingface', trackio_space_id='trackio', eval_strategy=<IntervalStrategy.NO: 'no'>, eval_steps=200.0, eval_delay=0, per_device_eval_batch_size=1, prediction_loss_only=False, eval_on_start=False, eval_do_concat_batches=True, eval_use_gather_object=False, eval_accumulation_steps=None, include_for_metrics=[], batch_eval_metrics=False, save_only_model=False, save_strategy=<SaveStrategy.STEPS: 'steps'>, save_steps=200, save_on_each_node=False, save_total_limit=2, enable_jit_checkpoint=False, push_to_hub=False, hub_token=None, hub_private_repo=None, hub_model_id=None, hub_strategy=<HubStrategy.EVERY_SAVE: 'every_save'>, hub_always_push=False, hub_revision=None, load_best_model_at_end=False, metric_for_best_model='loss', greater_is_better=False, ignore_data_skip=False, restore_callback_states_from_checkpoint=False, full_determinism=False, seed=42, data_seed=42, use_cpu=False, accelerator_config=AcceleratorConfig(split_batches=False, dispatch_batches=False, even_batches=True, use_seedable_sampler=True, non_blocking=False, gradient_accumulation_kwargs=None, use_configured_state=False), parallelism_config=None, dataloader_drop_last=False, dataloader_num_workers=32, dataloader_pin_memory=True, dataloader_persistent_workers=False, dataloader_prefetch_factor=2, remove_unused_columns=False, label_names=None, train_sampling_strategy='random', length_column_name='length', ddp_find_unused_parameters=None, ddp_bucket_cap_mb=None, ddp_broadcast_buffers=None, ddp_backend=None, ddp_timeout=18000000, fsdp=[], fsdp_config={'min_num_params': 0, 'xla': False, 'xla_fsdp_v2': False, 'xla_fsdp_grad_ckpt': False}, deepspeed={'fp16': {'enabled': 'auto', 'loss_scale': 0, 'loss_scale_window': 1000, 'initial_scale_power': 16, 'hysteresis': 2, 'min_loss_scale': 1}, 'bf16': {'enabled': 'auto'}, 'zero_optimization': {'stage': 3, 'offload_optimizer': {'device': 'cpu', 'pin_memory': True}, 'offload_param': {'device': 'cpu', 'pin_memory': True}, 'overlap_comm': False, 'contiguous_gradients': True, 'sub_group_size': 1000000000.0, 'reduce_bucket_size': 'auto', 'stage3_prefetch_bucket_size': 'auto', 'stage3_param_persistence_threshold': 'auto', 'stage3_max_live_parameters': 1000000000.0, 'stage3_max_reuse_distance': 1000000000.0, 'stage3_gather_16bit_weights_on_model_save': True}, 'gradient_accumulation_steps': 'auto', 'gradient_clipping': 'auto', 'steps_per_print': 2000, 'train_batch_size': 'auto', 'train_micro_batch_size_per_gpu': 'auto', 'wall_clock_breakdown': False}, debug=[], skip_memory_metrics=True, do_train=False, do_eval=False, do_predict=False, resume_from_checkpoint='/ephemeral/ms-swift/output/locooperator-4b-msswift-analysis-8xh100-65k/v0-20260303-141105/checkpoint-100', warmup_ratio=0.03, logging_dir='/ephemeral/ms-swift/output/locooperator-4b-msswift-analysis-8xh100-65k/v2-20260303-195906/runs', local_rank=0, sortish_sampler=False, predict_with_generate=False, generation_max_length=None, generation_num_beams=None, generation_config=None, tuner_backend='peft', vit_gradient_checkpointing=True, router_aux_loss_coef=0.0, enable_dft_loss=False, enable_channel_loss=False, check_model=True, acc_strategy='token', train_dataloader_shuffle=True, group_by_length=False, max_epochs=None, aligner_lr=None, vit_lr=None, use_logits_to_keep=None, ds3_gather_for_generation=True, resume_only_model=False, optimizer=None, loss_type=None, eval_metric=None, callbacks=[], early_stop_interval=None, eval_use_evalscope=False, eval_dataset=[], eval_dataset_args=None, eval_limit=None, eval_generation_config=None, extra_eval_args=None, tuner_type='full', use_galore=False, galore_target_modules=None, galore_rank=128, galore_update_proj_gap=50, galore_scale=1.0, galore_proj_type='std', galore_optim_per_parameter=False, galore_with_embedding=False, galore_quantization=False, galore_proj_quant=False, galore_proj_bits=4, galore_proj_group_size=256, galore_cos_threshold=0.4, galore_gamma_proj=2, galore_queue_size=5, lisa_activated_layers=0, lisa_step_interval=20, use_flash_ckpt=False)"
378
+ }
chat_template.jinja ADDED
@@ -0,0 +1,61 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ {%- if tools %}
2
+ {{- '<|im_start|>system\n' }}
3
+ {%- if messages[0].role == 'system' %}
4
+ {{- messages[0].content + '\n\n' }}
5
+ {%- endif %}
6
+ {{- "# Tools\n\nYou may call one or more functions to assist with the user query.\n\nYou are provided with function signatures within <tools></tools> XML tags:\n<tools>" }}
7
+ {%- for tool in tools %}
8
+ {{- "\n" }}
9
+ {{- tool | tojson }}
10
+ {%- endfor %}
11
+ {{- "\n</tools>\n\nFor each function call, return a json object with function name and arguments within <tool_call></tool_call> XML tags:\n<tool_call>\n{\"name\": <function-name>, \"arguments\": <args-json-object>}\n</tool_call><|im_end|>\n" }}
12
+ {%- else %}
13
+ {%- if messages[0].role == 'system' %}
14
+ {{- '<|im_start|>system\n' + messages[0].content + '<|im_end|>\n' }}
15
+ {%- endif %}
16
+ {%- endif %}
17
+ {%- for message in messages %}
18
+ {%- if message.content is string %}
19
+ {%- set content = message.content %}
20
+ {%- else %}
21
+ {%- set content = '' %}
22
+ {%- endif %}
23
+ {%- if (message.role == "user") or (message.role == "system" and not loop.first) %}
24
+ {{- '<|im_start|>' + message.role + '\n' + content + '<|im_end|>' + '\n' }}
25
+ {%- elif message.role == "assistant" %}
26
+ {{- '<|im_start|>' + message.role + '\n' + content }}
27
+ {%- if message.tool_calls %}
28
+ {%- for tool_call in message.tool_calls %}
29
+ {%- if (loop.first and content) or (not loop.first) %}
30
+ {{- '\n' }}
31
+ {%- endif %}
32
+ {%- if tool_call.function %}
33
+ {%- set tool_call = tool_call.function %}
34
+ {%- endif %}
35
+ {{- '<tool_call>\n{"name": "' }}
36
+ {{- tool_call.name }}
37
+ {{- '", "arguments": ' }}
38
+ {%- if tool_call.arguments is string %}
39
+ {{- tool_call.arguments }}
40
+ {%- else %}
41
+ {{- tool_call.arguments | tojson }}
42
+ {%- endif %}
43
+ {{- '}\n</tool_call>' }}
44
+ {%- endfor %}
45
+ {%- endif %}
46
+ {{- '<|im_end|>\n' }}
47
+ {%- elif message.role == "tool" %}
48
+ {%- if loop.first or (messages[loop.index0 - 1].role != "tool") %}
49
+ {{- '<|im_start|>user' }}
50
+ {%- endif %}
51
+ {{- '\n<tool_response>\n' }}
52
+ {{- content }}
53
+ {{- '\n</tool_response>' }}
54
+ {%- if loop.last or (messages[loop.index0 + 1].role != "tool") %}
55
+ {{- '<|im_end|>\n' }}
56
+ {%- endif %}
57
+ {%- endif %}
58
+ {%- endfor %}
59
+ {%- if add_generation_prompt %}
60
+ {{- '<|im_start|>assistant\n' }}
61
+ {%- endif %}
config.json ADDED
@@ -0,0 +1,71 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ {
2
+ "architectures": [
3
+ "Qwen3ForCausalLM"
4
+ ],
5
+ "attention_bias": false,
6
+ "attention_dropout": 0.0,
7
+ "bos_token_id": null,
8
+ "dtype": "bfloat16",
9
+ "eos_token_id": 151645,
10
+ "head_dim": 128,
11
+ "hidden_act": "silu",
12
+ "hidden_size": 2560,
13
+ "initializer_range": 0.02,
14
+ "intermediate_size": 9728,
15
+ "layer_types": [
16
+ "full_attention",
17
+ "full_attention",
18
+ "full_attention",
19
+ "full_attention",
20
+ "full_attention",
21
+ "full_attention",
22
+ "full_attention",
23
+ "full_attention",
24
+ "full_attention",
25
+ "full_attention",
26
+ "full_attention",
27
+ "full_attention",
28
+ "full_attention",
29
+ "full_attention",
30
+ "full_attention",
31
+ "full_attention",
32
+ "full_attention",
33
+ "full_attention",
34
+ "full_attention",
35
+ "full_attention",
36
+ "full_attention",
37
+ "full_attention",
38
+ "full_attention",
39
+ "full_attention",
40
+ "full_attention",
41
+ "full_attention",
42
+ "full_attention",
43
+ "full_attention",
44
+ "full_attention",
45
+ "full_attention",
46
+ "full_attention",
47
+ "full_attention",
48
+ "full_attention",
49
+ "full_attention",
50
+ "full_attention",
51
+ "full_attention"
52
+ ],
53
+ "max_position_embeddings": 262144,
54
+ "max_window_layers": 36,
55
+ "model_type": "qwen3",
56
+ "num_attention_heads": 32,
57
+ "num_hidden_layers": 36,
58
+ "num_key_value_heads": 8,
59
+ "pad_token_id": 151643,
60
+ "rms_norm_eps": 1e-06,
61
+ "rope_parameters": {
62
+ "rope_theta": 5000000,
63
+ "rope_type": "default"
64
+ },
65
+ "sliding_window": null,
66
+ "tie_word_embeddings": true,
67
+ "transformers_version": "5.2.0",
68
+ "use_cache": false,
69
+ "use_sliding_window": false,
70
+ "vocab_size": 151936
71
+ }
generation_config.json ADDED
@@ -0,0 +1,13 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ {
2
+ "bos_token_id": 151643,
3
+ "do_sample": true,
4
+ "eos_token_id": [
5
+ 151645,
6
+ 151643
7
+ ],
8
+ "pad_token_id": 151643,
9
+ "temperature": 0.7,
10
+ "top_k": 20,
11
+ "top_p": 0.8,
12
+ "transformers_version": "5.2.0"
13
+ }
global_step406/bf16_zero_pp_rank_0_mp_rank_00_optim_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:7c8ee24909d2afee62f2f676939678af5839ce5e9b70fd688f8d103922b0b08f
3
+ size 6033707441
global_step406/bf16_zero_pp_rank_1_mp_rank_00_optim_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:1c0587d6b985faa7e235c7a1dddda9c294127ab09ebbdbfbb9532cba7c4ceb7c
3
+ size 6033707441
global_step406/bf16_zero_pp_rank_2_mp_rank_00_optim_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:44309e0cbbce68c148f797b0e6e5077f81f7580a370980cb9c01c1f7b6f7eb93
3
+ size 6033707441
global_step406/bf16_zero_pp_rank_3_mp_rank_00_optim_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:37eb23117f6918bf83d8614b429dafbdf7ae4567a8988c82d76d2c14fa008d34
3
+ size 6033707441
global_step406/bf16_zero_pp_rank_4_mp_rank_00_optim_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:cd1aba0419ad766e6af520f0056e33c415aabf19def24576f533baf44201e4b1
3
+ size 6033707441
global_step406/bf16_zero_pp_rank_5_mp_rank_00_optim_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:71feade1bbad88f56229034255cda38981a45c0603241bacad027498d80b0f68
3
+ size 6033707441
global_step406/bf16_zero_pp_rank_6_mp_rank_00_optim_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:8a9b92962a8638e472342d9f871abbc696531174d744b2443418204bc0e9196a
3
+ size 6033707441
global_step406/bf16_zero_pp_rank_7_mp_rank_00_optim_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:264bf538893c63078faefe3f252c1a7398f62c995e04bbcf89663c8062470b6d
3
+ size 6033707441
global_step406/zero_pp_rank_0_mp_rank_00_model_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:f2456492588fd95e8e4ef548cedfb3250f722a86b7302c9aebf6aed34b7af102
3
+ size 202703
global_step406/zero_pp_rank_1_mp_rank_00_model_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:30b178a236e72bf32eca8c0f33d92ef48722c0ac0aab5d01e72e19b77aee6c60
3
+ size 202639
global_step406/zero_pp_rank_2_mp_rank_00_model_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:8f6d37df503d49e12bcbcf67e1c800d880cb41ddb4b243e86d30725cc68a87b9
3
+ size 202639
global_step406/zero_pp_rank_3_mp_rank_00_model_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:0e5c5021b4b04c60645f26b11690719a091d22479ec1b15e712af6e029af02be
3
+ size 202639
global_step406/zero_pp_rank_4_mp_rank_00_model_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:cee2423038f83a49f0da5eb48130e9144bb550480614e68f8ee53e031203699b
3
+ size 202639
global_step406/zero_pp_rank_5_mp_rank_00_model_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:af99ec434ea0c23ff5670aa755e9d6ceb232170409c171308d877ce532fcf5f8
3
+ size 202639
global_step406/zero_pp_rank_6_mp_rank_00_model_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:6ab02c3062be034e027e8344bbb3f5248919ff4bf95b8ca94b053061b42952d2
3
+ size 202639
global_step406/zero_pp_rank_7_mp_rank_00_model_states.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:dcbc53a10ba4fddf16469d23ab481e03e70861cdedd0da9f0fa5c2bb74ae3d7e
3
+ size 202639
latest ADDED
@@ -0,0 +1 @@
 
 
1
+ global_step406
model.safetensors ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:63c90c20c45fb2da5284f966ef3a21215b44f71f270bd788cd28a97d45671c15
3
+ size 8044982080
rng_state_0.pth ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:f8f92cf63e0989759370d24108b469c492c12202403f036015307ce49f12cedc
3
+ size 16389
rng_state_1.pth ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:9ed40a0a4e9f365d2c6cc004d97e6705894eba46c8be4c160c1455bc3062dee1
3
+ size 16389
rng_state_2.pth ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:d688b304d19c260b5cfa471535ed51d7e1d60b3a0d0159dfd1a04b87904a9f42
3
+ size 16389
rng_state_3.pth ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:9967425ebcaee80d9b518fa0244d52f739b1b983d87cda71d5fede0c073e9d3b
3
+ size 16389
rng_state_4.pth ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:469900fd39c667ffbd49c3c407c0ba317a1e9f5f9339a99b5d38423b7d0ce6d4
3
+ size 16389
rng_state_5.pth ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:124688471ff2a6e80f2fcefedbf741fb18d08dd539d5bd07a52e81be545142a5
3
+ size 16389
rng_state_6.pth ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:1e69f1ced9f992a72c948698e5eb06088610788988cdb2fdbdd624e064319d60
3
+ size 16389
rng_state_7.pth ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:a376268a55d6ee10c371c06aa952334c4c6a1af9ea2d71b1951a57367a0c6722
3
+ size 16389
scheduler.pt ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:0f9c5a0ad884974bb90506c9f47bf9f52fc627353ab4f20092d330d5be54fa64
3
+ size 1465
tokenizer.json ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:be75606093db2094d7cd20f3c2f385c212750648bd6ea4fb2bf507a6a4c55506
3
+ size 11422650
tokenizer_config.json ADDED
@@ -0,0 +1,14 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ {
2
+ "add_prefix_space": false,
3
+ "backend": "tokenizers",
4
+ "bos_token": null,
5
+ "clean_up_tokenization_spaces": false,
6
+ "eos_token": "<|im_end|>",
7
+ "errors": "replace",
8
+ "is_local": true,
9
+ "model_max_length": 1010000,
10
+ "pad_token": "<|endoftext|>",
11
+ "split_special_tokens": false,
12
+ "tokenizer_class": "Qwen2Tokenizer",
13
+ "unk_token": null
14
+ }
trainer_state.json ADDED
@@ -0,0 +1,362 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ {
2
+ "best_global_step": null,
3
+ "best_metric": null,
4
+ "best_model_checkpoint": null,
5
+ "epoch": 1.0,
6
+ "eval_steps": 100.0,
7
+ "global_step": 406,
8
+ "is_hyper_param_search": false,
9
+ "is_local_process_zero": true,
10
+ "is_world_process_zero": true,
11
+ "log_history": [
12
+ {
13
+ "epoch": 0.0024645717806531116,
14
+ "grad_norm": 4.4285664558410645,
15
+ "learning_rate": 1.5384615384615387e-06,
16
+ "loss": 0.35851195454597473,
17
+ "step": 1,
18
+ "token_acc": 0.9010631754678851
19
+ },
20
+ {
21
+ "epoch": 0.024645717806531114,
22
+ "grad_norm": 2.0952308177948,
23
+ "learning_rate": 1.5384615384615387e-05,
24
+ "loss": 0.35579657554626465,
25
+ "step": 10,
26
+ "token_acc": 0.8943837802540097
27
+ },
28
+ {
29
+ "epoch": 0.04929143561306223,
30
+ "grad_norm": 1.162745714187622,
31
+ "learning_rate": 1.9984348087759785e-05,
32
+ "loss": 0.3231017589569092,
33
+ "step": 20,
34
+ "token_acc": 0.9000949342463621
35
+ },
36
+ {
37
+ "epoch": 0.07393715341959335,
38
+ "grad_norm": 1.0469155311584473,
39
+ "learning_rate": 1.9907803587786273e-05,
40
+ "loss": 0.28833014965057374,
41
+ "step": 30,
42
+ "token_acc": 0.9078340515688281
43
+ },
44
+ {
45
+ "epoch": 0.09858287122612445,
46
+ "grad_norm": 0.9065660834312439,
47
+ "learning_rate": 1.976797992107587e-05,
48
+ "loss": 0.26889336109161377,
49
+ "step": 40,
50
+ "token_acc": 0.9149504419788507
51
+ },
52
+ {
53
+ "epoch": 0.12322858903265557,
54
+ "grad_norm": 0.9003399014472961,
55
+ "learning_rate": 1.9565770113518827e-05,
56
+ "loss": 0.23356928825378417,
57
+ "step": 50,
58
+ "token_acc": 0.9236266795610063
59
+ },
60
+ {
61
+ "epoch": 0.1478743068391867,
62
+ "grad_norm": 0.8582137823104858,
63
+ "learning_rate": 1.9302465638852484e-05,
64
+ "loss": 0.24206771850585937,
65
+ "step": 60,
66
+ "token_acc": 0.9218463180747745
67
+ },
68
+ {
69
+ "epoch": 0.1725200246457178,
70
+ "grad_norm": 1.0135269165039062,
71
+ "learning_rate": 1.897974817027588e-05,
72
+ "loss": 0.23689332008361816,
73
+ "step": 70,
74
+ "token_acc": 0.9239593434853264
75
+ },
76
+ {
77
+ "epoch": 0.1971657424522489,
78
+ "grad_norm": 0.8614147305488586,
79
+ "learning_rate": 1.8599678839938237e-05,
80
+ "loss": 0.22692694664001464,
81
+ "step": 80,
82
+ "token_acc": 0.9264865287496846
83
+ },
84
+ {
85
+ "epoch": 0.22181146025878004,
86
+ "grad_norm": 0.9398002028465271,
87
+ "learning_rate": 1.8164685074898737e-05,
88
+ "loss": 0.21968631744384765,
89
+ "step": 90,
90
+ "token_acc": 0.9295838807428485
91
+ },
92
+ {
93
+ "epoch": 0.24645717806531114,
94
+ "grad_norm": 0.7476951479911804,
95
+ "learning_rate": 1.7677545093633713e-05,
96
+ "loss": 0.2011038541793823,
97
+ "step": 100,
98
+ "token_acc": 0.9344147595660709
99
+ },
100
+ {
101
+ "epoch": 0.2711028958718423,
102
+ "grad_norm": 0.7503615617752075,
103
+ "learning_rate": 1.7141370162108973e-05,
104
+ "loss": 0.2057852029800415,
105
+ "step": 110,
106
+ "token_acc": 0.9330569189360355
107
+ },
108
+ {
109
+ "epoch": 0.2957486136783734,
110
+ "grad_norm": 0.9481154084205627,
111
+ "learning_rate": 1.6559584722744228e-05,
112
+ "loss": 0.17612676620483397,
113
+ "step": 120,
114
+ "token_acc": 0.9414746669207006
115
+ },
116
+ {
117
+ "epoch": 0.3203943314849045,
118
+ "grad_norm": 0.7433750629425049,
119
+ "learning_rate": 1.5935904523181872e-05,
120
+ "loss": 0.1758814573287964,
121
+ "step": 130,
122
+ "token_acc": 0.9421560794951352
123
+ },
124
+ {
125
+ "epoch": 0.3450400492914356,
126
+ "grad_norm": 0.83556067943573,
127
+ "learning_rate": 1.527431288454741e-05,
128
+ "loss": 0.16333937644958496,
129
+ "step": 140,
130
+ "token_acc": 0.9466238242526768
131
+ },
132
+ {
133
+ "epoch": 0.36968576709796674,
134
+ "grad_norm": 0.7809082269668579,
135
+ "learning_rate": 1.4579035260771374e-05,
136
+ "loss": 0.1606190323829651,
137
+ "step": 150,
138
+ "token_acc": 0.9473938285655826
139
+ },
140
+ {
141
+ "epoch": 0.3943314849044978,
142
+ "grad_norm": 0.8688177466392517,
143
+ "learning_rate": 1.3854512251457248e-05,
144
+ "loss": 0.15198636054992676,
145
+ "step": 160,
146
+ "token_acc": 0.9505260762845087
147
+ },
148
+ {
149
+ "epoch": 0.41897720271102895,
150
+ "grad_norm": 0.7590353488922119,
151
+ "learning_rate": 1.3105371240656894e-05,
152
+ "loss": 0.14457361698150634,
153
+ "step": 170,
154
+ "token_acc": 0.952075147520667
155
+ },
156
+ {
157
+ "epoch": 0.4436229205175601,
158
+ "grad_norm": 0.9393133521080017,
159
+ "learning_rate": 1.233639684269092e-05,
160
+ "loss": 0.15146660804748535,
161
+ "step": 180,
162
+ "token_acc": 0.9508095578367639
163
+ },
164
+ {
165
+ "epoch": 0.4682686383240912,
166
+ "grad_norm": 0.7637022733688354,
167
+ "learning_rate": 1.1552500343770658e-05,
168
+ "loss": 0.15038838386535644,
169
+ "step": 190,
170
+ "token_acc": 0.951290851489551
171
+ },
172
+ {
173
+ "epoch": 0.4929143561306223,
174
+ "grad_norm": 0.6834350824356079,
175
+ "learning_rate": 1.0758688334592034e-05,
176
+ "loss": 0.12394154071807861,
177
+ "step": 200,
178
+ "token_acc": 0.9598665193837932
179
+ },
180
+ {
181
+ "epoch": 0.5175600739371534,
182
+ "grad_norm": 0.7546061277389526,
183
+ "learning_rate": 9.960030734238672e-06,
184
+ "loss": 0.12569220066070558,
185
+ "step": 210,
186
+ "token_acc": 0.9589528875283819
187
+ },
188
+ {
189
+ "epoch": 0.5422057917436846,
190
+ "grad_norm": 0.779545783996582,
191
+ "learning_rate": 9.161628409619237e-06,
192
+ "loss": 0.12487788200378418,
193
+ "step": 220,
194
+ "token_acc": 0.9589421215806513
195
+ },
196
+ {
197
+ "epoch": 0.5668515095502157,
198
+ "grad_norm": 0.7616660594940186,
199
+ "learning_rate": 8.368580597247156e-06,
200
+ "loss": 0.11189166307449341,
201
+ "step": 230,
202
+ "token_acc": 0.9632912747367435
203
+ },
204
+ {
205
+ "epoch": 0.5914972273567468,
206
+ "grad_norm": 0.8745431303977966,
207
+ "learning_rate": 7.5859523354333695e-06,
208
+ "loss": 0.09375449419021606,
209
+ "step": 240,
210
+ "token_acc": 0.9687846226896224
211
+ },
212
+ {
213
+ "epoch": 0.6161429451632778,
214
+ "grad_norm": 0.9441593885421753,
215
+ "learning_rate": 6.818742114896185e-06,
216
+ "loss": 0.10027874708175659,
217
+ "step": 250,
218
+ "token_acc": 0.9676357965433932
219
+ },
220
+ {
221
+ "epoch": 0.640788662969809,
222
+ "grad_norm": 0.7328006625175476,
223
+ "learning_rate": 6.071849954397321e-06,
224
+ "loss": 0.09634994268417359,
225
+ "step": 260,
226
+ "token_acc": 0.9679430186907485
227
+ },
228
+ {
229
+ "epoch": 0.6654343807763401,
230
+ "grad_norm": 0.7206295728683472,
231
+ "learning_rate": 5.35004610529874e-06,
232
+ "loss": 0.1047346830368042,
233
+ "step": 270,
234
+ "token_acc": 0.9656306522961448
235
+ },
236
+ {
237
+ "epoch": 0.6900800985828712,
238
+ "grad_norm": 0.7431440353393555,
239
+ "learning_rate": 4.657940584917983e-06,
240
+ "loss": 0.0888257384300232,
241
+ "step": 280,
242
+ "token_acc": 0.9706398288469873
243
+ },
244
+ {
245
+ "epoch": 0.7147258163894024,
246
+ "grad_norm": 0.8753840327262878,
247
+ "learning_rate": 3.999953733266395e-06,
248
+ "loss": 0.09608613252639771,
249
+ "step": 290,
250
+ "token_acc": 0.969108049311095
251
+ },
252
+ {
253
+ "epoch": 0.7393715341959335,
254
+ "grad_norm": 0.6335790753364563,
255
+ "learning_rate": 3.380287981218536e-06,
256
+ "loss": 0.09120213985443115,
257
+ "step": 300,
258
+ "token_acc": 0.9703202351742667
259
+ },
260
+ {
261
+ "epoch": 0.7640172520024646,
262
+ "grad_norm": 0.785146176815033,
263
+ "learning_rate": 2.8029010104237786e-06,
264
+ "loss": 0.09605880975723266,
265
+ "step": 310,
266
+ "token_acc": 0.9673275924451842
267
+ },
268
+ {
269
+ "epoch": 0.7886629698089956,
270
+ "grad_norm": 0.6153045296669006,
271
+ "learning_rate": 2.2714804763824448e-06,
272
+ "loss": 0.08603854775428772,
273
+ "step": 320,
274
+ "token_acc": 0.9712083643140942
275
+ },
276
+ {
277
+ "epoch": 0.8133086876155268,
278
+ "grad_norm": 0.9868772029876709,
279
+ "learning_rate": 1.7894204561251416e-06,
280
+ "loss": 0.08434219360351562,
281
+ "step": 330,
282
+ "token_acc": 0.9721527649830232
283
+ },
284
+ {
285
+ "epoch": 0.8379544054220579,
286
+ "grad_norm": 0.5985115766525269,
287
+ "learning_rate": 1.359799770919238e-06,
288
+ "loss": 0.07187292575836182,
289
+ "step": 340,
290
+ "token_acc": 0.9767571751932819
291
+ },
292
+ {
293
+ "epoch": 0.862600123228589,
294
+ "grad_norm": 0.6144799590110779,
295
+ "learning_rate": 9.853623224511078e-07,
296
+ "loss": 0.08109406232833863,
297
+ "step": 350,
298
+ "token_acc": 0.9739249053643897
299
+ },
300
+ {
301
+ "epoch": 0.8872458410351202,
302
+ "grad_norm": 0.559677243232727,
303
+ "learning_rate": 6.684995680729489e-07,
304
+ "loss": 0.08470932245254517,
305
+ "step": 360,
306
+ "token_acc": 0.9718354862416234
307
+ },
308
+ {
309
+ "epoch": 0.9118915588416513,
310
+ "grad_norm": 0.7215991616249084,
311
+ "learning_rate": 4.1123524704133276e-07,
312
+ "loss": 0.07193084955215454,
313
+ "step": 370,
314
+ "token_acc": 0.9762649270830526
315
+ },
316
+ {
317
+ "epoch": 0.9365372766481824,
318
+ "grad_norm": 0.6857699155807495,
319
+ "learning_rate": 2.1521245529793732e-07,
320
+ "loss": 0.08433130979537964,
321
+ "step": 380,
322
+ "token_acc": 0.9732891762933199
323
+ },
324
+ {
325
+ "epoch": 0.9611829944547134,
326
+ "grad_norm": 0.6883733868598938,
327
+ "learning_rate": 8.1683151343257e-08,
328
+ "loss": 0.07680711746215821,
329
+ "step": 390,
330
+ "token_acc": 0.9747542420637405
331
+ },
332
+ {
333
+ "epoch": 0.9858287122612446,
334
+ "grad_norm": 0.6657755970954895,
335
+ "learning_rate": 1.150016022719691e-08,
336
+ "loss": 0.0683711290359497,
337
+ "step": 400,
338
+ "token_acc": 0.9770520741394528
339
+ }
340
+ ],
341
+ "logging_steps": 10,
342
+ "max_steps": 406,
343
+ "num_input_tokens_seen": 0,
344
+ "num_train_epochs": 1,
345
+ "save_steps": 100,
346
+ "stateful_callbacks": {
347
+ "TrainerControl": {
348
+ "args": {
349
+ "should_epoch_stop": false,
350
+ "should_evaluate": false,
351
+ "should_log": false,
352
+ "should_save": true,
353
+ "should_training_stop": true
354
+ },
355
+ "attributes": {}
356
+ }
357
+ },
358
+ "total_flos": 325926586712064.0,
359
+ "train_batch_size": 1,
360
+ "trial_name": null,
361
+ "trial_params": null
362
+ }
training_args.bin ADDED
@@ -0,0 +1,3 @@
 
 
 
 
1
+ version https://git-lfs.github.com/spec/v1
2
+ oid sha256:03b71e1c8a1b98adeb62ec7835a042441f17ddb6e348ccc7dfcdfca0d8728384
3
+ size 9233
zero_to_fp32.py ADDED
@@ -0,0 +1,760 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
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)