88 lines
3.3 KiB
Python
Executable File
88 lines
3.3 KiB
Python
Executable File
#!/usr/bin/env python
|
|
# Copyright 2020 The HuggingFace Team. All rights reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
"""Fill examples with bitext up to max_tokens without breaking up examples.
|
|
[['I went', 'yo fui'],
|
|
['to the store', 'a la tienda']
|
|
]
|
|
=> ['I went to the store', 'yo fui a la tienda']
|
|
"""
|
|
|
|
import argparse
|
|
import shutil
|
|
from pathlib import Path
|
|
|
|
from tqdm import tqdm
|
|
|
|
from transformers import AutoTokenizer
|
|
|
|
|
|
def pack_examples(tok, src_examples, tgt_examples, max_tokens=1024):
|
|
finished_src, finished_tgt = [], []
|
|
|
|
sorted_examples = list(zip(src_examples, tgt_examples))
|
|
new_src, new_tgt = sorted_examples[0]
|
|
|
|
def is_too_big(strang):
|
|
return tok(strang, return_tensors="pt").input_ids.shape[1] > max_tokens
|
|
|
|
for src, tgt in tqdm(sorted_examples[1:]):
|
|
cand_src = new_src + " " + src
|
|
cand_tgt = new_tgt + " " + tgt
|
|
if is_too_big(cand_src) or is_too_big(cand_tgt): # cant fit, finalize example
|
|
finished_src.append(new_src)
|
|
finished_tgt.append(new_tgt)
|
|
new_src, new_tgt = src, tgt
|
|
else: # can fit, keep adding
|
|
new_src, new_tgt = cand_src, cand_tgt
|
|
|
|
# cleanup
|
|
if new_src:
|
|
assert new_tgt
|
|
finished_src.append(new_src)
|
|
finished_tgt.append(new_tgt)
|
|
return finished_src, finished_tgt
|
|
|
|
|
|
def pack_data_dir(tok, data_dir: Path, max_tokens, save_path):
|
|
save_path = Path(save_path)
|
|
save_path.mkdir(exist_ok=True)
|
|
for split in ["train"]:
|
|
src_path, tgt_path = data_dir / f"{split}.source", data_dir / f"{split}.target"
|
|
src_docs = [x.rstrip() for x in Path(src_path).open().readlines()]
|
|
tgt_docs = [x.rstrip() for x in Path(tgt_path).open().readlines()]
|
|
packed_src, packed_tgt = pack_examples(tok, src_docs, tgt_docs, max_tokens)
|
|
print(f"packed {split} split from {len(src_docs)} examples -> {len(packed_src)}.")
|
|
Path(save_path / f"{split}.source").open("w").write("\n".join(packed_src))
|
|
Path(save_path / f"{split}.target").open("w").write("\n".join(packed_tgt))
|
|
for split in ["val", "test"]:
|
|
src_path, tgt_path = data_dir / f"{split}.source", data_dir / f"{split}.target"
|
|
shutil.copyfile(src_path, save_path / f"{split}.source")
|
|
shutil.copyfile(tgt_path, save_path / f"{split}.target")
|
|
|
|
|
|
def packer_cli():
|
|
parser = argparse.ArgumentParser()
|
|
parser.add_argument("--tok_name", type=str, help="like facebook/bart-large-cnn,t5-base, etc.")
|
|
parser.add_argument("--max_seq_len", type=int, default=128)
|
|
parser.add_argument("--data_dir", type=str)
|
|
parser.add_argument("--save_path", type=str)
|
|
args = parser.parse_args()
|
|
tokenizer = AutoTokenizer.from_pretrained(args.tok_name)
|
|
return pack_data_dir(tokenizer, Path(args.data_dir), args.max_seq_len, args.save_path)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
packer_cli()
|