refactor(supervised_finetuning): 重构 Chinese Instruct 数据集处理逻辑
This commit is contained in:
@@ -1,23 +1,14 @@
|
|||||||
from datasets import DatasetDict
|
from datasets import DatasetDict
|
||||||
from datasets import load_dataset, concatenate_datasets
|
from datasets import load_dataset, concatenate_datasets
|
||||||
from modules.utils import process_dataset
|
from modules.utils import process_dataset, comprehensive_normalization
|
||||||
|
|
||||||
|
|
||||||
def replace_seg(query:str, response:str) -> str:
|
|
||||||
replacements = {
|
|
||||||
"\\[": "$$", "\\]": "$$",
|
|
||||||
"\\(": "$", "\\)": "$"
|
|
||||||
}
|
|
||||||
for old, new in replacements.items():
|
|
||||||
query = query.replace(old, new)
|
|
||||||
response = response.replace(old, new)
|
|
||||||
|
|
||||||
return query, response
|
|
||||||
|
|
||||||
def process_func(input_dict: dict):
|
def process_func(input_dict: dict):
|
||||||
query = input_dict["prompt"] if input_dict["prompt"] else ""
|
query = input_dict["prompt"] if input_dict["prompt"] else ""
|
||||||
resp = input_dict["response"] if input_dict["response"] else ""
|
resp = input_dict["response"] if input_dict["response"] else ""
|
||||||
query, resp = replace_seg(query, resp)
|
|
||||||
|
query = comprehensive_normalization(query)
|
||||||
|
resp = comprehensive_normalization(resp)
|
||||||
|
|
||||||
return {"query": query, "response": resp }
|
return {"query": query, "response": resp }
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user