diff --git a/setup.py b/setup.py index 583eedd2..8a13bb7f 100644 --- a/setup.py +++ b/setup.py @@ -4,7 +4,7 @@ import os with open("README.md", "r") as fh: long_description = fh.read() -version = "0.0.0" +version = "0.2.1" setuptools.setup( name="trustgraph", diff --git a/trustgraph/embeddings_client.py b/trustgraph/embeddings_client.py index e464e02f..bac41074 100644 --- a/trustgraph/embeddings_client.py +++ b/trustgraph/embeddings_client.py @@ -20,6 +20,8 @@ class EmbeddingsClient: pulsar_host="pulsar://pulsar:6650", ): + self.client = None + if client_id == None: client_id = str(uuid.uuid4()) @@ -64,7 +66,6 @@ class EmbeddingsClient: def __del__(self): - self.producer.close() - self.consumer.close() - self.client.close() + if self.client: + self.client.close()