Avoid circular references to make GC's life a bit easier
This commit is contained in:
@@ -1,3 +1,5 @@
|
|||||||
|
import weakref
|
||||||
|
|
||||||
from ..transport import Transport
|
from ..transport import Transport
|
||||||
from ..exceptions import NotFoundError, TransportError
|
from ..exceptions import NotFoundError, TransportError
|
||||||
from .indices import IndicesClient
|
from .indices import IndicesClient
|
||||||
@@ -53,8 +55,9 @@ class Elasticsearch(object):
|
|||||||
self.transport = transport_class(_normalize_hosts(hosts), **kwargs)
|
self.transport = transport_class(_normalize_hosts(hosts), **kwargs)
|
||||||
|
|
||||||
# namespaced clients for compatibility with API names
|
# namespaced clients for compatibility with API names
|
||||||
self.indices = IndicesClient(self)
|
# use weakref to make GC's work a little easier
|
||||||
self.cluster = ClusterClient(self)
|
self.indices = IndicesClient(weakref.proxy(self))
|
||||||
|
self.cluster = ClusterClient(weakref.proxy(self))
|
||||||
|
|
||||||
def _bulk_body(self, body):
|
def _bulk_body(self, body):
|
||||||
# if not passed in a string, serialize items and join by newline
|
# if not passed in a string, serialize items and join by newline
|
||||||
|
|||||||
Reference in New Issue
Block a user