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(