From 701accff10b9b03ba1e03d1d7238f7f3b3c6b84b Mon Sep 17 00:00:00 2001
From: Elad Kalif <45845474+eladkal@users.noreply.github.com>
Date: Thu, 25 Apr 2024 21:05:30 +0300
Subject: [PATCH] Fix schema assigment in PostgresOperator

---
 airflow/providers/postgres/operators/postgres.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/providers/postgres/operators/postgres.py b/airflow/providers/postgres/operators/postgres.py
index 44562c64db157..424a86b66690f 100644
--- a/airflow/providers/postgres/operators/postgres.py
+++ b/airflow/providers/postgres/operators/postgres.py
@@ -68,7 +68,7 @@ def __init__(
     ) -> None:
         if database is not None:
             hook_params = kwargs.pop("hook_params", {})
-            kwargs["hook_params"] = {"schema": database, **hook_params}
+            kwargs["hook_params"] = {"database": database, **hook_params}
 
         if runtime_parameters:
             warnings.warn(