class_docstr: A class to query states from data source, caches, and post-processes
  the entries.
class_docstr_tok: ["A","class","to","query","states","from","data","source",",","caches",",","and","post-processes","the","entries","."]
code: def data_source_client(self):
      return self._client
  
file_path: ray/python/ray/dashboard/state_aggregator.py
imports: import asyncio
  import logging
  from dataclasses import fields
  import dataclasses
  from itertools import islice
  from typing import List, Tuple, Optional
  from datetime import datetime
  from ray._private.ray_constants import env_integer
  from ray._private.profiling import chrome_tracing_dump
  import ray.dashboard.memory_utils
  from ray.util.state.common import protobuf_message_to_dict, ActorState, JobState, ListApiOptions, ListApiResponse, NodeState, ObjectState, PlacementGroupState, RuntimeEnvState, SummaryApiResponse, RAY_MAX_LIMIT_FROM_API_SERVER, SummaryApiOptions, TaskSummaries, StateSchema, SupportedFilterType, TaskState, WorkerState, StateSummary, ActorSummaries, ObjectSummaries, ClusterEventState, filter_fields, PredicateType, protobuf_to_task_state_dict
  from ray.util.state.state_manager import DataSourceUnavailable, StateDataSourceClient
  from ray.runtime_env import RuntimeEnv
  from ray.util.state.util import convert_string_to_type
label_desc: Use image node_id 2 for calling the StateAPIManager obj's underlying member method code with example usage: obj.data_source_client() and returns: self