yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2026-01-09 05:56:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix #5484: Postgress Connector Fix (#5485)

Browse Source
This commit is contained in:
Mayur Singal 2022-06-16 16:11:50 +05:30 committed by GitHub
parent 1883a670b9
commit 0ee87b2d99
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ingestion/src/metadata/ingestion/source/database/postgres.py
View File

@ -82,7 +82,7 @@ class PostgresSource(CommonDbSourceService):
f"Error trying to connect to database {new_database} - {err}"
)
def is_partition(self, table_name: str, schema: str, inspector) -> bool:
def is_partition(self, table_name: str, schema_name: str, inspector) -> bool:
cur = self.pgconn.cursor()
cur.execute(
"""
@ -92,7 +92,7 @@ class PostgresSource(CommonDbSourceService):
WHERE c.relname = %s
AND n.nspname = %s
""",
(table_name, schema),
(table_name, schema_name),
)
obj = cur.fetchone()
is_partition = obj[0] if obj else False