From 7fde48d0983bd442f1470c068a3bcc5defdb2a2f Mon Sep 17 00:00:00 2001
From: Ajit J Gupta <ajitg131@gmail.com>
Date: Fri, 6 Dec 2024 17:32:33 +0530
Subject: [PATCH] Removed deprecated code (#44700)

---
 .../providers/apache/beam/CHANGELOG.rst       |  9 +++++++++
 .../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 d5cdfa623700b..b51e2a6828580 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 92c137d3bb3e6..3eb3611b6139e 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 @@
 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 @@ async def run(self) -> AsyncIterator[TriggerEvent]:  # type: ignore[override]
         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)