code: def test_parallel_data_set_fill_up(include_prepended_source_length):
      batch_size = 32
      buckets = data_io.define_parallel_buckets(100, 100, 10, True, 1.0)
      bucket_batch_sizes = data_io.define_bucket_batch_sizes(
          buckets,
          batch_size,
          batch_type=C.BATCH_TYPE_SENTENCE,
          data_target_average_len=[None] * len(buckets),
      )
      dataset = data_io.ParallelDataSet(
          *_get_random_bucketed_data(
              buckets,
              min_count=1,
              max_count=5,
              include_prepended_source_length=include_prepended_source_length,
          )
      )
  
      dataset_filled_up = dataset.fill_up(bucket_batch_sizes)
      assert len(dataset_filled_up.source) == len(dataset.source)
      assert len(dataset_filled_up.target) == len(dataset.target)
      if include_prepended_source_length:
          assert len(dataset_filled_up.prepended_source_length) == len(
              dataset.prepended_source_length
          )
      for bidx in range(len(dataset)):
          bucket_batch_size = bucket_batch_sizes[bidx].batch_size
          assert (
              dataset_filled_up.source[bidx].shape[0]
              == bucket_batch_size
          )
          assert (
              dataset_filled_up.target[bidx].shape[0]
              == bucket_batch_size
          )
          if include_prepended_source_length:
              assert (
                  dataset_filled_up.prepended_source_length[bidx].shape[
                      0
                  ]
                  == bucket_batch_size
              )
  
imports: import os
  import random
  from tempfile import TemporaryDirectory
  from typing import Optional, List, Tuple
  import numpy
  import pytest
  import torch
  from sockeye import constants
  from sockeye import data_io
  from sockeye import utils
  from sockeye import vocab
  from sockeye.test_utils import tmp_digits_dataset
  from sockeye.utils import SockeyeError, get_tokens, seed_rngs
label_desc: Use image node_id 16 for calling a global function with example usage: test_parallel_data_set_fill_up(include_prepended_source_length) without return types