code: def test_training_with_ndarry_distributed(self):
      keras_model = self.create_model()
      model = KerasModel(keras_model)
  
      x, y = self.create_training_data()
  
      model.fit(x, y, batch_size=4, distributed=True)
  
imports: import pytest
  from test.zoo.pipeline.utils.test_utils import ZooTestCase
  import tensorflow
  import numpy
  import os
  from zoo.tfpark import KerasModel, TFDataset, TFOptimizer
label_desc: Use image node_id 9 for calling the TestTFParkModel obj's underlying member method code with example usage: obj.test_training_with_ndarry_distributed() without return types