(airflow) branch main updated: Removed deprecated code (#44700)

[po...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 7fde48d0983 Removed deprecated code (#44700)
7fde48d0983 is described below

commit 7fde48d0983bd442f1470c068a3bcc5defdb2a2f
Author: Ajit J Gupta <aj...@gmail.com>
AuthorDate: Fri Dec 6 17:32:33 2024 +0530

    Removed deprecated code (#44700)
---
 .../src/airflow/providers/apache/beam/CHANGELOG.rst   |  9 +++++++++
 .../airflow/providers/apache/beam/triggers/beam.py    | 19 -------------------
 2 files changed, 9 insertions(+), 19 deletions(-)

diff --git a/providers/src/airflow/providers/apache/beam/CHANGELOG.rst b/providers/src/airflow/providers/apache/beam/CHANGELOG.rst
index d5cdfa62370..b51e2a68285 100644
--- a/providers/src/airflow/providers/apache/beam/CHANGELOG.rst
+++ b/providers/src/airflow/providers/apache/beam/CHANGELOG.rst
@@ -26,6 +26,15 @@
 Changelog
 ---------
 
+main
+.....
+
+.. warning::
+  All deprecated classes, parameters, and features have been removed from the Airbyte provider package.
+  The following breaking changes were introduced:
+
+  * Removed ``BeamPipelineTrigger`` class from ``trigger``. Use the ``class:`airflow.providers.apache.beam.triggers.beam.BeamPythonPipelineTrigger`` class instead.
+
 5.9.1
 .....
 
diff --git a/providers/src/airflow/providers/apache/beam/triggers/beam.py b/providers/src/airflow/providers/apache/beam/triggers/beam.py
index 92c137d3bb3..3eb3611b613 100644
--- a/providers/src/airflow/providers/apache/beam/triggers/beam.py
+++ b/providers/src/airflow/providers/apache/beam/triggers/beam.py
@@ -21,10 +21,8 @@ import contextlib
 from collections.abc import AsyncIterator, Sequence
 from typing import IO, Any
 
-from deprecated import deprecated
 from google.cloud.dataflow_v1beta3 import ListJobsRequest
 
-from airflow.exceptions import AirflowProviderDeprecationWarning
 from airflow.providers.apache.beam.hooks.beam import BeamAsyncHook
 from airflow.providers.google.cloud.hooks.dataflow import AsyncDataflowHook
 from airflow.providers.google.cloud.hooks.gcs import GCSHook
@@ -289,20 +287,3 @@ class BeamJavaPipelineTrigger(BeamPipelineBaseTrigger):
         else:
             yield TriggerEvent({"status": "error", "message": "Operation failed"})
         return
-
-
-@deprecated(
-    reason="`BeamPipelineTrigger` is deprecated. Please use `BeamPythonPipelineTrigger`.",
-    category=AirflowProviderDeprecationWarning,
-)
-class BeamPipelineTrigger(BeamPythonPipelineTrigger):
-    """
-    Trigger to perform checking the Python pipeline status until it reaches terminate state.
-
-    This class is deprecated. Please use
-    :class:`airflow.providers.apache.beam.triggers.beam.BeamPythonPipelineTrigger`
-    instead.
-    """
-
-    def __init__(self, *args, **kwargs):
-        super().__init__(*args, **kwargs)