updates for v4

finetune_large_mt5_sentencefix.gin

@@ -0,0 +1,41 @@
+from __gin__ import dynamic_registration
+import tasks
+
+import __main__ as train_script
+from t5.data import mixtures
+from t5x import models
+from t5x import partitioning
+from t5x import utils
+
+include "t5x/examples/t5/mt5/small.gin"
+include "t5x/configs/runs/finetune.gin"
+
+MIXTURE_OR_TASK_NAME = "sentencefix"
+TASK_FEATURE_LENGTHS = {"inputs": 256, "targets": 256}
+TRAIN_STEPS = 1_100_000  # 1000000 pre-trained steps + 20000 fine-tuning steps.
+USE_CACHED_TASKS = False
+DROPOUT_RATE = 0.0
+RANDOM_SEED = 0
+
+# `LOSS_NORMALIZING_FACTOR`: When fine-tuning a model that was pre-trained
+# using Mesh Tensorflow (e.g. the public T5 / mT5 / ByT5 models), this should be
+# set to `pretraining batch_size` * `target_token_length`. For T5 and T5.1.1:
+# `2048 * 114`. For mT5: `1024 * 229`. For ByT5: `1024 * 189`.
+#LOSS_NORMALIZING_FACTOR = 234496
+INITIAL_CHECKPOINT_PATH = "gs://t5-data/pretrained_models/t5x/mt5_large/checkpoint_1000000"
+
+train_script.train:
+  eval_period = 500
+  partitioner = @partitioning.ModelBasedPjitPartitioner()
+
+# `num_decodes` is equivalent to a beam size in a beam search decoding.
+models.EncoderDecoderModel.predict_batch_with_aux.num_decodes = 4
+
+partitioning.ModelBasedPjitPartitioner.num_partitions = 2
+
+
+#from t5.models import mesh_transformer
+#import t5.models
+#mesh_transformer.learning_rate_schedules.constant_learning_rate.learning_rate = 0.0005
+#run.learning_rate_schedule = @learning_rate_schedules.constant_learning_rate
+

finetune_mt5_sentencefix.gin

@@ -12,7 +12,7 @@ include "t5x/configs/runs/finetune.gin"
 
 MIXTURE_OR_TASK_NAME = "sentencefix"
 TASK_FEATURE_LENGTHS = {"inputs": 256, "targets": 256}
-TRAIN_STEPS = 1_100_000  # 1000000 pre-trained steps + 20000 fine-tuning steps.
+TRAIN_STEPS = 1_100_050  # 1000000 pre-trained steps + 20000 fine-tuning steps.
 USE_CACHED_TASKS = False
 DROPOUT_RATE = 0.0
 RANDOM_SEED = 0

finetune_mt5_sentencefix_v4.gin

@@ -0,0 +1,41 @@
+from __gin__ import dynamic_registration
+import tasksv4
+
+import __main__ as train_script
+from t5.data import mixtures
+from t5x import models
+from t5x import partitioning
+from t5x import utils
+
+include "t5x/examples/t5/mt5/base.gin"
+include "t5x/configs/runs/finetune.gin"
+
+MIXTURE_OR_TASK_NAME = "sentencefix"
+TASK_FEATURE_LENGTHS = {"inputs": 256, "targets": 256}
+TRAIN_STEPS = 1_100_050  # 1000000 pre-trained steps + 20000 fine-tuning steps.
+USE_CACHED_TASKS = False
+DROPOUT_RATE = 0.0
+RANDOM_SEED = 0
+
+# `LOSS_NORMALIZING_FACTOR`: When fine-tuning a model that was pre-trained
+# using Mesh Tensorflow (e.g. the public T5 / mT5 / ByT5 models), this should be
+# set to `pretraining batch_size` * `target_token_length`. For T5 and T5.1.1:
+# `2048 * 114`. For mT5: `1024 * 229`. For ByT5: `1024 * 189`.
+LOSS_NORMALIZING_FACTOR = 234496
+INITIAL_CHECKPOINT_PATH = "gs://t5-data/pretrained_models/t5x/mt5_base/checkpoint_1000000"
+
+train_script.train:
+  eval_period = 500
+  partitioner = @partitioning.ModelBasedPjitPartitioner()
+
+# `num_decodes` is equivalent to a beam size in a beam search decoding.
+models.EncoderDecoderModel.predict_batch_with_aux.num_decodes = 4
+
+partitioning.ModelBasedPjitPartitioner.num_partitions = 2
+
+
+#from t5.models import mesh_transformer
+#import t5.models
+#mesh_transformer.learning_rate_schedules.constant_learning_rate.learning_rate = 0.0005
+#run.learning_rate_schedule = @learning_rate_schedules.constant_learning_rate
+

tasksv4.py

@@ -0,0 +1,65 @@
+# /home/perk/mymodel/sentencefix/tasks.py
+
+import functools
+import seqio
+import tensorflow_datasets as tfds
+from t5.evaluation import metrics
+from t5.data import preprocessors
+import t5
+import tensorflow.compat.v1 as tf
+
+tsv_path = {
+        "train": "gs://nb-t5x-us-central2/corpus/train/train.tsv",
+        "validation": "gs://nb-t5x-us-central2/corpus/eval/eval.tsv",
+        "test": "gs://nb-t5x-us-central2/corpus/test/test.tsv"
+}
+
+vocabulary = seqio.SentencePieceVocabulary(
+                'gs://t5-data/vocabs/mc4.250000.100extra/sentencepiece.model', extra_ids=0)
+
+DEFAULT_OUTPUT_FEATURES = {
+    "inputs":
+        seqio.Feature(
+            vocabulary=vocabulary, add_eos=True),
+    "targets":
+        seqio.Feature(
+            vocabulary=vocabulary, add_eos=True)
+}
+
+def sentencefix_preprocessor(ds):
+  def normalize_text(text):
+    """Lowercase and remove quotes from a TensorFlow string."""
+    text = tf.strings.regex_replace(text,"'(.*)'", r"\1")
+    return text
+
+  def to_inputs_and_targets(ex):
+    """Map {"source": ..., "source": ...}->{"target": ..., "target": ...}."""
+    return {
+        "inputs":
+             tf.strings.join(
+                 [normalize_text(ex["source"])]),
+        "targets": 
+	    tf.strings.join(
+                 [normalize_text(ex["target"])]),
+    }
+  return ds.map(to_inputs_and_targets, 
+                num_parallel_calls=tf.data.experimental.AUTOTUNE)
+
+
+seqio.TaskRegistry.add(
+    "sentencefix",
+    source=seqio.TextLineDataSource(
+        split_to_filepattern=tsv_path,
+        #num_input_examples=num_nq_examples
+        ),
+    preprocessors=[
+      functools.partial(
+          t5.data.preprocessors.parse_tsv,
+          field_names=["source", "target"]),
+      sentencefix_preprocessor,
+      seqio.preprocessors.tokenize_and_append_eos,
+    ],
+    #metric_fns=[t5.evaluation.metrics.bleu],
+    output_features=DEFAULT_OUTPUT_FEATURES,
+)
+

train_large.sh

@@ -0,0 +1,12 @@
+PROJECT_DIR=${HOME}"/models/multi-sentencefix-mt5"
+T5X_DIR="../../t5x"  # directory where the t5x is cloned.
+TFDS_DATA_DIR="gs://nb-t5x/corpus_multi_sentencefix_mt5"
+MODEL_DIR="gs://nb-t5x/large_model_multi_sentencefix_mt5"
+export PYTHONPATH=${PROJECT_DIR}
+
+python3 ${T5X_DIR}/t5x/train.py \
+  --gin_search_paths=${PROJECT_DIR} \
+  --gin_file="finetune_large_mt5_sentencefix.gin" \
+  --gin.MODEL_DIR="'${MODEL_DIR}'" \
+  --tfds_data_dir=${TFDS_DATA_DIR}
+

train_large_v4.sh

@@ -0,0 +1,12 @@
+PROJECT_DIR=${HOME}"/models/multi-sentencefix-mt5"
+T5X_DIR="../../t5x"  # directory where the t5x is cloned.
+TFDS_DATA_DIR="gs://nb-t5x-us-central2/corpus_multi_sentencefix_mt5"
+MODEL_DIR="gs://nb-t5x-us-central2/large_model_multi_sentencefix_mt5"
+export PYTHONPATH=${PROJECT_DIR}
+
+python3 ${T5X_DIR}/t5x/train.py \
+  --gin_search_paths=${PROJECT_DIR} \
+  --gin_file="finetune_large_mt5_sentencefix_v4.gin" \
+  --gin.MODEL_DIR="'${MODEL_DIR}'" \
+  --tfds_data_dir=${TFDS_DATA_DIR}
+

train_v4.sh

@@ -0,0 +1,12 @@
+PROJECT_DIR=${HOME}"/models/multi-sentencefix-mt5"
+T5X_DIR="../../t5x"  # directory where the t5x is cloned.
+TFDS_DATA_DIR="gs://nb-t5x-us-central2/corpus_multi_sentencefix_mt5"
+MODEL_DIR="gs://nb-t5x-us-central2/model_multi_sentencefix_mt5"
+export PYTHONPATH=${PROJECT_DIR}
+
+python3 ${T5X_DIR}/t5x/train.py \
+  --gin_search_paths=${PROJECT_DIR} \
+  --gin_file="finetune_mt5_sentencefix_v4.gin" \
+  --gin.MODEL_DIR="'${MODEL_DIR}'" \
+  --tfds_data_dir=${TFDS_DATA_DIR}
+