Remove Provider Deprecations in Postgres (apache#44705)

* Remove Provider Deprecations in Postgres

* Add spelling wordlist

* Remove docs from removed operator

docs/apache-airflow-providers-postgres/operators/postgres_operator_howto_guide.rst

@@ -31,8 +31,8 @@ A task defined or implemented by a operator is a unit of work in your data pipel
 The purpose of this guide is to define tasks involving interactions with a PostgreSQL database with
 the :class:`~airflow.providers.common.sql.operators.SQLExecuteQueryOperator`.
 
-.. warning::
-    Previously, PostgresOperator was used to perform this kind of operation. But at the moment PostgresOperator is deprecated and will be removed in future versions of the provider. Please consider to switch to SQLExecuteQueryOperator as soon as possible.
+.. note::
+    Previously, PostgresOperator was used to perform this kind of operation. After deprecation this has been removed. Please use SQLExecuteQueryOperator instead.
 
 Common Database Operations with SQLExecuteQueryOperator
 -------------------------------------------------------

docs/spelling_wordlist.txt

@@ -684,6 +684,7 @@ getframe
 getint
 GetPartitions
 getsource
+getters
 gevent
 GH
 GiB

providers/src/airflow/providers/postgres/CHANGELOG.rst

@@ -27,6 +27,21 @@
 Changelog
 ---------
 
+main
+....
+
+Breaking changes
+~~~~~~~~~~~~~~~~
+
+.. warning::
+  All deprecated classes, parameters and features have been removed from the Postgres provider package.
+  The following breaking changes were introduced:
+
+  * Hooks
+     * The ``schema`` arg has been renamed to ``database`` as it contained the database name. Deprecated parameters, getters and setters have been removed. Please use ``database`` to set the database name.
+  * Operators
+     * Remove ``airflow.providers.postgres.operators.postgres.PostgresOperator``. Please use ``airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator`` instead.
+
 5.14.0
 ......
 

providers/src/airflow/providers/postgres/hooks/postgres.py

@@ -18,7 +18,6 @@
 from __future__ import annotations
 
 import os
-import warnings
 from collections.abc import Iterable
 from contextlib import closing
 from copy import deepcopy
@@ -27,11 +26,9 @@
 import psycopg2
 import psycopg2.extensions
 import psycopg2.extras
-from deprecated import deprecated
 from psycopg2.extras import DictCursor, NamedTupleCursor, RealDictCursor
 from sqlalchemy.engine import URL
 
-from airflow.exceptions import AirflowProviderDeprecationWarning
 from airflow.providers.common.sql.hooks.sql import DbApiHook
 
 if TYPE_CHECKING:
@@ -92,42 +89,12 @@ class PostgresHook(DbApiHook):
     def __init__(
         self, *args, options: str | None = None, enable_log_db_messages: bool = False, **kwargs
     ) -> None:
-        if "schema" in kwargs:
-            warnings.warn(
-                'The "schema" arg has been renamed to "database" as it contained the database name.'
-                'Please use "database" to set the database name.',
-                AirflowProviderDeprecationWarning,
-                stacklevel=2,
-            )
-            kwargs["database"] = kwargs["schema"]
         super().__init__(*args, **kwargs)
         self.conn: connection = None
         self.database: str | None = kwargs.pop("database", None)
         self.options = options
         self.enable_log_db_messages = enable_log_db_messages
 
-    @property
-    @deprecated(
-        reason=(
-            'The "schema" variable has been renamed to "database" as it contained the database name.'
-            'Please use "database" to get the database name.'
-        ),
-        category=AirflowProviderDeprecationWarning,
-    )
-    def schema(self):
-        return self.database
-
-    @schema.setter
-    @deprecated(
-        reason=(
-            'The "schema" variable has been renamed to "database" as it contained the database name.'
-            'Please use "database" to set the database name.'
-        ),
-        category=AirflowProviderDeprecationWarning,
-    )
-    def schema(self, value):
-        self.database = value
-
     @property
     def sqlalchemy_url(self) -> URL:
         conn = self.get_connection(self.get_conn_id())

providers/src/airflow/providers/postgres/provider.yaml

@@ -85,11 +85,6 @@ integrations:
     logo: /integration-logos/postgres/Postgres.png
     tags: [software]
 
-operators:
-  - integration-name: PostgreSQL
-    python-modules:
-      - airflow.providers.postgres.operators.postgres
-
 hooks:
   - integration-name: PostgreSQL
     python-modules:

providers/tests/postgres/hooks/test_postgres.py

@@ -25,7 +25,6 @@
 import psycopg2.extras
 import pytest
 
-from airflow.exceptions import AirflowProviderDeprecationWarning
 from airflow.models import Connection
 from airflow.providers.postgres.hooks.postgres import PostgresHook
 from airflow.utils.types import NOTSET
@@ -340,15 +339,6 @@ def test_get_uri_from_connection_with_database_override(self):
         )
         assert hook.get_uri() == "postgresql://login:password@host:1/database-override"
 
-    def test_schema_kwarg_database_kwarg_compatibility(self):
-        database = "database-override"
-        with pytest.warns(
-            AirflowProviderDeprecationWarning,
-            match='The "schema" arg has been renamed to "database" as it contained the database name.Please use "database" to set the database name.',
-        ):
-            hook = PostgresHook(schema=database)
-        assert hook.database == database
-
     @mock.patch("airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook")
     @pytest.mark.parametrize("aws_conn_id", [NOTSET, None, "mock_aws_conn"])
     @pytest.mark.parametrize("port", [5432, 5439, None])