code: def test_read_sync_on_read_variable(self, strategy):
      # TODO(b/178943315): Enable test when the design in b/17894331 is
      # implemented.
      self.skipTest(
          "This test fails today due to issue in multiple workers trying to write"
          " to same file location: b/178943315"
      )
  
      class Model(tf.Module):
          def __init__(self):
              self.v = tf.Variable(
                  0.0,
                  synchronization=tf.VariableSynchronization.ON_READ,
                  aggregation=tf.VariableAggregation.SUM,
              )
  
          @tf.function(input_signature=[])
          def __call__(self):
              return self.v.read_value()
  
      export_dir = os.path.join(
          self._get_tempdir_path_test(), "test-file-failure"
      )
      with strategy.scope():
          m = Model()
          m.v.assign(1.0)
          # This fails when multiple workers try to write to the same file location.
          # b/178943315 for tracking this bug.
          tf.saved_model.save(m, export_dir)
  
imports: import os
  from absl.testing import parameterized
  import tensorflow
  import tensorflow.compat.v1
  from tensorflow.python.distribute import combinations
  from tensorflow.python.distribute import multi_worker_test_base
  from tensorflow.python.distribute import parameter_server_strategy_v2
  from tensorflow.python.distribute import sharded_variable
  from tensorflow.python.distribute import strategy_combinations
  from tensorflow.python.distribute import test_util
  from tensorflow.python.distribute import values
  from tensorflow.python.eager import context
  from tensorflow.python.eager import test
  from tensorflow.python.ops import lookup_ops
label_desc: Use image node_id 1 for calling the SaveModelForMultipleWorkers obj's underlying member method code with example usage: obj.test_read_sync_on_read_variable(strategy) and returns: self