yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-12 08:52:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor client rest apis

Browse Source
This commit is contained in:
Suresh Srinivas 2021-08-24 08:37:25 -07:00
parent 2af624a2d8
commit 723b9ba5d6
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ingestion/src/metadata/ingestion/sink/ldap_rest_users.py
View File

@ -61,4 +61,4 @@ class LdapRestUsersSink(Sink):
return self.status return self.status
def close(self): def close(self):
self.rest.close() pass

4
ingestion/src/metadata/ingestion/sink/metadata_rest_tables.py
View File

@ -68,7 +68,7 @@ class MetadataRestTablesSink(Sink):
if table_and_db.table.viewDefinition is not None and table_and_db.table.viewDefinition != "": if table_and_db.table.viewDefinition is not None and table_and_db.table.viewDefinition != "":
table_request.viewDefinition = table_and_db.table.viewDefinition.__root__ 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: 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) 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 return self.status
def close(self): def close(self):
self.client.close() pass

2
ingestion/src/metadata/ingestion/sink/metadata_rest_topics.py
View File

@ -65,4 +65,4 @@ class MetadataRestTopicsSink(Sink):
return self.status return self.status
def close(self): def close(self):
self.close() pass

2
ingestion/src/metadata/ingestion/sink/metadata_rest_users.py
View File

@ -96,4 +96,4 @@ class MetadataRestUsersSink(Sink):
return self.status return self.status
def close(self): def close(self):
self.rest.close() pass