code: def test_datasets_contains(client):
      key, value = "key", "value"
      client.publish_dataset(key=value)
      assert key in client.datasets
  
file_path: distributed/distributed/tests/test_publish.py
imports: from __future__ import annotations
  import asyncio
  import pytest
  from dask import delayed
  from distributed import Client
  from distributed.client import futures_of
  from distributed.metrics import time
  from distributed.protocol import Serialized
  from distributed.utils_test import gen_cluster, inc
label_desc: Use image node_id 8 for calling a global function with example usage: test_datasets_contains(client) without return types