From 0ee87b2d99e8db07736f8b6ca8dc44af0b732518 Mon Sep 17 00:00:00 2001
From: Mayur Singal <39544459+ulixius9@users.noreply.github.com>
Date: Thu, 16 Jun 2022 16:11:50 +0530
Subject: [PATCH] Fix #5484: Postgress Connector Fix (#5485)

---
 ingestion/src/metadata/ingestion/source/database/postgres.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/ingestion/src/metadata/ingestion/source/database/postgres.py b/ingestion/src/metadata/ingestion/source/database/postgres.py
index 439f5ffbda7..7cec7d5ee10 100644
--- a/ingestion/src/metadata/ingestion/source/database/postgres.py
+++ b/ingestion/src/metadata/ingestion/source/database/postgres.py
@@ -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