mirror of
https://github.com/nomic-ai/gpt4all.git
synced 2024-10-01 01:06:10 -04:00
71 lines
2.0 KiB
Python
71 lines
2.0 KiB
Python
|
import numpy as np
|
||
|
|
import glob
|
||
|
|
import os
|
||
|
|
import json
|
||
|
|
import jsonlines
|
||
|
|
import pandas as pd
|
||
|
|
|
||
|
|
|
||
|
|
prompt_generation_dir = "prompts-reponses"
|
||
|
|
for file in glob.glob(os.path.join(prompt_generation_dir, "*.jsonl")):
|
||
|
|
data = []
|
||
|
|
print(file)
|
||
|
|
with open(file) as f:
|
||
|
|
for line in f:
|
||
|
|
try:
|
||
|
|
contents = json.loads(line)
|
||
|
|
data.append(contents)
|
||
|
|
except BaseException:
|
||
|
|
pass
|
||
|
|
|
||
|
|
processed = []
|
||
|
|
|
||
|
|
for item in data:
|
||
|
|
if 'source' not in item:
|
||
|
|
item['source'] = 'unspecified'
|
||
|
|
if 'model_settings' in item:
|
||
|
|
item.pop('model_settings', None)
|
||
|
|
|
||
|
|
for key in list(item.keys()):
|
||
|
|
if key not in ['source', 'prompt', 'response']:
|
||
|
|
#print(item[key])
|
||
|
|
item.pop(key, None)
|
||
|
|
|
||
|
|
if isinstance(item['prompt'], dict):
|
||
|
|
if "value" in item["prompt"]:
|
||
|
|
item["prompt"] = item["prompt"]["value"]
|
||
|
|
elif "description" in item["prompt"]:
|
||
|
|
item["prompt"] = item["prompt"]["description"]
|
||
|
|
else:
|
||
|
|
continue
|
||
|
|
|
||
|
|
elif not isinstance(item['prompt'], str):
|
||
|
|
continue
|
||
|
|
|
||
|
|
if isinstance(item['response'], dict):
|
||
|
|
if "value" in item["response"]:
|
||
|
|
item["response"] = item["response"]["value"]
|
||
|
|
elif "description" in item["response"]:
|
||
|
|
item["response"] = item["response"]["description"]
|
||
|
|
else:
|
||
|
|
continue
|
||
|
|
elif not isinstance(item['response'], str):
|
||
|
|
continue
|
||
|
|
|
||
|
|
if item:
|
||
|
|
processed.append(item)
|
||
|
|
|
||
|
|
df = pd.DataFrame(processed)
|
||
|
|
prev_len = len(df)
|
||
|
|
|
||
|
|
# drop empty or null string
|
||
|
|
df = df.dropna(subset=['prompt', 'response'])
|
||
|
|
df = df[df['prompt'] != '']
|
||
|
|
df = df[df['response'] != '']
|
||
|
|
curr_len = len(df)
|
||
|
|
|
||
|
|
print(f"Removed {prev_len - curr_len} rows")
|
||
|
|
|
||
|
|
clean_name = file.split(".jsonl")[0] + "_clean.jsonl"
|
||
|
|
print(f"writing to {clean_name}")
|
||
|
|
df.to_json(clean_name, orient="records", lines=True)
|