code: def test_partition(self):
      distributor = MultiprocessingDistributor(n_workers=1)
  
      data = [1, 3, 10, -10, 343.0]
      distro = distributor.partition(data, 3)
      self.assertEqual(next(distro), [1, 3, 10])
      self.assertEqual(next(distro), [-10, 343.0])
  
      data = np.arange(10)
      distro = distributor.partition(data, 2)
      self.assertEqual(next(distro), [0, 1])
      self.assertEqual(next(distro), [2, 3])
  
imports: import sys
  from unittest import TestCase, skipIf
  import numpy
  import pandas
  from distributed import Client, LocalCluster
  from tests.fixtures import DataTestCase
  from tsfresh import extract_features
  from tsfresh.utilities.distribution import ClusterDaskDistributor, LocalDaskDistributor, MultiprocessingDistributor
  from tsfresh.utilities.profiling import get_n_jobs, set_n_jobs
label_desc: Use image node_id 2 for calling the MultiprocessingDistributorTestCase obj's underlying member method code with example usage: obj.test_partition() without return types