def __init__(self, hosts=None, transport_class=Transport, **kwargs):
        self.transport = transport_class(_normalize_hosts(hosts), **kwargs)

        # namespaced clients for compatibility with API names
        # use weakref to make GC's work a little easier
        self.indices = IndicesClient(weakref.proxy(self))
        self.ingest = IngestClient(weakref.proxy(self))
        self.cluster = ClusterClient(weakref.proxy(self))
        self.cat = CatClient(weakref.proxy(self))
        self.nodes = NodesClient(weakref.proxy(self))
        self.snapshot = SnapshotClient(weakref.proxy(self))
        self.tasks = TasksClient(weakref.proxy(self))
Calls all observers attached to the given subject.
dataset/ETHPy150Open elastic/elasticsearch-py/elasticsearch/client/__init__.py/Elasticsearch.__init__--crossover with--dataset/ETHPy150Open openstack/networking-cisco/networking_cisco/plugins/cisco/cfg_agent/service_helpers/service_helper.py/ServiceHelperBase.notify