code: def test_sending_validator_instance_between_processes():
      alice = hivemind.DHT(start=True)
      bob = hivemind.DHT(
          start=True, initial_peers=alice.get_visible_maddrs()
      )
  
      alice.add_validators([SchemaValidator(SampleSchema)])
      bob.add_validators([SchemaValidator(SampleSchema)])
  
      assert bob.store(
          "experiment_name", b"foo_bar", get_dht_time() + 10
      )
      assert not bob.store("experiment_name", 777, get_dht_time() + 10)
      assert (
          alice.get("experiment_name", latest=True).value == b"foo_bar"
      )
  
      alice.shutdown()
      bob.shutdown()
  
file_path: hivemind/tests/test_dht_schema.py
imports: import asyncio
  from typing import Dict
  import pytest
  from pydantic import BaseModel, StrictInt, conint
  import hivemind
  from hivemind.dht.node import DHTNode
  from hivemind.dht.schema import BytesWithPublicKey, SchemaValidator
  from hivemind.dht.validation import DHTRecord, RecordValidatorBase
  from hivemind.utils.timed_storage import get_dht_time
label_desc: Use image node_id 1 for calling a global function with example usage: test_sending_validator_instance_between_processes() without return types