From 723b9ba5d6ef61e448047dd216bd2ff94ae9ef16 Mon Sep 17 00:00:00 2001
From: Suresh Srinivas <srini3005@gmail.com>
Date: Tue, 24 Aug 2021 08:37:25 -0700
Subject: [PATCH] Refactor client rest apis

---
 ingestion/src/metadata/ingestion/sink/ldap_rest_users.py      | 2 +-
 ingestion/src/metadata/ingestion/sink/metadata_rest_tables.py | 4 ++--
 ingestion/src/metadata/ingestion/sink/metadata_rest_topics.py | 2 +-
 ingestion/src/metadata/ingestion/sink/metadata_rest_users.py  | 2 +-
 4 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/ingestion/src/metadata/ingestion/sink/ldap_rest_users.py b/ingestion/src/metadata/ingestion/sink/ldap_rest_users.py
index 024860bf478..1cd422b23fd 100644
--- a/ingestion/src/metadata/ingestion/sink/ldap_rest_users.py
+++ b/ingestion/src/metadata/ingestion/sink/ldap_rest_users.py
@@ -61,4 +61,4 @@ class LdapRestUsersSink(Sink):
         return self.status
 
     def close(self):
-        self.rest.close()
+        pass
diff --git a/ingestion/src/metadata/ingestion/sink/metadata_rest_tables.py b/ingestion/src/metadata/ingestion/sink/metadata_rest_tables.py
index 2c89b5885a0..5afa84d54cb 100644
--- a/ingestion/src/metadata/ingestion/sink/metadata_rest_tables.py
+++ b/ingestion/src/metadata/ingestion/sink/metadata_rest_tables.py
@@ -68,7 +68,7 @@ class MetadataRestTablesSink(Sink):
             if table_and_db.table.viewDefinition is not None and table_and_db.table.viewDefinition != "":
                 table_request.viewDefinition = table_and_db.table.viewDefinition.__root__
 
-            created_table = self.rest.create_or_update_table(table_request)
+            created_table = self.client.create_or_update_table(table_request)
             if table_and_db.table.sampleData is not None:
                 self.client.ingest_sample_data(id=created_table.id, sample_data=table_and_db.table.sampleData)
 
@@ -86,4 +86,4 @@ class MetadataRestTablesSink(Sink):
         return self.status
 
     def close(self):
-        self.client.close()
+        pass
diff --git a/ingestion/src/metadata/ingestion/sink/metadata_rest_topics.py b/ingestion/src/metadata/ingestion/sink/metadata_rest_topics.py
index 51a2dd18321..232a79fa88a 100644
--- a/ingestion/src/metadata/ingestion/sink/metadata_rest_topics.py
+++ b/ingestion/src/metadata/ingestion/sink/metadata_rest_topics.py
@@ -65,4 +65,4 @@ class MetadataRestTopicsSink(Sink):
         return self.status
 
     def close(self):
-        self.close()
+        pass
diff --git a/ingestion/src/metadata/ingestion/sink/metadata_rest_users.py b/ingestion/src/metadata/ingestion/sink/metadata_rest_users.py
index 373ba3bc83b..58e6e21dff6 100644
--- a/ingestion/src/metadata/ingestion/sink/metadata_rest_users.py
+++ b/ingestion/src/metadata/ingestion/sink/metadata_rest_users.py
@@ -96,4 +96,4 @@ class MetadataRestUsersSink(Sink):
         return self.status
 
     def close(self):
-        self.rest.close()
+        pass