File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
fast_llm/data/preparator/gpt_memmap Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -229,6 +229,7 @@ def run(self) -> None:
229
229
},
230
230
batched = False ,
231
231
desc = "Combining fields" ,
232
+ num_proc = self ._config .loading_workers ,
232
233
)
233
234
logger .info (f"Sample after combining fields:\n { dataset [0 ]} " )
234
235
self ._data_column = new_combined_column
@@ -237,11 +238,12 @@ def run(self) -> None:
237
238
dataset = dataset .map (
238
239
lambda example : {
239
240
loss_masking_column : [
240
- (0 , len (str ( example [source_schema .prompt_column ]) ) - 1 )
241
+ (0 , len (example [source_schema .prompt_column ]) - 1 )
241
242
]# spans are inclusive
242
243
},
243
244
batched = False ,
244
245
desc = "Setting loss masking spans" ,
246
+ num_proc = self ._config .loading_workers ,
245
247
)
246
248
logger .info (f"Sample after setting loss masking spans:\n { dataset [0 ]} " )
247
249
self ._loss_masking_spans_column = loss_masking_column
You can’t perform that action at this time.
0 commit comments